Springboot2.x中怎么避免重复提交
Springboot 2.x 中怎么避免重复提交 ,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
成都创新互联公司坚持“要么做到,要么别承诺”的工作理念,服务领域包括:做网站、成都做网站、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的印台网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
Guava是什么?
guava包是google嫌弃JAVA自带的类库不好用,自行研发的一套工具包,对JDK工具做了很好的拓展。例如:并发[Concurrency]、缓存[Caches]、 函数式风格[Functional idioms]、 字符串处理[Strings]等等。
一、引入Guava包依赖
com.google.guava guava 21.0
二、自定义LocalLock注解
自定义一个LocalLock注解用于需要防止重复提交的方法上
/** * 锁的注解 * */ @Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) @Documented @Inherited public @interface LocalLock { /** * @author fly */ String key() default ""; }
注解定义好以后就需要做AOP拦截器切面的具体实现,在 interceptor()
方法上采用的是 Around
(环绕增强) ,所有带 LocalLock
注解的都将被切面处理;
既然是缓存,那紧跟的属性一定要有过期时间,通过expireAfterWrite
设置缓存的过期时间,maximumSize
设置缓存的个数。
通过在内存中查询key是否存在来判断是否让再次提交,和redis
的setNX
方法是一个原理。
那么这个注解该怎么用呢?
@Aspect @Configuration public class LockMethodInterceptor { private static final CacheCACHES = CacheBuilder.newBuilder() // 最大缓存 100 个 .maximumSize(1000) // 设置写缓存后 5 秒钟过期 .expireAfterWrite(5, TimeUnit.SECONDS) .build(); @Around("execution(public * *(..)) && @annotation(com.battcn.annotation.LocalLock)") public Object interceptor(ProceedingJoinPoint pjp) { MethodSignature signature = (MethodSignature) pjp.getSignature(); Method method = signature.getMethod(); LocalLock localLock = method.getAnnotation(LocalLock.class); String key = getKey(localLock.key(), pjp.getArgs()); if (!StringUtils.isEmpty(key)) { if (CACHES.getIfPresent(key) != null) { throw new RuntimeException("请勿重复请求"); } // 如果是第一次请求,就将 key 当前对象压入缓存中 CACHES.put(key, key); } try { return pjp.proceed(); } catch (Throwable throwable) { throw new RuntimeException("服务器异常"); } finally { // TODO 为了演示效果,这里就不调用 CACHES.invalidate(key); 代码了 } } /** * key 的生成策略,如果想灵活可以写成接口与实现类的方式(TODO 后续讲解) * * @param keyExpress 表达式 * @param args 参数 * @return 生成的key */ private String getKey(String keyExpress, Object[] args) { for (int i = 0; i < args.length; i++) { keyExpress = keyExpress.replace("arg[" + i + "]", args[i].toString()); } return keyExpress; } }
控制层的实现
我们将注解加在控制层方法上,key = "city:arg[0]
key自己定义,arg[0]
这个匹配规则表示替换成第一个参数。那么就实现city:token
在一定时间内不可以重复提交了
@RestController @RequestMapping("/city") public class BookController { @LocalLock(key = "city:arg[0]") @GetMapping public String query(@RequestParam String token) { return "ok- " + token; } }
测试
接下来我们就测试一下,我用的是postman
第一请求正常响应
紧接着请求第二次,返回结果“重复提交”,显然我们实现成功了
整理了几百本各类技术电子书,送给小伙伴们。关注公号回复【666】自行领取。和一些小伙伴们建了一个技术交流群,一起探讨技术、分享技术资料,旨在共同学习进步,如果感兴趣就加入我们吧!
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。
网页名称:Springboot2.x中怎么避免重复提交
文章位置:http://cdiso.cn/article/igsooh.html