java并发访问重复请求过滤问题
程序员文章站
2023-12-19 14:35:58
问题描述
前段时间遇到个问题,自己内部系统调用出现重复请求导致数据混乱。
发生条件:接受到一个请求,该请求没有执行完成又接受到相同请求,导致数据错误(如果是...
问题描述
前段时间遇到个问题,自己内部系统调用出现重复请求导致数据混乱。
发生条件:接受到一个请求,该请求没有执行完成又接受到相同请求,导致数据错误(如果是前一个请求执行完成,马上又接受相同请求不会有问题)
问题分析:是由于数据库的脏读导致
问题解决思路
1.加一把大大的锁 (是最简单的实现方式,但是性能堪忧,而且会阻塞请求)
2.实现请求拦截 (可以共用,但是怎么去实现却是一个问题,怎么用一个优雅的方式实现,并且方便复用)
3.修改实现 (会对原有代码做改动,存在风险,最主要的是不能共用)
最终实现方式
通过注解+spring aop 的方式实现
使用
通过在任意方法上添加注解notduplicate
类1:
import static java.lang.annotation.elementtype.method; import java.lang.annotation.documented; import java.lang.annotation.retention; import java.lang.annotation.retentionpolicy; import java.lang.annotation.target; @target({method}) @retention(retentionpolicy.runtime) @documented public @interface notduplicate { }
类2:
import java.lang.reflect.method; import java.util.set; import java.util.concurrent.concurrentskiplistset; import org.aspectj.lang.proceedingjoinpoint; import org.aspectj.lang.annotation.around; import org.aspectj.lang.annotation.aspect; import org.aspectj.lang.annotation.pointcut; import org.aspectj.lang.reflect.methodsignature; import org.springframework.stereotype.component; @aspect @component public class notduplicateaop { private static final set<string> key = new concurrentskiplistset<>(); @pointcut("@annotation(com.hhly.skeleton.base.filter.notduplicate)") public void duplicate() { } /** * 对方法拦截后进行参数验证 * @param pjp * @return * @throws throwable */ @around("duplicate()") public object duplicate(proceedingjoinpoint pjp) throws throwable { methodsignature msig = (methodsignature) pjp.getsignature(); method currentmethod = pjp.gettarget().getclass().getmethod(msig.getname(), msig.getparametertypes()); //拼接签名 stringbuilder sb = new stringbuilder(currentmethod.tostring()); object[] args = pjp.getargs(); for (object object : args) { if(object != null){ sb.append(object.getclass().tostring()); sb.append(object.tostring()); } } string sign = sb.tostring(); boolean success = key.add(sign); if(!success){ throw new serviceruntimeexception("该方法正在执行,不能重复请求"); } try { return pjp.proceed(); } finally { key.remove(sign); } } }
以上就是本次给大家讲述的全部内容以及相关代码,如果大家还有任何问题可以在下方的留言区讨论,感谢大家对的支持。