redis解決高并發(fā)看門狗策略的實現(xiàn)
當一個業(yè)務(wù)執(zhí)行時間超過自己設(shè)定的鎖釋放時間,那么會導致有其他線程進入,從而搶到同一個票,所有需要使用看門狗策略,其實就是開一個守護線程,讓守護線程去監(jiān)控key,如果到時間了還未結(jié)束,就會將這個key重新set一次,重置到原來的時間,只要主線程未結(jié)束,守護線程就會一直存在,這里還是會有一些問題,就是如果redis宕機了,導致第一個線程拿到了鎖,第二個線程也拿到了鎖,為了解決這個就需要引入紅鎖
1. 導入依賴,這里導入依賴可能會和原先的redis依賴沖突,所以只能留下一個,不然可能會出錯
去除spring-boot-starter-data-redis
<!-- 集成Redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>添加redisson
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.21.0</version>
</dependency>2. 修改配置文件,將之前的配置緩存redisson的
spring:
data:
redis: # redis配置
url: redis://:127.0.0.1:63793. 開始分布式鎖-看門狗策略,找到高頻訪問的業(yè)務(wù)添加以下代碼
在業(yè)務(wù)方法開始的頭添加

在方法末尾添加釋放鎖,別忘了添加try-catch-finally塊

這是一段完整的分布式處理,有需要直接copy后修改即可
public void doConfirm(ConfirmOrderDoReq req) {
String lockKey = DateUtil.formatDate(req.getDate()) + "-" + req.getTrainCode();
RLock lock = null;
try {
lock = redissonClient.getLock(lockKey);
boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);
if (tryLock) {
LOG.info("搶到鎖,開始處理訂單");
} else {
LOG.info("很遺憾,沒有搶到鎖");
//當前搶票人數(shù)多,請稍后再試
throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);
}
//業(yè)務(wù)處理。。。。
} catch (InterruptedException e) {
LOG.error("搶票失敗", e);
throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);
} finally {
LOG.info("鎖被釋放了");
// 釋放鎖
if (lock != null && lock.isHeldByCurrentThread()){
lock.unlock();
}
}
}到此這篇關(guān)于redis解決高并發(fā)看門狗策略的實現(xiàn)的文章就介紹到這了,更多相關(guān)redis 高并發(fā)看門狗策略內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Redis數(shù)據(jù)庫的應(yīng)用場景介紹
這篇文章主要介紹了Redis數(shù)據(jù)庫的應(yīng)用場景介紹,本文講解了MySql+Memcached架構(gòu)的問題、Redis常用數(shù)據(jù)類型、Redis數(shù)據(jù)類型應(yīng)用和實現(xiàn)方式、Redis實際應(yīng)用場景等內(nèi)容,需要的朋友可以參考下2015-06-06
Redis序列化反序列化不一致導致String類型值多了雙引號問題
這篇文章主要介紹了Redis序列化反序列化不一致導致String類型值多了雙引號問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-08-08

