服务器之家

服务器之家 > 正文

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

时间:2021-05-06 11:09     来源/作者:u010704600

问题描述

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

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

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

问题解决思路

1.加一把大大的锁 (是最简单的实现方式,但是性能堪忧,而且会阻塞请求)

2.实现请求拦截 (可以共用,但是怎么去实现却是一个问题,怎么用一个优雅的方式实现,并且方便复用)

3.修改实现 (会对原有代码做改动,存在风险,最主要的是不能共用)

最终实现方式

通过注解+spring AOP 的方式实现

使用

通过在任意方法上添加注解NotDuplicate

类1:

java" id="highlighter_459420">
?
1
2
3
4
5
6
7
8
9
10
11
12
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:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
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);
    }
 
  }
}

以上就是本次给大家讲述的全部内容以及相关代码,如果大家还有任何问题可以在下方的留言区讨论,感谢大家对服务器之家的支持。

原文链接:https://blog.csdn.net/u010704600/article/details/77799169

标签:

相关文章

热门资讯

2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
Intellij idea2020永久破解,亲测可用!!!
Intellij idea2020永久破解,亲测可用!!! 2020-07-29
返回顶部