Java利用redis實現防止接口重復提交
更新時間：2022年11月15日 10:37:24 作者：鴨血粉絲Tang
本文主要為大家詳細介紹了Java如何利用redis實現防止接口重復提交，文中通過示例代碼介紹的非常詳細,具有一定的參考價值，感興趣的小伙伴們可以參考一下
一、摘要
在上一篇文章中，我們詳細的介紹了對于下單流量不算高的系統(tǒng)，可以通過請求唯一ID+數據表增加唯一索引約束這種方案來實現防止接口重復提交！
隨著業(yè)務的快速增長，每一秒的下單請求次數，可能從幾十上升到幾百甚至幾千。
面對這種下單流量越來越高的場景，此時數據庫的訪問壓力會急劇上升，上面這套方案全靠數據庫來解決，會特別吃力！
對于這樣的場景，我們可以選擇引入緩存中間件來解決，可選的組件有 redis、memcache 等。
下面，我們以引入redis緩存數據庫服務器，向大家介紹具體的解決方案！
二、方案實踐
我們先來看一張圖，這張圖就是本次方案的核心流程圖。
實現的邏輯，流程如下：
1.當用戶進入訂單提交界面的時候，調用后端獲取請求唯一 ID，同時后端將請求唯一ID存儲到
redis中再返回給前端，前端將唯一 ID 值埋點在頁面里面- 2.當用戶點擊提交按鈕時，后端檢查這個請求唯一 ID 是否存在，如果不存在，提示錯誤信息；如果存在，繼續(xù)后續(xù)檢查流程
- 3.使用
redis的分布式鎖服務，對請求 ID 在限定的時間內進行加鎖，如果加鎖成功，繼續(xù)后續(xù)流程；如果加鎖失敗，說明服務正在處理，請勿重復提交 - 4.最后一步，如果加鎖成功后，需要將鎖手動釋放掉，以免再次請求時，提示同樣的信息；同時如果任務執(zhí)行成功，需要將
redis中的請求唯一 ID 清理掉 - 5.至于數據庫是否需要增加字段唯一索引，理論上可以不用加，如果加了更保險
引入緩存服務，防止重復提交的大體思路如上，實踐代碼如下！
2.1、引入 redis 組件
小編的項目是基于SpringBoot版本進行構建，添加相關的redis依賴環(huán)境如下：
<!--?引入springboot?--> <parent> ????<groupId>org.springframework.boot</groupId> ????<artifactId>spring-boot-starter-parent</artifactId> ????<version>2.1.0.RELEASE</version> </parent> ...... <!--?Redis相關依賴包，采用jedis作為客戶端?--> <dependency> ????<groupId>org.springframework.boot</groupId> ????<artifactId>spring-boot-starter-data-redis</artifactId> ????<exclusions> ????????<exclusion> ????????????<groupId>redis.clients</groupId> ????????????<artifactId>jedis</artifactId> ????????</exclusion> ????????<exclusion> ????????????<artifactId>lettuce-core</artifactId> ????????????<groupId>io.lettuce</groupId> ????????</exclusion> ????</exclusions> </dependency> <dependency> ????<groupId>redis.clients</groupId> ????<artifactId>jedis</artifactId> </dependency> <dependency> ????<groupId>org.apache.commons</groupId> ????<artifactId>commons-pool2</artifactId> </dependency>
特別注意：由于每個項目環(huán)境不一樣，具體的依賴包需要和工程版本號匹配！
2.2、添加 redis 環(huán)境配置
在全局配置application.properties文件中，添加redis相關服務配置如下
#?Redis數據庫索引（默認為0） spring.redis.database=1 #?Redis服務器地址 spring.redis.host=127.0.0.1 #?Redis服務器連接端口 spring.redis.port=6379 #?Redis服務器連接密碼（默認為空） spring.redis.password= #?Redis服務器連接超時配置 spring.redis.timeout=1000 #?連接池配置 spring.redis.jedis.pool.max-active=8 spring.redis.jedis.pool.max-wait=1000 spring.redis.jedis.pool.max-idle=8 spring.redis.jedis.pool.min-idle=0 spring.redis.jedis.pool.time-between-eviction-runs=100
在使用redis之前，請確保redis服務器是啟動狀態(tài)，并且能正常訪問！
2.3、編寫獲取請求唯一ID的接口，同時將唯一ID存入redis
@RestController
@RequestMapping("api")
public?class?SubmitTokenController?{
????/**
?????*?SubmitToken過期時間
?????*/
????private?static?final?Integer?EXPIRE_TIME?=?60;
????@Autowired
????private?StringRedisTemplate?stringRedisTemplate;
????/**
?????*?獲取getSubmitToken
?????*?@return
?????*/
????@RequestMapping("getSubmitToken")
????public?ResResult?getSubmitToken(){
????????String?uuid?=?UUID.randomUUID().toString();
????????//存入redis
????????stringRedisTemplate.opsForValue().set(uuid,?uuid,?EXPIRE_TIME,?TimeUnit.SECONDS);
????????return?ResResult.getSuccess(uuid);
????}
}
2.4、編寫服務驗證邏輯，通過 aop 代理方式實現
首先創(chuàng)建一個@SubmitToken注解，通過這個注解來進行方法代理攔截！
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public?@interface?SubmitToken?{
}
編寫方法代理服務，增加防止重復提交的驗證，實現了邏輯如下！
@Order(1)
@Aspect
@Component
public?class?SubmitTokenAspect?{
????private?static?final?Logger?LOGGER?=?LoggerFactory.getLogger(SubmitTokenAspect.class);
????/**
?????*?獲取分布式鎖等待時間，單位秒
?????*/
????private?static?final?Long?LOCK_REDIS_WAIT_TIME?=?3L;
????/**
?????*?分布式鎖前綴
?????*/
????private?static?final?String?LOCK_KEY_PREFIX?=?"SUBMIT:TOKEN:LOCK";
????/**
?????*?默認鎖對應的值
?????*/
????private?static?final?String?DEFAULT_LOCK_VALUE?=?"DEFAULT_LOCK_VALUE";
????@Autowired
????private?StringRedisTemplate?stringRedisTemplate;
????@Autowired
????private?RedisLockService?redisLockService;
????/**
?????*?方法調用環(huán)繞攔截
?????*/
????@Around(value?=?"@annotation(com.example.submittoken.config.annotation.SubmitToken)")
????public?Object?doAround(ProceedingJoinPoint?joinPoint){
????????HttpServletRequest?request?=?getHttpServletRequest();
????????if(Objects.isNull(request)){
????????????return?ResResult.getSysError("請求參數不能為空！");
????????}
????????String?submitToken?=?request.getHeader("submitToken");
????????if(StringUtils.isEmpty(submitToken)){
????????????return?ResResult.getSysError("submitToken不能為空！");
????????}
????????//檢查submitToken是否存在
????????String?submitTokenValue?=?stringRedisTemplate.opsForValue().get(submitToken);
????????if(StringUtils.isEmpty(submitTokenValue)){
????????????return?ResResult.getSysError(ResResultEnum.SUBMIT_ERROR_MESSAGE);
????????}
????????//嘗試加鎖
????????String?lockKey?=?LOCK_KEY_PREFIX?+?submitToken;
????????boolean?lock?=?redisLockService.tryLock(lockKey,?DEFAULT_LOCK_VALUE,?Duration.ofSeconds(LOCK_REDIS_WAIT_TIME));
????????if(!lock){
????????????return?ResResult.getSysError("服務正在處理，請勿重復提交！");
????????}
????????try?{
????????????//繼續(xù)執(zhí)行后續(xù)流程
????????????Object?result?=?joinPoint.proceed();
????????????//任務執(zhí)行成功，清除submitToken緩存
????????????stringRedisTemplate.delete(submitToken);
????????????return?result;
????????}?catch?(CommonException?e)?{
????????????return?ResResult.getSysError(e.getMessage());
????????}?catch?(Throwable?e)?{
????????????LOGGER.error("業(yè)務處理發(fā)生異常，錯誤信息：",e);
????????????return?ResResult.getSysError(ResResultEnum.DEFAULT_ERROR_MESSAGE);
????????}?finally?{
????????????//執(zhí)行完畢之后，手動將鎖釋放
????????????redisLockService.releaseLock(lockKey,?DEFAULT_LOCK_VALUE);
????????}
????}
????/**
?????*?獲取請求對象
?????*?@return
?????*/
????private?HttpServletRequest?getHttpServletRequest(){
????????RequestAttributes?ra?=?RequestContextHolder.getRequestAttributes();
????????ServletRequestAttributes?sra?=?(ServletRequestAttributes)ra;
????????HttpServletRequest?request?=?sra.getRequest();
????????return?request;
????}
}
部分校驗邏輯用到了redis分布式鎖，具體實現邏輯如下：
/**
?*?redis分布式鎖服務類
?*?采用LUA腳本實現，保證加鎖、解鎖操作原子性
?*
?*/
@Component
public?class?RedisLockService?{
????/**
?????*?分布式鎖過期時間，單位秒
?????*/
????private?static?final?Long?DEFAULT_LOCK_EXPIRE_TIME?=?60L;
????@Autowired
????private?StringRedisTemplate?stringRedisTemplate;
????/**
?????*?嘗試在指定時間內加鎖
?????*?@param?key
?????*?@param?value
?????*?@param?timeout?鎖等待時間
?????*?@return
?????*/
????public?boolean?tryLock(String?key,String?value,?Duration?timeout){
????????long?waitMills?=?timeout.toMillis();
????????long?currentTimeMillis?=?System.currentTimeMillis();
????????do?{
????????????boolean?lock?=?lock(key,?value,?DEFAULT_LOCK_EXPIRE_TIME);
????????????if?(lock)?{
????????????????return?true;
????????????}
????????????try?{
????????????????Thread.sleep(1L);
????????????}?catch?(InterruptedException?e)?{
????????????????Thread.interrupted();
????????????}
????????}?while?(System.currentTimeMillis()?<?currentTimeMillis?+?waitMills);
????????return?false;
????}
????/**
?????*?直接加鎖
?????*?@param?key
?????*?@param?value
?????*?@param?expire
?????*?@return
?????*/
????public?boolean?lock(String?key,String?value,?Long?expire){
????????String?luaScript?=?"if?redis.call('setnx',?KEYS[1],?ARGV[1])?==?1?then?return?redis.call('expire',?KEYS[1],?ARGV[2])?else?return?0?end";
????????RedisScript<Long>?redisScript?=?new?DefaultRedisScript<>(luaScript,?Long.class);
????????Long?result?=?stringRedisTemplate.execute(redisScript,?Collections.singletonList(key),?value,?String.valueOf(expire));
????????return?result.equals(Long.valueOf(1));
????}
????/**
?????*?釋放鎖
?????*?@param?key
?????*?@param?value
?????*?@return
?????*/
????public?boolean?releaseLock(String?key,String?value){
????????String?luaScript?=?"if?redis.call('get',?KEYS[1])?==?ARGV[1]?then?return?redis.call('del',?KEYS[1])?else?return?0?end";
????????RedisScript<Long>?redisScript?=?new?DefaultRedisScript<>(luaScript,?Long.class);
????????Long?result?=?stringRedisTemplate.execute(redisScript,?Collections.singletonList(key),value);
????????return?result.equals(Long.valueOf(1));
????}
}
2.5、在相關的業(yè)務接口上，增加SubmitToken注解即可
@RestController
@RequestMapping("order")
public?class?OrderController?{
????@Autowired
????private?OrderService?orderService;
????/**
?????*?下單
?????*?@param?request
?????*?@return
?????*/
????@SubmitToken
????@PostMapping(value?=?"confirm")
????public?ResResult?confirm(@RequestBody?OrderConfirmRequest?request){
????????//調用訂單下單相關邏輯
????????orderService.confirm(request);
????????return?ResResult.getSuccess();
????}
}
整套方案完全基于redis來實現，同時結合redis的分布式鎖來實現請求限流，之所以選擇redis，是因為它是一個內存數據庫，性能比關系型數據庫強太多，即使每秒的下單請求量在幾千，也能很好的應對，為關系型數據庫起到降壓作用！
特別注意的地方：使用redis的分布式鎖，推薦單機環(huán)境，如果redis是集群環(huán)境，可能會導致鎖短暫無效！
三、小結
隨著下單流量逐漸上升，通過查詢數據庫來檢查當前服務請求是否重復提交這種方式，可能會讓數據庫的請求查詢頻率變得非常高，數據庫的壓力會倍增。
此時我們可以引入redis緩存，將通過查詢數據庫來檢查當前請求是否重復提交這種方式，轉移到通過查詢緩存來檢查當前請求是否重復提交，可以很好的給數據庫降壓！
到此這篇關于Java利用redis實現防止接口重復提交的文章就介紹到這了,更多相關Java redis接口防重復提交內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
相關文章
本文主要講解了Zookeeper的基礎知識，ZooKeeper提供了一個通用協(xié)調模式實現方法的開源共享庫，使程序員免于寫這類通用的協(xié)議。關于Zookeeper更多相關知識，感興趣的小伙伴參考一下這篇文章2021-09-09
Java Spring Cloud Bus 實現配置實時更新詳解
這篇文章主要介紹了SpringCloud Bus如何實現配置刷新,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2021-09-09
SpringCloudAlibaba是一款優(yōu)秀的微服務架構,在市面上有著廣泛的應用,這篇文章介紹了SpringCloudAlibaba的一些基本使用,適合初學者,希望能夠給大家?guī)韼椭?/div> 2024-08-08
這篇文章主要介紹了使用SpringBoot_jar方式啟動并配置日志文件操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
基于bufferedreader的read()與readline()讀取出錯原因及解決
這篇文章主要介紹了bufferedreader的read()與readline()讀取出錯原因及解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
本篇文章主要介紹了淺談Spring @Async異步線程池用法總結，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-07-07
這篇文章主要介紹了使用Spring靜態(tài)注入實現讀取配置工具類新方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
這篇文章主要介紹了SpringBoot整合阿里?Druid?數據源，主要講解了手動配置方法，結合實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-11-11
Spring?Boot讓我們可以快速構建項目并運行web應用,大大簡化了Spring的復雜配置,本文主要介紹了SpringBoot進行Web開發(fā)的實現,感興趣的可以了解一下2023-10-10
這篇文章主要介紹了springboot實現通過路徑從磁盤直接讀取圖片，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03最新評論