背景#

同一条数据被用户点击了多次&＃xff0c;导致数据冗余&＃xff0c;需要防止弱网络等环境下的重复点击

目标#

通过在指定的接口处添加注解&＃xff0c;实现根据指定的接口参数来防重复点击

说明#

这里的重复点击是指在指定的时间段内多次点击按钮

技术方案#

springboot &＃43; redis锁 &＃43; 注解

使用 feign client 进行请求测试

最终的使用实例#

1、根据接口收到 PathVariable 参数判断唯一

Copy/** * 根据请求参数里的 PathVariable 里获取的变量进行接口级别防重复点击 * * &＃64;param testId 测试id * &＃64;param requestVo 请求参数 * &＃64;return * &＃64;author daleyzou */ &＃64;PostMapping("/test/{testId}") &＃64;NoRepeatSubmit(location &＃61; "thisIsTestLocation", seconds &＃61; 6) public RsVo thisIsTestLocation(&＃64;PathVariable Integer testId, &＃64;RequestBody RequestVo requestVo) throws Throwable { // 睡眠 5 秒&＃xff0c;模拟业务逻辑 Thread.sleep(5); return RsVo.success("test is return success"); }

2、根据接口收到的 RequestBody 中指定变量名的值判断为一

Copy/** * 根据请求参数里的 RequestBody 里获取指定名称的变量param5的值进行接口级别防重复点击 * * &＃64;param testId 测试id * &＃64;param requestVo 请求参数 * &＃64;return * &＃64;author daleyzou */ &＃64;PostMapping("/test/{testId}") &＃64;NoRepeatSubmit(location &＃61; "thisIsTestBody", seconds &＃61; 6, argIndex &＃61; 1, name &＃61; "param5") public RsVo thisIsTestBody(&＃64;PathVariable Integer testId, &＃64;RequestBody RequestVo requestVo) throws Throwable { // 睡眠 5 秒&＃xff0c;模拟业务逻辑 Thread.sleep(5); return RsVo.success("test is return success"); }

ps: jedis 2.9 和 springboot有各种兼容问题&＃xff0c;无奈只有降低springboot的版本了

运行结果#

Copy收到响应&＃xff1a;{"succeeded":true,"code":500,"msg":"操作过于频繁&＃xff0c;请稍后重试","data":null}收到响应&＃xff1a;{"succeeded":true,"code":500,"msg":"操作过于频繁&＃xff0c;请稍后重试","data":null}收到响应&＃xff1a;{"succeeded":true,"code":500,"msg":"操作过于频繁&＃xff0c;请稍后重试","data":null}收到响应&＃xff1a;{"succeeded":true,"code":200,"msg":"success","data":"test is return success"}

测试用例#

Copypackage com.dalelyzou.preventrepeatsubmit.controller;import com.dalelyzou.preventrepeatsubmit.PreventrepeatsubmitApplicationTests;import com.dalelyzou.preventrepeatsubmit.service.AsyncFeginService;import com.dalelyzou.preventrepeatsubmit.vo.RequestVo;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * TestControllerTest * &＃64;description 防重复点击测试类 * &＃64;author daleyzou * &＃64;date 2020年09月28日 17:13 * &＃64;version 1.3.1 */class TestControllerTest extends PreventrepeatsubmitApplicationTests { &＃64;Autowired AsyncFeginService asyncFeginService; &＃64;Test public void thisIsTestLocation() throws IOException { RequestVo requestVo &＃61; new RequestVo(); requestVo.setParam5("random"); ExecutorService executorService &＃61; Executors.newFixedThreadPool(4); for (int i &＃61; 0; i <&＃61; 3; i&＃43;&＃43;) { executorService.execute(() -> { String kl &＃61; asyncFeginService.thisIsTestLocation(requestVo); System.err.println("收到响应&＃xff1a;" &＃43; kl); }); } System.in.read(); } &＃64;Test public void thisIsTestBody() throws IOException { RequestVo requestVo &＃61; new RequestVo(); requestVo.setParam5("special"); ExecutorService executorService &＃61; Executors.newFixedThreadPool(4); for (int i &＃61; 0; i <&＃61; 3; i&＃43;&＃43;) { executorService.execute(() -> { String kl &＃61; asyncFeginService.thisIsTestBody(requestVo); System.err.println("收到响应&＃xff1a;" &＃43; kl); }); } System.in.read(); }}

定义一个注解#

Copypackage com.dalelyzou.preventrepeatsubmit.aspect;import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;/** * NoRepeatSubmit * &＃64;description 重复点击的切面 * &＃64;author daleyzou * &＃64;date 2020年09月23日 14:35 * &＃64;version 1.4.8 */&＃64;Target(ElementType.METHOD)&＃64;Retention(RetentionPolicy.RUNTIME)public &＃64;interface NoRepeatSubmit { /** * 锁过期的时间 * */ int seconds() default 5; /** * 锁的位置 * */ String location() default "NoRepeatSubmit"; /** * 要扫描的参数位置 * */ int argIndex() default 0; /** * 参数名称 * */ String name() default "";}

根据指定的注解定义一个切面&＃xff0c;根据参数中的指定值来判断请求是否重复#

Copypackage com.dalelyzou.preventrepeatsubmit.aspect;import com.dalelyzou.preventrepeatsubmit.constant.RedisKey;import com.dalelyzou.preventrepeatsubmit.service.LockService;import com.dalelyzou.preventrepeatsubmit.vo.RsVo;import com.google.common.collect.Maps;import com.google.gson.Gson;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.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;import java.lang.reflect.Field;import java.util.Map;&＃64;Aspect&＃64;Componentpublic class NoRepeatSubmitAspect { private static final Logger logger &＃61; LoggerFactory.getLogger(NoRepeatSubmitAspect.class); private static Gson gson &＃61; new Gson(); private static final String SUFFIX &＃61; "SUFFIX"; &＃64;Autowired LockService lockService; /** * 横切点 */ &＃64;Pointcut("&＃64;annotation(noRepeatSubmit)") public void repeatPoint(NoRepeatSubmit noRepeatSubmit) { } /** * 接收请求&＃xff0c;并记录数据 */ &＃64;Around(value &＃61; "repeatPoint(noRepeatSubmit)") public Object doBefore(ProceedingJoinPoint joinPoint, NoRepeatSubmit noRepeatSubmit) { String key &＃61; RedisKey.NO_REPEAT_LOCK_PREFIX &＃43; noRepeatSubmit.location(); Object[] args &＃61; joinPoint.getArgs(); String name &＃61; noRepeatSubmit.name(); int argIndex &＃61; noRepeatSubmit.argIndex(); String suffix; if (StringUtils.isEmpty(name)) { suffix &＃61; String.valueOf(args[argIndex]); } else { Map keyAndValue &＃61; getKeyAndValue(args[argIndex]); Object valueObj &＃61; keyAndValue.get(name); if (valueObj &＃61;&＃61; null) { suffix &＃61; SUFFIX; } else { suffix &＃61; String.valueOf(valueObj); } } key &＃61; key &＃43; ":" &＃43; suffix; logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;"); for (Object arg : args) { logger.info(gson.toJson(arg)); } logger.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;"); int seconds &＃61; noRepeatSubmit.seconds(); logger.info("lock key : " &＃43; key); if (!lockService.isLock(key, seconds)) { return RsVo.fail("操作过于频繁&＃xff0c;请稍后重试"); } try { Object proceed &＃61; joinPoint.proceed(); return proceed; } catch (Throwable throwable) { logger.error("运行业务代码出错", throwable); throw new RuntimeException(throwable.getMessage()); } finally { lockService.unLock(key); } } public static Map getKeyAndValue(Object obj) { Map map &＃61; Maps.newHashMap(); // 得到类对象 Class userCla &＃61; (Class) obj.getClass(); /* 得到类中的所有属性集合 */ Field[] fs &＃61; userCla.getDeclaredFields(); for (int i &＃61; 0; i

完整地址&＃xff1a;https://github.com/daleyzou/PreventRepeatSubmit

原文链接&＃xff1a;https://www.cnblogs.com/daleyzou/p/noSubmitRepeat.html

如果觉得本文对你有帮助&＃xff0c;可以转发关注支持一下