切面实现下单请求防重提交功能（自定义注释@repeatSubmit） ...

该切面功能适用场景

• 下单请求多次提交，导致生成多个相同的订单
  

解决方案

• 前端解决：限制点击下单按钮为1次后失效。不足：用户体验下降，能绕过前端
  
• 后端解决：防重提交切面解决，自定义注释实现该功能（如下)
  
  
  
  • 步骤：
    
    
    
    • 自定义注释类RepeatSubmit
      
    • 创建切面并有该注释绑定，在切面类实现防重提交功能：
      
      
      
      • 方式一：引入redission进行加锁5秒，原理redis的setAbsent
        
      • 方式二：将token存入redis中，下单成功删除token,下单前需要调用获取token接口才能成功下单（类似于加锁，和方式一原理相同）
        
      
      
    
    
  
  
• RepeatSubmit
  

1. /**
2. * 自定义防重提交
3. */
4. @Documented
5. @Target(ElementType.METHOD)
6. @Retention(RetentionPolicy.RUNTIME)
7. public @interface RepeatSubmit {
8.     /**
9.      * 防重提交类型。  方法、令牌
10.      */
11.     enum Type {PARAM, TOKEN}
13.     /**
14.      * 默认防重提交，是方法参数
15.      * @return
16.      */
17.     Type limitType() default Type.PARAM;
19.     /**
20.      * 加锁过期时间，默认5秒
21.      * @return
22.      */
23.     long lockTime() default 5;
25. }

复制代码

• 自定义切面类
  

1. /**
2. * 定义一个切面类
3. */
4. @Aspect
5. @Component
6. @Slf4j
7. public class RepeatSubmitAspect {
9.     @Autowired
10.     private StringRedisTemplate redisTemplate;
12.     @Autowired
13.     private RedissonClient redissonClient;
15.     /**
16.      * 定义 @Pointcut注解表达式，
17.      * 方式一：@annotation：当执行的方法上拥有指定的注解时生效（我们采用这）
18.      */
19.     @Pointcut("@annotation(repeatSubmit)")
20.     public void pointCutNoRepeatSubmit(RepeatSubmit repeatSubmit) {
22.     }
24.     /**
25.      * 环绕通知, 围绕着方法执行
26.      *
27.      * @param joinPoint
28.      * @param repeatSubmit
29.      * @return
30.      * @throws Throwable
31.      * @Around 可以用来在调用一个具体方法前和调用后来完成一些具体的任务。
32.      */
33.     @Around("pointCutNoRepeatSubmit(repeatSubmit)")
34.     public Object around(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) throws Throwable {
37.         HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
39.         Long accountNo = LoginInterceptor.threadLocal.get().getAccountNo();
41.         // 记录成功或者失败
42.         Boolean res = false;
45.         // 防重提交类型
46.         String type = repeatSubmit.limitType().name();
47.         if (type.equalsIgnoreCase(RepeatSubmit.Type.PARAM.name())) {
48.             //方式一，参数形式防重提交
50.             long lockTime = repeatSubmit.lockTime();
52.             String ipAddr = CommonUtil.getIpAddr(request);
54.             MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
56.             Method method = methodSignature.getMethod();
57.             String className = method.getDeclaringClass().getName();
58.             String key = "order-server:repeat_submit"+CommonUtil.MD5(String.format("%s-%s-%s-%s", ipAddr, className, method, accountNo));
60.             // 加锁
61.             //res = redisTemplate.opsForValue().setIfAbsent(key,"1",lockTime, TimeUnit.SECONDS);
62.             RLock lock = redissonClient.getLock(key);
64.             // 尝试加锁，最多等待2秒，上锁以后5秒自动解锁 [lockTime默认为5s, 可以自定义]
65.             res = lock.tryLock(2, lockTime, TimeUnit.SECONDS);
67.         } else if (type.equalsIgnoreCase(RepeatSubmit.Type.TOKEN.name())) {
68.             //方式二，令牌形式防重提交
69.             String requestToken = request.getHeader("request-token");
70.             if (StringUtils.isBlank(requestToken)) {
71.                 throw new BizException(BizCodeEnum.ORDER_CONFIRM_TOKEN_EQUAL_FAIL);
72.             }
73.             String key = String.format(RedisKey.SUBMIT_ORDER_TOKEN_KEY, accountNo, requestToken);
74.             /**
75.              * 提交表单的token key
76.              * key是 order:submit:accountNo:token,然后直接删除成功则完成
77.              */
78.             res = redisTemplate.delete(key);
80.         }
81.         if (!res) {
82.             log.error("订单请求重复提交");
83.             return null;
84.         }
86.         log.info("环绕通知执行前");
88.         Object obj = joinPoint.proceed();
90.         log.info("环绕通知执行后");
91.         return obj;
92.     }
93. }

复制代码

• RedissionConfiguration配置类（用于加锁）
  

1. @Configuration
2. public class RedissionConfiguration {
4.     @Value("${spring.redis.host}")
5.     private String redisHost;
7.     @Value("${spring.redis.port}")
8.     private String redisPort;
11.     @Value("${spring.redis.password}")
12.     private String redisPwd;
15.     /**
16.      * 配置分布式锁的redisson
17.      * @return
18.      */
19.     @Bean
20.     public RedissonClient redissonClient(){
21.         Config config = new Config();
23.         //单机方式
24.         config.useSingleServer().setPassword(redisPwd).setAddress("redis://"+redisHost+":"+redisPort);
26.         //集群
27.         //config.useClusterServers().addNodeAddress("redis://192.31.21.1:6379","redis://192.31.21.2:6379")
29.         RedissonClient redissonClient = Redisson.create(config);
30.         return redissonClient;
31.     }
33.     /**
34.      * 集群模式
35.      * 备注：可以用"rediss://"来启用SSL连接
36.      */
37.     /*@Bean
38.     public RedissonClient redissonClusterClient() {
39.         Config config = new Config();
40.         config.useClusterServers().setScanInterval(2000) // 集群状态扫描间隔时间，单位是毫秒
41.               .addNodeAddress("redis://127.0.0.1:7000")
42.               .addNodeAddress("redis://127.0.0.1:7002");
43.         RedissonClient redisson = Redisson.create(config);
44.         return redisson;
45.     }*/
47. }

复制代码

• 使用说明：在下单接口标注@RepeatSubmit(limitType = RepeatSubmit.Type.TOKEN)
  
• 或者@RepeatSubmit(limitType = RepeatSubmit.Type.PARAM)
  

1.     /**
2.      * 下单前获取令牌，用于防重提交
3.      * @return
4.      */
5.     @GetMapping("token")
6.     public JsonData getOrderToken() {
8.         Long accountNo = LoginInterceptor.threadLocal.get().getAccountNo();
10.         String token = CommonUtil.getStringNumRandom(32);
12.         String key = String.format(RedisKey.SUBMIT_ORDER_TOKEN_KEY, accountNo, token);
13.         // token 过期时间30分钟
14.         redisTemplate.opsForValue().set(key, String.valueOf(Thread.currentThread().getId()), 30, TimeUnit.MINUTES);
16.         return JsonData.buildSuccess(token);
17.     }        
20.         @PostMapping("confirm")
21.     @RepeatSubmit(limitType = RepeatSubmit.Type.TOKEN)
22.     public void confirmOrder(@RequestBody ConfirmOrderRequest orderRequest, HttpServletResponse response) {
23.         // TODO 下单业务
24.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！