这篇文章将介绍如何在
java
中
不依赖数据库
完成防抖、防止重复提交相同数据
防止重复提交的方式很多，这里就介绍不依赖Mysql以及Redis数据库的实现方案。
本文基于RuoYi实现防抖业务,只有当URI和参数都相同时才会触发防抖
一、防抖简介
连续点击提交按钮，理论上来说这是同一条数据，数据库应该只能存入一条，而实际上存放了多条，这就违反了幂等性。因此我们就需要做一些处理，来保证连续点击提交按钮后，数据库只能存入一条数据。
幂等性就是说无论你执行几次请求，其结果是一样的。
防抖就是避免用户在使用时不小心多次点击提交导致 数据库存在多条相同数据,
说到防抖,其实也就是多次提交
数据一致性问题
。
二、都有哪些实现方式
防止重复提交的方式很多，这里简单介绍都有哪些实现方式:
前端方案
:
1
. 按钮只能单击一次，加上confirm确认框
2
. 按钮点击后，加入 loading 效果，提交之后进入成功或失败环节
3
. 用户点击后，进行跳转。不给多次点击的机会
后端方案
:
1
. 通过redis等缓存服务缓存(userId + 接口 + 参数) 做为key，且对应的过期时间为3秒，当在3秒内接收到的同一个key的请求视为相同请求，直接返回”请勿点击过快或请稍后再试”等提示信息
2
. 给数据库增加唯一键约束:在数据库建表的时候在ID字段添加主键约束，用户名、邮箱、电话等字段加唯一性约束。确保数据库只可以添加一条数据。
3
. 利用Session防止表单重复提交（推荐）
三、本文实现方案
通过Session机制,自定义注解加拦截器实现,只有当URI和参数都相同时才会触发防抖
我们通过获取用户URI及提交内容来判断他是否重复提交，假如这个URI在一段时间内容多次访问这个接口，我们则认为是重复提交，我们将重复提交的请求直接返回，给出提示即可。
四、 使用步骤
1.自定义注解
/**
* 自定义注解防止表单重复提交
*/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RepeatSubmit {
/**
* 间隔时间(ms)，小于此时间视为重复提交
*/
public int interval() default 5000;
/**
* 提示消息
*/
public String message() default "不允许重复提交，请稍后再试";
}
2.拦截器(抽象类)
/**
* 防止重复提交拦截器
*/
@Component
public abstract class RepeatSubmitInterceptor implements HandlerInterceptor {
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
if (handler instanceof HandlerMethod) {
HandlerMethod handlerMethod = (HandlerMethod) handler;
Method method = handlerMethod.getMethod();
RepeatSubmit annotation = method.getAnnotation(RepeatSubmit.class);
if (annotation != null) {
if (this.isRepeatSubmit(request, annotation)) {
throw new BizException(annotation.message());
}
}
return true;
} else {
return true;
}
}
/**
* 验证是否重复提交由子类实现具体的防重复提交的规则
*
* @param request 请求对象
* @param annotation 防复注解
* @return 结果
*/
public abstract boolean isRepeatSubmit(HttpServletRequest request, RepeatSubmit annotation) throws Exception;
}
3.拦截器实现
/**
* 判断请求url和数据是否和上一次相同，
* 如果和上次相同，则是重复提交。
*/
@Component
public class SameUrlDataInterceptor extends RepeatSubmitInterceptor {
public final String REPEAT_PARAMS = "repeatParams";
public final String REPEAT_TIME = "repeatTime";
public final String SESSION_REPEAT_KEY = "repeatData";
@SuppressWarnings("unchecked")
@Override
public boolean isRepeatSubmit(HttpServletRequest request, RepeatSubmit annotation) throws Exception {
// 本次参数及系统时间
String nowParams = JSONUtil.toJsonStr(request.getParameterMap());
Map<String, Object> nowDataMap = new HashMap<String, Object>();
nowDataMap.put(REPEAT_PARAMS, nowParams);
nowDataMap.put(REPEAT_TIME, System.currentTimeMillis());
// 请求地址（作为存放session的key值）
String url = request.getRequestURI();
HttpSession session = request.getSession();
Object sessionObj = session.getAttribute(SESSION_REPEAT_KEY);
if (sessionObj != null) {
Map<String, Object> sessionMap = (Map<String, Object>) sessionObj;
if (sessionMap.containsKey(url)) {
Map<String, Object> preDataMap = (Map<String, Object>) sessionMap.get(url);
if (compareParams(nowDataMap, preDataMap) && compareTime(nowDataMap, preDataMap, annotation.interval())) {
return true;
}
}
}
Map<String, Object> sessionMap = new HashMap<String, Object>();
sessionMap.put(url, nowDataMap);
session.setAttribute(SESSION_REPEAT_KEY, sessionMap);
return false;
}
/**
* 判断参数是否相同
*/
private boolean compareParams(Map<String, Object> nowMap, Map<String, Object> preMap) {
String nowParams = (String) nowMap.get(REPEAT_PARAMS);
String preParams = (String) preMap.get(REPEAT_PARAMS);
return nowParams.equals(preParams);
}
/**
* 判断两次间隔时间
*/
private boolean compareTime(Map<String, Object> nowMap, Map<String, Object> preMap, int interval) {
long time1 = (Long) nowMap.get(REPEAT_TIME);
long time2 = (Long) preMap.get(REPEAT_TIME);
if ((time1 - time2) < interval) {
return true;
}
return false;
}
}
4.测试使用
@RepeatSubmit
@Operation(summary = "新增测试内容")
@PostMapping("/add")
public ActionResult addTestContent(@RequestBody TestConTentDTO dto) {
return ActionResult.success(testConcentService.addTestContent(dto));
}
当然时间可以自行根据实际设定
@RepeatSubmit(interval = 3000,message = "重复提交")
正常提交
重复提交
测试成功
五、总结
实现的方案有很多,可根据业务自行判断使用那种