Java 处理重复提交问题

1、定义一个接口用来控制限制的时间

1. package org.jeecg.common.aspect.annotation;
3. import java.lang.annotation.Documented;
4. import java.lang.annotation.ElementType;
5. import java.lang.annotation.Inherited;
6. import java.lang.annotation.Retention;
7. import java.lang.annotation.RetentionPolicy;
8. import java.lang.annotation.Target;
11. /**
12. * @author 作者 :Tring
13. * @version 创建时间：2022年5月10日 下午6:25:17
14. * 类说明 处理重复提交问题
15. */
17. @Inherited
18. @Target(ElementType.METHOD)
19. @Retention(RetentionPolicy.RUNTIME)
20. @Documented
21. public @interface NoRepeatSubmit {
23.     /**
24.      * 默认1s钟以内算重复提交
25.      * @return
26.      */
27.     long timeout() default 1;
28.    
29. }

复制代码

 
2、配置切面拦截所有请求

1. package org.jeecg.common.aspect;
3. import java.lang.reflect.Method;
4. import java.util.concurrent.TimeUnit;
6. import javax.servlet.http.HttpServletRequest;
8. import org.aspectj.lang.ProceedingJoinPoint;
9. import org.aspectj.lang.annotation.Around;
10. import org.aspectj.lang.annotation.Aspect;
11. import org.aspectj.lang.annotation.Pointcut;
12. import org.aspectj.lang.reflect.MethodSignature;
13. import org.jeecg.common.api.vo.Result;
14. import org.jeecg.common.aspect.annotation.NoRepeatSubmit;
15. import org.jeecg.common.constant.PublicHeaderParameter;
16. import org.jeecg.common.util.RedisUtil;
17. import org.springframework.beans.factory.annotation.Autowired;
18. import org.springframework.stereotype.Component;
19. import org.springframework.web.context.request.RequestContextHolder;
20. import org.springframework.web.context.request.ServletRequestAttributes;
22. import me.zhyd.oauth.utils.IpUtils;
24. /**
25. * @author 作者 :Tring
26. * @version 创建时间：2022年5月10日 下午6:26:36
27. *
28. * 类说明 aop切面注解控制指定接口不能重复提交
29. * 实现原理 请求拦截，通过IP+token+请求地址为key存Redis，Redis若存在则弹出异常
30. * 使用例子 在想要拦截的接口上面加入@NoRepeatSubmit自定义注解即系
31. */
32. @Aspect
33. @Component
34. public class NoRepeatSubmitAop {
35.    
36.     @Autowired
37.     private RedisUtil redisService;
39.     /**
40.      * 切入点
41.      */
42.     @Pointcut("@annotation(org.jeecg.common.aspect.annotation.NoRepeatSubmit)")
43.     public void pt() {
44.     }
46.     @Around("pt()")
47.     public Object arround(ProceedingJoinPoint joinPoint) throws Throwable {
49.         ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
50.         assert attributes != null;
51.         HttpServletRequest request = attributes.getRequest();
52.         
53.         // 获取注解
54.         MethodSignature signature = (MethodSignature) joinPoint.getSignature();
55.         Method method = signature.getMethod();
56.         NoRepeatSubmit annotation = method.getAnnotation(NoRepeatSubmit.class);
57.         
58.         //获取请求IP
59.         String IP = IpUtils.getLocalIp();
60.         
61.         //获取token
62.         String token = request.getHeader(PublicHeaderParameter.X_ACCESS_TOKEN);
63.         
64.         //这里是唯一标识 根据情况而定
65.         String key = IP + "-" + token + "-" + request.getServletPath();
66.         // 如果缓存中有这个url视为重复提交
67.         if (!redisService.hasKey(key)) {
68.             //通过，执行下一步
69.             Object o = joinPoint.proceed();
70.             //然后存入redis 并且设置1s倒计时
71.             redisService.set(key, 0, annotation.timeout(), TimeUnit.SECONDS);
72.             //返回结果
73.             return o;
74.         } else {
75.             return Result.error(500, "请勿重复提交或者操作过于频繁！");
76.         }
78.     }
79.    
80. }

复制代码

 
3、在需要加限制重复操作的地方加上@NoRepeatSubmit 注解
 

1. /**
2.      * 用户投票
3.      */
4.     @RequestMapping(value = "/setPollReply/{version}", method = RequestMethod.POST)
5.     @ApiVersion(2)
6.     @NoRepeatSubmit
7.     public Result<?> setPollReply( HttpServletRequest request,@RequestBody EbCorporatePollReply PollReply) {
8.         return pollCampaignService.setPollReply(request,PollReply);
9.     }

复制代码

 

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