目錄1 Maven依賴2 RepeatedlyRequestWrapper3 RepeatableFilter4 RepeatSubmit5 RepeatSubmitInterceptor6 RepeatSubmitConfig7 RepeatSubmitController1 Maven依賴

<!--redis緩存--><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency> <!-- 阿里JSON解析器 --><dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.76</version></dependency><!--hutool工具包--><dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.5.1</version></dependency>2 RepeatedlyRequestWrapper

構建可重復讀取inputStream的request。

package com.servlet; import javax.servlet.*;import javax.servlet.http.*;import java.io.*;import java.nio.charset.Charset; /** * 構建可重復讀取inputStream的request */public class RepeatedlyRequestWrapper extends HttpServletRequestWrapper { private final String body; public RepeatedlyRequestWrapper(HttpServletRequest request, ServletResponse response) throws IOException {super(request);request.setCharacterEncoding('UTF-8');response.setCharacterEncoding('UTF-8'); body = getBodyString(request); } @Override public BufferedReader getReader() throws IOException {return new BufferedReader(new InputStreamReader(getInputStream())); } public String getBody() {return body; } @Override public ServletInputStream getInputStream() throws IOException {final ByteArrayInputStream bais = new ByteArrayInputStream(body.getBytes('UTF-8'));return new ServletInputStream() { @Override public int read() throws IOException {return bais.read(); } @Override public int available() throws IOException {return body.length(); } @Override public boolean isFinished() {return false; } @Override public boolean isReady() {return false; } @Override public void setReadListener(ReadListener readListener) { }}; } /** * 獲取Request請求body內容 * * @param request * @return */ private String getBodyString(ServletRequest request) {StringBuilder sb = new StringBuilder();BufferedReader reader = null;try (InputStream inputStream = request.getInputStream()) { reader = new BufferedReader(new InputStreamReader(inputStream, Charset.forName('UTF-8'))); String line = ''; while ((line = reader.readLine()) != null) {sb.append(line); }} catch (IOException e) { e.printStackTrace();} finally { if (reader != null) {try { reader.close();} catch (IOException e) { e.printStackTrace();} }}return sb.toString(); }}3 RepeatableFilter

將原生的request變為可重復讀取inputStream的request。

package com.filter; import com.servlet.RepeatedlyRequestWrapper;import org.springframework.http.MediaType;import org.springframework.util.StringUtils; import javax.servlet.*;import javax.servlet.http.HttpServletRequest;import java.io.IOException; /** * 過濾器（重寫request） */public class RepeatableFilter implements Filter { @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {ServletRequest requestWrapper = null;//將原生的request變為可重復讀取inputStream的requestif (request instanceof HttpServletRequest&& StringUtils.startsWithIgnoreCase(request.getContentType(), MediaType.APPLICATION_JSON_VALUE)) { requestWrapper = new RepeatedlyRequestWrapper((HttpServletRequest) request, response);}if (null == requestWrapper) { chain.doFilter(request, response);} else { chain.doFilter(requestWrapper, response);} }}4 RepeatSubmit

自定義注解（防止表單重復提交）。

package com.annotation; import java.lang.annotation.*; /** * 自定義注解防止表單重復提交 */@Inherited@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)@Documentedpublic @interface RepeatSubmit {}5 RepeatSubmitInterceptor

防止重復提交攔截器。

package com.interceptor; import cn.hutool.core.util.StrUtil;import com.alibaba.fastjson.JSONObject;import com.annotation.RepeatSubmit;import com.service.*;import com.servlet.RepeatedlyRequestWrapper;import org.springframework.beans.factory.annotation.*;import org.springframework.stereotype.Component;import org.springframework.web.method.HandlerMethod;import org.springframework.web.servlet.HandlerInterceptor; import javax.servlet.http.*;import java.io.IOException;import java.lang.reflect.Method;import java.util.*;import java.util.concurrent.TimeUnit; /** * 防止重復提交攔截器 */@Componentpublic class RepeatSubmitInterceptor implements HandlerInterceptor { public final String REPEAT_PARAMS = 'repeatParams'; public final String REPEAT_TIME = 'repeatTime'; /** * 防重提交 redis key */ public final String REPEAT_SUBMIT_KEY = 'repeat_submit:'; // 令牌自定義標識 @Value('${token.header}') private String header; @Autowired private RedisService redisService; /** * 間隔時間，單位:秒 * <p> * 兩次相同參數的請求，如果間隔時間大于該參數，系統不會認定為重復提交的數據 */ @Value('${repeatSubmit.intervalTime}') private int intervalTime; @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)) { //返回重復提交提示 Map<String, Object> resultMap = new HashMap<>(); resultMap.put('code', '500'); resultMap.put('msg', request.getRequestURI() + '不允許重復提交，請稍后再試'); try {response.setStatus(200);response.setContentType('application/json');response.setCharacterEncoding('utf-8');response.getWriter().print(JSONObject.toJSONString(resultMap)); } catch (IOException e) {e.printStackTrace(); } return false;} } return true;} else { return preHandle(request, response, handler);} } /** * 驗證是否重復提交由子類實現具體的防重復提交的規則 * * @param request * @return * @throws Exception */ public boolean isRepeatSubmit(HttpServletRequest request) {String nowParams = '';if (request instanceof RepeatedlyRequestWrapper) { RepeatedlyRequestWrapper repeatedlyRequest = (RepeatedlyRequestWrapper) request; nowParams = repeatedlyRequest.getBody();}// body參數為空，獲取Parameter的數據if (StrUtil.isBlank(nowParams)) { nowParams = JSONObject.toJSONString(request.getParameterMap());}Map<String, Object> nowDataMap = new HashMap<String, Object>();nowDataMap.put(REPEAT_PARAMS, nowParams);nowDataMap.put(REPEAT_TIME, System.currentTimeMillis()); // 請求地址（作為存放cache的key值）String url = request.getRequestURI(); // 唯一值（沒有消息頭則使用請求地址）String submitKey = request.getHeader(header);if (StrUtil.isBlank(submitKey)) { submitKey = url;} // 唯一標識（指定key + 消息頭）String cacheRepeatKey = REPEAT_SUBMIT_KEY + submitKey; Object sessionObj = redisService.getCacheObject(cacheRepeatKey);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)) { return true;} }}Map<String, Object> cacheMap = new HashMap<String, Object>();cacheMap.put(url, nowDataMap);redisService.setCacheObject(cacheRepeatKey, cacheMap, intervalTime, TimeUnit.SECONDS);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) {long time1 = (Long) nowMap.get(REPEAT_TIME);long time2 = (Long) preMap.get(REPEAT_TIME);if ((time1 - time2) < (this.intervalTime * 1000)) { return true;}return false; } }6 RepeatSubmitConfig

防重復提交配置。

package com.config; import com.filter.RepeatableFilter;import com.interceptor.RepeatSubmitInterceptor;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.web.servlet.FilterRegistrationBean;import org.springframework.context.annotation.*;import org.springframework.web.servlet.config.annotation.*; /** * 防重復提交配置 */@Configurationpublic class RepeatSubmitConfig implements WebMvcConfigurer { @Autowired private RepeatSubmitInterceptor repeatSubmitInterceptor; /** * 添加防重復提交攔截 */ @Override public void addInterceptors(InterceptorRegistry registry) {registry.addInterceptor(repeatSubmitInterceptor).addPathPatterns('/**'); } /** * 生成防重復提交過濾器（重寫request） * @return */ @SuppressWarnings({ 'rawtypes', 'unchecked' }) @Bean public FilterRegistrationBean createRepeatableFilter() {FilterRegistrationBean registration = new FilterRegistrationBean();registration.setFilter(new RepeatableFilter());registration.addUrlPatterns('/*');registration.setName('repeatableFilter');registration.setOrder(FilterRegistrationBean.LOWEST_PRECEDENCE);return registration; }}7 RepeatSubmitController

調試代碼。

package com.controller; import com.annotation.RepeatSubmit;import org.springframework.web.bind.annotation.*; import java.util.List; @RestController@RequestMapping('/repeatSubmit')public class RepeatSubmitController { /** * 保存Param * @param name * @return */ @RepeatSubmit @PostMapping('/saveParam/{name}') public String saveParam(@PathVariable('name')String name){return '保存Param成功'; } /** * 保存Param * @param name * @return */ @RepeatSubmit @PostMapping('/saveBody') public String saveBody(@RequestBody List<String> name){return '保存Body成功'; }}

8 調試結果

param傳參：

body傳參：

注：

（1）RedisService源碼請查看以下博客。

Spring Boot 配置Redis（緩存數據庫）實現保存、獲取、刪除數據

（2）只有加上@RepeatSubmit的接口才會進行防重復提交校驗。

到此這篇關于SpringBoot+Redis實現后端接口防重復提交校驗的示例的文章就介紹到這了,更多相關SpringBoot接口防重復提交內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！