java并发访问重复请求过滤问题

本篇文章给大家分享了关于java并发访问重复请求过滤的相关问题以及解决方法,对此有需要的朋友参考学习下。

问题描述

前段时间遇到个问题,自己内部系统调用出现重复请求导致数据混乱。

发生条件:接受到一个请求,该请求没有执行完成又接受到相同请求,导致数据错误(如果是前一个请求执行完成,马上又接受相同请求不会有问题)

问题分析:是由于数据库的脏读导致

问题解决思路

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 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); } } }

以上就是java并发访问重复请求过滤问题的详细内容,更多请关注0133技术站其它相关文章!

赞(0) 打赏
未经允许不得转载:0133技术站首页 » Java