在传统的web项目中,防止重复提交,通常做法是:后端生成一个唯一的提交令牌(uuid),并存储在服务端。页面提交请求携带这个提交令牌,后端验证并在第一次验证后删除该令牌,保证提交请求的唯一性。

上述的思路其实没有问题的,但是需要前后端都稍加改动,如果在业务开发完在加这个的话,改动量未免有些大了,本节的实现方案无需前端配合,纯后端处理。

思路

  1. 自定义注解 @NoRepeatSubmit 标记所有Controller中的提交请求

  2. 通过AOP 对所有标记了 @NoRepeatSubmit 的方法拦截

  3. 在业务方法执行前,获取当前用户的 token(或者JSessionId)+ 当前请求地址,作为一个唯一 KEY,去获取 Redis 分布式锁(如果此时并发获取,只有一个线程会成功获取锁)

  4. 业务方法执行后,释放锁

关于Redis 分布式锁

  • 不了解的同学戳这里 ==> Redis分布式锁的正确实现方式

  • 使用Redis 是为了在负载均衡部署,如果是单机的部署的项目可以使用一个线程安全的本地Cache 替代 Redis

Code

这里只贴出 AOP 类和测试类,完整代码见 ==> Gitee

@Aspect
@Component
public class RepeatSubmitAspect {private final static Logger LOGGER = LoggerFactory.getLogger(RepeatSubmitAspect.class);@Autowiredprivate RedisLock redisLock;@Pointcut("@annotation(noRepeatSubmit)")public void pointCut(NoRepeatSubmit noRepeatSubmit) {}@Around("pointCut(noRepeatSubmit)")public Object around(ProceedingJoinPoint pjp, NoRepeatSubmit noRepeatSubmit) throws Throwable {int lockSeconds = noRepeatSubmit.lockTime();HttpServletRequest request = RequestUtils.getRequest();Assert.notNull(request, "request can not null");// 此处可以用token或者JSessionIdString token = request.getHeader("Authorization");String path = request.getServletPath();String key = getKey(token, path);String clientId = getClientId();boolean isSuccess = redisLock.tryLock(key, clientId, lockSeconds);if (isSuccess) {LOGGER.info("tryLock success, key = [{}], clientId = [{}]", key, clientId);// 获取锁成功, 执行进程Object result;try {result = pjp.proceed();} finally {// 解锁redisLock.releaseLock(key, clientId);LOGGER.info("releaseLock success, key = [{}], clientId = [{}]", key, clientId);}return result;} else {// 获取锁失败,认为是重复提交的请求LOGGER.info("tryLock fail, key = [{}]", key);return new ResultBean(ResultBean.FAIL, "重复请求,请稍后再试", null);}}private String getKey(String token, String path) {return token + path;}private String getClientId() {return UUID.randomUUID().toString();}}

多线程测试

测试代码如下,模拟十个请求并发同时提交

@Component
public class RunTest implements ApplicationRunner {private static final Logger LOGGER = LoggerFactory.getLogger(RunTest.class);@Autowiredprivate RestTemplate restTemplate;@Overridepublic void run(ApplicationArguments args) throws Exception {System.out.println("执行多线程测试");String url="http://localhost:8000/submit";CountDownLatch countDownLatch = new CountDownLatch(1);ExecutorService executorService = Executors.newFixedThreadPool(10);for(int i=0; i<10; i++){String userId = "userId" + i;HttpEntity request = buildRequest(userId);executorService.submit(() -> {try {countDownLatch.await();System.out.println("Thread:"+Thread.currentThread().getName()+", time:"+System.currentTimeMillis());ResponseEntity<String> response = restTemplate.postForEntity(url, request, String.class);System.out.println("Thread:"+Thread.currentThread().getName() + "," + response.getBody());} catch (InterruptedException e) {e.printStackTrace();}});}countDownLatch.countDown();}private HttpEntity buildRequest(String userId) {HttpHeaders headers = new HttpHeaders();headers.setContentType(MediaType.APPLICATION_JSON);headers.set("Authorization", "yourToken");Map<String, Object> body = new HashMap<>();body.put("userId", userId);return new HttpEntity<>(body, headers);}}

成功防止重复提交,控制台日志如下,可以看到十个线程的启动时间几乎同时发起,只有一个请求提交成功了

Spring Boot 使用 AOP 防止重复提交相关推荐

  1. Spring Boot使用@RepeatSubmit 防止重复提交

    自定义防止重复提交的注解 @Inherited@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)@Documentedpubl ...

  2. Spring MVC表单防重复提交

    转载自 Spring MVC表单防重复提交 利用Spring MVC的过滤器及token传递验证来实现表单防重复提交. 创建注解 @Target(ElementType.METHOD) @Retent ...

  3. Spring Boot——基于AOP的HTTP操作日志解决方案

    解决方案 package com.hailiu.web.aop;import com.fasterxml.jackson.databind.ObjectMapper; import com.haili ...

  4. redis+aop防重复提交

    文章目录 1.防重复提交注解 2.redis分布式锁 3.防止重复提交Aop 之前有记录一篇用redis+拦截器防重复提交的内容: redis+拦截器防重复提交 1.防重复提交注解 @Target(E ...

  5. Spring Boot 集成AOP

    在这里多谈一些关于AOP 方面的知识,如果你对AOP 方面的知识比较熟悉,可以直接略过这个段落,往下看. 一.AOP概述 AOP(面向切面编程) 概念:这种在运行时,动态地将代码切入到类的指定方法.指 ...

  6. Spring Boot 使用 AOP 实现页面自适应

    鉴于复杂页面自适应的难度,一般会做几套模板分别适应手机.平板.电脑等设备.使用 Spring Boot 开发单体应用时,一般会使用 Thymeleaf 模板,那么可以使用 AOP 技术来实现页面自适应 ...

  7. Spring Boot使用AOP在控制台打印请求、响应信息

    AOP称为面向切面编程,在程序开发中主要用来解决一些系统层面上的问题,比如日志,事务,权限等. AOP简介 AOP全称Aspect Oriented Programming,面向切面,AOP主要实现的 ...

  8. Spring Boot 使用AOP实现多个数据库源的读写分离

    1.首先引入Maven依赖 <dependency><groupId>org.aspectj</groupId><artifactId>aspectjr ...

  9. Spring boot 之 aop pointcut execution规则详解

    文章目录 规则表达式含义 规则表达式 组合使用 或 与 非 示例 规则表达式含义 任意公共方法的执行: execution(public * *(..)) ##public可以省略, 第一个* 代表方 ...

最新文章

  1. 【C++】STL队列和栈的使用
  2. glibc方式安装mysql
  3. 场效应管的判别、检测及使用时的注意事项!
  4. 从源码分析DEARGUI之菜单
  5. python super 变参数问题(六)
  6. 自动化测试框架搭建-邮件-5
  7. BZOJ 1055 [HAOI2008]玩具取名
  8. npm script 的实践
  9. android抽奖动画,Android App中实现简单的刮刮卡抽奖效果的实例详解
  10. DVWA-SQL注入
  11. 关于Java中被static修饰的静态变量 (类变量)
  12. NumPy Essentials 带注释源码 四、NumPy 核心和模块
  13. Iphone隐藏和显示TabBar的方法
  14. projectwbs表_从Project 2007导出WBS图表到Visio 2007
  15. JS基础——图片切换的综合实例
  16. 文化是一种meme,NFT也是
  17. 请求头(request headers)和响应头(response headers)解析
  18. 使用jdk查看jks文件信息
  19. 卧式铣床主传动系统设计建模及运动仿真
  20. 随机信号处理笔记之色噪声及白化滤波器

热门文章

  1. MySQL 不落地迁移、导入 PostgreSQL - 推荐 rds_dbsync
  2. Thinkphp5 自定义分页类
  3. linux Makefile编写的整理
  4. EXCEL基本操作(一~二)
  5. 路由器qos设置包括哪些内容
  6. Deverpress 中国代理商使用 官方地址
  7. oracle创建表空间.创建用户.创建表
  8. cisco SMD 配置安装
  9. 网络经典命令行【网络高手必备】
  10. Matlab语音信号频谱分析代码实现