springboot订单重复提交_springbootAOP实现防止接口重复提交

背景&＃xff1a;之前自己写了一个简单的书写文章小项目&＃xff0c;测试的时候发现多次点击添加文章按钮系统会出现重复的文章&＃xff0c;所以就想着用aop实现防止接口重复提交功能。

个人设计的思路&＃xff1a;

1. 自定义一个注解&＃xff0c;添加了该注解的接口可以防止重复提交。

2. 定义切面类&＃xff0c;对使用了自定义注解的接口做代理。

3. 使用登录的userId&＃43;文章标题作为key存入redis&＃xff0c;设置有效期&＃xff0c;当有请求调用接口时&＃xff0c;到redis中查找相应的key&＃xff0c;如果能找到&＃xff0c;则说明重复提交&＃xff0c;如果找不到&＃xff0c;则执行文章插入操作。

具体代码如下&＃xff1a;

一&＃xff0e;导入aop依赖(本文测试使用的springboot)

org.springframework.boot

spring-boot-starter-aop

二&＃xff0e;自定义注解

&＃64;Target(ElementType.METHOD)

&＃64;Retention(RetentionPolicy.RUNTIME)

&＃64;Documented

public &＃64;interface ArticleReSubmit {

}

三&＃xff0e;定义切面类

切面类需要使用&＃64;Aspect和&＃64;Component这两个注解做标注。

代码图片

&＃64;Aspect&＃64;Component&＃64;Slf4jpublic class ArticleAspect {&＃64;Resource private RedisUtil redisUtil; &＃64;Value("${user.session.key}") private String userSessionKey; &＃64;Pointcut(value &＃61; "&＃64;annotation(com.mypage.annotation.ArticleReSubmit)") public void annotationPointCut() { } &＃64;Around("annotationPointCut()") public Object NoReSubmit(ProceedingJoinPoint joinPoint) { ServletRequestAttributes attributes &＃61; (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); //获取request HttpServletRequest request &＃61; attributes.getRequest(); HttpSession session &＃61; request.getSession(); //从session中获取登录的user对象&＃xff0c;如果为null,则要求重新登录 Object sessionUser &＃61; session.getAttribute(userSessionKey); if (sessionUser &＃61;&＃61; null) { return Response.FAIL("页面超时&＃xff0c;请重新登录"); } User user &＃61; (User) sessionUser; Integer userId &＃61; user.getId(); //获取接口的请求参数&＃xff0c;如果时Article类型&＃xff0c;则保存为Article对象&＃xff0c;使用Article对象里的title属性 Object[] args &＃61; joinPoint.getArgs(); Article article &＃61; null; for (Object object &＃xff1a; args) { if (object instanceof Article) { article &＃61; (Article) object; } } if (args &＃61;&＃61; null) { return Response.FAIL("请求参数错误"); } //组装redis key 从redis中获取对应的值 String key &＃61; userId &＃43; "_" &＃43; article.getTitle(); Object flag &＃61; redisUtil.getStr(key); //如果redis中不存在对应的值&＃xff0c;则执行原有的代码逻辑(插入文章操作) if (flag &＃61;&＃61; null) { //redis设置key,value值为1 redisUtil.setStr(key, "1"); //设置有效期为5分钟 redisUtil.strSetExpireSeconds(key, 5*60L); try { return joinPoint.proceed(); } catch (Throwable throwable) { redisUtil.delStr(key); return Response.FAIL("系统错误&＃xff0c;请联系管理员&＃xff01;"); } } else { //如果redis中存在对应的值&＃xff0c;则证明重复提交&＃xff0c;返回对应的信息 log.info("{}:重复提交", key); return Response.FAIL("重复提交"); } }}

四. 在想要防止重复提交的接口上添加注解

&＃64;RequestMapping("/addArticle")&＃64;ResponseBody&＃64;ArticleReSubmitpublic Response addArticle(Article article, HttpServletRequest request) {User user &＃61; (User) request.getSession().getAttribute(userSessionKey); return articleService.addArticle(article, user);}

至此&＃xff0c;我们的代码就完成了。

如果您觉得我哪写得不好&＃xff0c;或者有什么意见或建议&＃xff0c;还请指出&＃xff0c;谢谢&＃xff01;