欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot實現(xiàn)防重復(fù)提交和防重復(fù)點擊的示例

 更新時間:2020年09月29日 08:34:42   作者:DaleyZou''''s  
這篇文章主要介紹了springboot實現(xiàn)防重復(fù)提交和防重復(fù)點擊的示例,幫助大家更好的理解和學(xué)習(xí)springboot框架,感興趣的朋友可以了解下

背景

同一條數(shù)據(jù)被用戶點擊了多次,導(dǎo)致數(shù)據(jù)冗余,需要防止弱網(wǎng)絡(luò)等環(huán)境下的重復(fù)點擊

目標(biāo)

通過在指定的接口處添加注解,實現(xiàn)根據(jù)指定的接口參數(shù)來防重復(fù)點擊

說明

這里的重復(fù)點擊是指在指定的時間段內(nèi)多次點擊按鈕

技術(shù)方案

springboot + redis鎖 + 注解

使用 feign client 進行請求測試

最終的使用實例

1、根據(jù)接口收到 PathVariable 參數(shù)判斷唯一

/**
  * 根據(jù)請求參數(shù)里的 PathVariable 里獲取的變量進行接口級別防重復(fù)點擊
  *
  * @param testId 測試id
  * @param requestVo 請求參數(shù)
  * @return
  * @author daleyzou
  */
 @PostMapping("/test/{testId}")
 @NoRepeatSubmit(location = "thisIsTestLocation", seconds = 6)
 public RsVo thisIsTestLocation(@PathVariable Integer testId, @RequestBody RequestVo requestVo) throws Throwable {
  // 睡眠 5 秒,模擬業(yè)務(wù)邏輯
  Thread.sleep(5);
  return RsVo.success("test is return success");
 }

2、根據(jù)接口收到的 RequestBody 中指定變量名的值判斷唯一

/**
  * 根據(jù)請求參數(shù)里的 RequestBody 里獲取指定名稱的變量param5的值進行接口級別防重復(fù)點擊
  *
  * @param testId 測試id
  * @param requestVo 請求參數(shù)
  * @return
  * @author daleyzou
  */
 @PostMapping("/test/{testId}")
 @NoRepeatSubmit(location = "thisIsTestBody", seconds = 6, argIndex = 1, name = "param5")
 public RsVo thisIsTestBody(@PathVariable Integer testId, @RequestBody RequestVo requestVo) throws Throwable {
  // 睡眠 5 秒,模擬業(yè)務(wù)邏輯
  Thread.sleep(5);
  return RsVo.success("test is return success");
 }

ps: jedis 2.9 和 springboot有各種兼容問題,無奈只有降低springboot的版本了

運行結(jié)果

收到響應(yīng):{"succeeded":true,"code":500,"msg":"操作過于頻繁,請稍后重試","data":null}
收到響應(yīng):{"succeeded":true,"code":500,"msg":"操作過于頻繁,請稍后重試","data":null}
收到響應(yīng):{"succeeded":true,"code":500,"msg":"操作過于頻繁,請稍后重試","data":null}
收到響應(yīng):{"succeeded":true,"code":200,"msg":"success","data":"test is return success"}

測試用例

package com.dalelyzou.preventrepeatsubmit.controller;

import com.dalelyzou.preventrepeatsubmit.PreventrepeatsubmitApplicationTests;
import com.dalelyzou.preventrepeatsubmit.service.AsyncFeginService;
import com.dalelyzou.preventrepeatsubmit.vo.RequestVo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * TestControllerTest
 * @description 防重復(fù)點擊測試類
 * @author daleyzou
 * @date 2020年09月28日 17:13
 * @version 1.3.1
 */
class TestControllerTest extends PreventrepeatsubmitApplicationTests {
 @Autowired
 AsyncFeginService asyncFeginService;

 @Test
 public void thisIsTestLocation() throws IOException {
  RequestVo requestVo = new RequestVo();
  requestVo.setParam5("random");
  ExecutorService executorService = Executors.newFixedThreadPool(4);
  for (int i = 0; i <= 3; i++) {
   executorService.execute(() -> {
    String kl = asyncFeginService.thisIsTestLocation(requestVo);
    System.err.println("收到響應(yīng):" + kl);
   });
  }
  System.in.read();
 }

 @Test
 public void thisIsTestBody() throws IOException {
  RequestVo requestVo = new RequestVo();
  requestVo.setParam5("special");
  ExecutorService executorService = Executors.newFixedThreadPool(4);
  for (int i = 0; i <= 3; i++) {
   executorService.execute(() -> {
    String kl = asyncFeginService.thisIsTestBody(requestVo);
    System.err.println("收到響應(yīng):" + kl);
   });
  }
  System.in.read();
 }
}

定義一個注解

package com.dalelyzou.preventrepeatsubmit.aspect;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * NoRepeatSubmit
 * @description 重復(fù)點擊的切面
 * @author daleyzou
 * @date 2020年09月23日 14:35
 * @version 1.4.8
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface NoRepeatSubmit {
 /**
  * 鎖過期的時間
  * */
 int seconds() default 5;
 /**
  * 鎖的位置
  * */
 String location() default "NoRepeatSubmit";
 /**
  * 要掃描的參數(shù)位置
  * */
 int argIndex() default 0;
 /**
  * 參數(shù)名稱
  * */
 String name() default "";
}

根據(jù)指定的注解定義一個切面,根據(jù)參數(shù)中的指定值來判斷請求是否重復(fù)

package com.dalelyzou.preventrepeatsubmit.aspect;

import com.dalelyzou.preventrepeatsubmit.constant.RedisKey;
import com.dalelyzou.preventrepeatsubmit.service.LockService;
import com.dalelyzou.preventrepeatsubmit.vo.RsVo;
import com.google.common.collect.Maps;
import com.google.gson.Gson;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import java.lang.reflect.Field;
import java.util.Map;

@Aspect
@Component
public class NoRepeatSubmitAspect {
 private static final Logger logger = LoggerFactory.getLogger(NoRepeatSubmitAspect.class);

 private static Gson gson = new Gson();

 private static final String SUFFIX = "SUFFIX";

 @Autowired
 LockService lockService;

 /**
  * 橫切點
  */
 @Pointcut("@annotation(noRepeatSubmit)")
 public void repeatPoint(NoRepeatSubmit noRepeatSubmit) {
 }

 /**
  * 接收請求,并記錄數(shù)據(jù)
  */
 @Around(value = "repeatPoint(noRepeatSubmit)")
 public Object doBefore(ProceedingJoinPoint joinPoint, NoRepeatSubmit noRepeatSubmit) {
  String key = RedisKey.NO_REPEAT_LOCK_PREFIX + noRepeatSubmit.location();
  Object[] args = joinPoint.getArgs();
  String name = noRepeatSubmit.name();
  int argIndex = noRepeatSubmit.argIndex();
  String suffix;
  if (StringUtils.isEmpty(name)) {
   suffix = String.valueOf(args[argIndex]);
  } else {
   Map<String, Object> keyAndValue = getKeyAndValue(args[argIndex]);
   Object valueObj = keyAndValue.get(name);
   if (valueObj == null) {
    suffix = SUFFIX;
   } else {
    suffix = String.valueOf(valueObj);
   }
  }
  key = key + ":" + suffix;
  logger.info("==================================================");
  for (Object arg : args) {
   logger.info(gson.toJson(arg));
  }
  logger.info("==================================================");
  int seconds = noRepeatSubmit.seconds();
  logger.info("lock key : " + key);
  if (!lockService.isLock(key, seconds)) {
   return RsVo.fail("操作過于頻繁,請稍后重試");
  }
  try {
   Object proceed = joinPoint.proceed();
   return proceed;
  } catch (Throwable throwable) {
   logger.error("運行業(yè)務(wù)代碼出錯", throwable);
   throw new RuntimeException(throwable.getMessage());
  } finally {
   lockService.unLock(key);
  }
 }

 public static Map<String, Object> getKeyAndValue(Object obj) {
  Map<String, Object> map = Maps.newHashMap();
  // 得到類對象
  Class userCla = (Class) obj.getClass();
  /* 得到類中的所有屬性集合 */
  Field[] fs = userCla.getDeclaredFields();
  for (int i = 0; i < fs.length; i++) {
   Field f = fs[i];
   // 設(shè)置些屬性是可以訪問的
   f.setAccessible(true);
   Object val = new Object();
   try {
    val = f.get(obj);
    // 得到此屬性的值
    // 設(shè)置鍵值
    map.put(f.getName(), val);
   } catch (IllegalArgumentException e) {
    logger.error("getKeyAndValue IllegalArgumentException", e);
   } catch (IllegalAccessException e) {
    logger.error("getKeyAndValue IllegalAccessException", e);
   }

  }
  logger.info("掃描結(jié)果:" + gson.toJson(map));
  return map;
 }
}

項目完整代碼

https://github.com/daleyzou/PreventRepeatSubmit

以上就是springboot實現(xiàn)防重復(fù)提交和防重復(fù)點擊的示例的詳細內(nèi)容,更多關(guān)于springboot實現(xiàn)防重復(fù)提交和防重復(fù)點擊的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • 基于java中的PO VO DAO BO POJO(詳解)

    基于java中的PO VO DAO BO POJO(詳解)

    下面小編就為大家?guī)硪黄趈ava中的PO VO DAO BO POJO(詳解)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-06-06
  • java使用反射訪問成員變量的值示例

    java使用反射訪問成員變量的值示例

    這篇文章主要介紹了java使用反射訪問成員變量的值,結(jié)合實例形式分析了java基于反射機制操作類成員變量相關(guān)實現(xiàn)技巧,需要的朋友可以參考下
    2019-07-07
  • 一道關(guān)于java異常處理的題目

    一道關(guān)于java異常處理的題目

    本文給大家分享一道關(guān)于java異常處理的題目,非常不錯,具有參考借鑒價值,需要的朋友可以參考下
    2016-09-09
  • SpringBoot使用Sa-Token實現(xiàn)路徑攔截和特定接口放行

    SpringBoot使用Sa-Token實現(xiàn)路徑攔截和特定接口放行

    這篇文章主要介紹了SpringBoot使用Sa-Token實現(xiàn)路徑攔截和特定接口放行,文中通過代碼示例講解的非常詳細,對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下
    2024-06-06
  • 詳解JavaFX桌面應(yīng)用開發(fā)-Group(容器組)

    詳解JavaFX桌面應(yīng)用開發(fā)-Group(容器組)

    這篇文章主要介紹了JavaFX桌面應(yīng)用開發(fā)-Group(容器組),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-04-04
  • Springboot整合fastdfs實現(xiàn)分布式文件存儲

    Springboot整合fastdfs實現(xiàn)分布式文件存儲

    本文主要介紹了Springboot整合fastdfs實現(xiàn)分布式文件存儲,詳細闡述了Springboot應(yīng)用程序如何與FastDFS進行集成及演示了如何使用Springboot和FastDFS實現(xiàn)分布式文件存儲,感興趣的可以了解一下
    2023-08-08
  • 聊聊SpringMVC項目依賴和靜態(tài)資源導(dǎo)出問題

    聊聊SpringMVC項目依賴和靜態(tài)資源導(dǎo)出問題

    這篇文章主要介紹了SpringMVC項目依賴和靜態(tài)資源導(dǎo)出問題,本文給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-12-12
  • Java如何自定義線程池中隊列

    Java如何自定義線程池中隊列

    這篇文章主要介紹了Java如何自定義線程池中隊列,文章圍繞主題展開詳細的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-07-07
  • 詳談Java靜態(tài)動態(tài)的問題

    詳談Java靜態(tài)動態(tài)的問題

    下面小編就為大家?guī)硪黄斦凧ava靜態(tài)動態(tài)的問題。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-09-09
  • Java Scala實現(xiàn)數(shù)據(jù)庫增刪查改操作詳解

    Java Scala實現(xiàn)數(shù)據(jù)庫增刪查改操作詳解

    這篇文章主要介紹了Java Scala實現(xiàn)數(shù)據(jù)庫增刪查改操作,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧
    2023-04-04

最新評論