java并发访问重复请求过滤问题
问题描述
前段时间遇到个问题，自己内部系统调用出现重复请求导致数据混乱。
发生条件：接受到一个请求，该请求没有执行完成又接受到相同请求，导致数据错误（如果是前一个请求执行完成，马上又接受相同请求不会有问题）
问题分析：是由于数据库的脏读导致
问题解决思路
1.加一把大大的锁（是最简单的实现方式，但是性能堪忧，而且会阻塞请求）
2.实现请求拦截（可以共用，但是怎么去实现却是一个问题，怎么用一个优雅的方式实现，并且方便复用）
3.修改实现（会对原有代码做改动，存在风险，最主要的是不能共用）
最终实现方式
通过注解+springAOP的方式实现
使用
通过在任意方法上添加注解NotDuplicate
类1：
importstaticjava.lang.annotation.ElementType.METHOD;
importjava.lang.annotation.Documented;
importjava.lang.annotation.Retention;
importjava.lang.annotation.RetentionPolicy;
importjava.lang.annotation.Target;
@Target({METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public@interfaceNotDuplicate{
}
类2：
importjava.lang.reflect.Method;
importjava.util.Set;
importjava.util.concurrent.ConcurrentSkipListSet;
importorg.aspectj.lang.ProceedingJoinPoint;
importorg.aspectj.lang.annotation.Around;
importorg.aspectj.lang.annotation.Aspect;
importorg.aspectj.lang.annotation.Pointcut;
importorg.aspectj.lang.reflect.MethodSignature;
importorg.springframework.stereotype.Component;
@Aspect
@Component
publicclassNotDuplicateAop{
privatestaticfinalSetKEY=newConcurrentSkipListSet<>();
@Pointcut("@annotation(com.hhly.skeleton.base.filter.NotDuplicate)")
publicvoidduplicate(){
}
/**
*对方法拦截后进行参数验证
*@parampjp
*@return
*@throwsThrowable
*/
@Around("duplicate()")
publicObjectduplicate(ProceedingJoinPointpjp)throwsThrowable{
MethodSignaturemsig=(MethodSignature)pjp.getSignature();
MethodcurrentMethod=pjp.getTarget().getClass().getMethod(msig.getName(),msig.getParameterTypes());
//拼接签名
StringBuildersb=newStringBuilder(currentMethod.toString());
Object[]args=pjp.getArgs();
for(Objectobject:args){
if(object!=null){
sb.append(object.getClass().toString());
sb.append(object.toString());
}
}
Stringsign=sb.toString();
booleansuccess=KEY.add(sign);
if(!success){
thrownewServiceRuntimeException("该方法正在执行,不能重复请求");
}
try{
returnpjp.proceed();
}finally{
KEY.remove(sign);
}
}
}
以上就是本次给大家讲述的全部内容以及相关代码，如果大家还有任何问题可以在下方的留言区讨论，感谢大家对毛票票的支持。