Redis分布式鎖解決超賣問題
更新時間：2023年12月11日 10:51:03 作者：Eliauk-_-
超賣問題是典型的多線程安全問題,本文就來介紹一下Redis分布式鎖解決超賣問題,具有一定的參考價值,感興趣的可以了解一下
一、使用redisTemplate中的setIfAbsent方法。
// setIfAbsent就是對應(yīng)redis的setnx
Boolean setIfAbsent = redisTemplate.opsForValue().setIfAbsent(lockKey, lockKey, 10, TimeUnit.SECONDS);
if (Boolean.TRUE.equals(setIfAbsent)) {
LOG.info("恭喜，搶到鎖了！lockKey：{}", lockKey);
} else {
LOG.info("很遺憾，沒搶到鎖！lockKey：{}", lockKey);
}缺點：
- 性能不高，可能會導致少買。
- 假如業(yè)務(wù)執(zhí)行時間長，設(shè)置的鎖的過期時間短的話，可能出現(xiàn)超賣問題。
二、使用Redisson解決（看門狗方式）
2.1、實現(xiàn)原理
redisson在獲取鎖之后，會開啟一個守護線程（看門狗線程），當鎖即將過期還沒有釋放時，不斷的延長鎖key的生存時間
2.2、SpringBoot集成Redisson
2.2.1、添加pom.xml依賴
<!--至少3.18.0版本，才支持spring boot 3-->
<!--升級到3.20.0，否則打包生產(chǎn)會報錯：Could not initialize class org.redisson.spring.data.connection.RedissonConnection-->
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.21.0</version>
</dependency>2.2.2、注入RedissonClient對象
@Autowired private RedissonClient redissonClient;
2.2.3、使用Redisson
RLock lock = null;
try {
// 使用redisson，自帶看門狗
lock = redissonClient.getLock(lockKey);
/**
waitTime – the maximum time to acquire the lock 等待獲取鎖時間(最大嘗試獲得鎖的時間)，超時返回false
leaseTime – lease time 鎖時長，即n秒后自動釋放鎖
time unit – time unit 時間單位
*/
// boolean tryLock = lock.tryLock(30, 10, TimeUnit.SECONDS); // 不帶看門狗
boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS); // 帶看門狗
if (tryLock) {
LOG.info("恭喜，搶到鎖了！");
} else {
LOG.info("很遺憾，沒搶到鎖");
}
} catch (InterruptedException e) {
LOG.error("發(fā)生異常", e);
} finally {
LOG.info("釋放鎖！");
//當lock不等于null并且lock是當前線程的時候去釋放鎖
if (null != lock && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}缺點：
- 看門狗啟動后，對整體性能也會有一定影響
- 當redis宕機后，獲取不到鎖，業(yè)務(wù)中斷。
- 正常情況下，如果加鎖成功了，那么master節(jié)點會異步復制給對應(yīng)的slave節(jié)點。但是如果在這個過程中發(fā)生master節(jié)點宕機，主備切換，slave節(jié)點從變?yōu)榱?master節(jié)點，而鎖還沒從舊master節(jié)點同步過來，這就發(fā)生了鎖丟失，會導致多個客戶端可以同時持有同一把鎖的問題
三、Redis紅鎖
2.1、Redis紅鎖名稱來源
Redis 紅鎖的名稱來源于 Redis 的logo，Redis 的 logo 是一個紅色熱氣球，而紅色的熱氣球上有一把鎖的圖案，因此這種分布式鎖解決方案也被稱為"Redlock"，中文翻譯為"紅鎖"。
2.2、原理
現(xiàn)在假設(shè)有5個Redis主節(jié)點(大于3的奇數(shù)個)，這樣基本保證他們不會同時都宕掉，獲取鎖和釋放鎖的過程中，客戶端會執(zhí)行以下操作：
- 獲取當前Unix時間，以毫秒為單位，并設(shè)置超時時間過期時間（過期時間要大于正常業(yè)務(wù)執(zhí)行的時間 + 獲取所有redis服務(wù)消耗時間 + 時鐘漂移）
- 依次嘗試從5個實例，使用相同的key和具有唯一性的value獲取鎖，當向Redis請求獲取鎖時，客戶端應(yīng)該設(shè)置一個網(wǎng)絡(luò)連接和響應(yīng)超時時間，這個超時時間應(yīng)該小于鎖的失效時間TTL，這樣可以避免客戶端死等。比如：TTL為5s，設(shè)置獲取鎖最多用1s，所以如果一秒內(nèi)無法獲取鎖，就放棄獲取這個鎖，從而嘗試獲取下個鎖
- 客戶端 獲取所有能獲取的鎖后的時間 減去 第(1)步的時間，就得到鎖的獲取時間。鎖的獲取時間要小于鎖失效時間TTL，并且至少從半數(shù)以上的Redis節(jié)點取到鎖，才算獲取成功鎖
- 如果成功獲得鎖，key的真正有效時間 = TTL - 鎖的獲取時間 - 時鐘漂移。比如：TTL 是5s,獲取所有鎖用了2s，則真正鎖有效時間為3s
- 如果因為某些原因，獲取鎖失?。]有在半數(shù)以上實例取到鎖或者取鎖時間已經(jīng)超過了有效時間），客戶端應(yīng)該在所有的Redis實例上進行解鎖，無論Redis實例是否加鎖成功，因為可能服務(wù)端響應(yīng)消息丟失了但是實際成功了。
2.3、代碼實現(xiàn)
2.3.1、注冊紅鎖的RedissonClient
@Component
public class RedisConfig {
@Bean(name = "redissonClient1")
@Primary
public RedissonClient redissonRed1(){
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6379").setDatabase(0);
return Redisson.create(config);
}
@Bean(name = "redissonClient2")
public RedissonClient redissonRed2(){
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6380").setDatabase(0);
return Redisson.create(config);
}
@Bean(name = "redissonClient3")
public RedissonClient redissonRed3(){
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6381").setDatabase(0);
return Redisson.create(config);
}
@Bean(name = "redissonClient4")
public RedissonClient redissonRed4(){
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6382").setDatabase(0);
return Redisson.create(config);
}
@Bean(name = "redissonClient5")
public RedissonClient redissonRed5(){
Config config = new Config();
config.useSingleServer().setAddress("127.0.0.1:6383").setDatabase(0);
return Redisson.create(config);
}
}
2.3.2、注入Redis紅鎖對象
// 紅鎖
@Autowired
@Qualifier("redissonClient1")
private RedissonClient redissonClient1;
@Autowired
@Qualifier("redissonClient2")
private RedissonClient redissonClient2;
@Autowired
@Qualifier("redissonClient3")
private RedissonClient redissonClient3;
@Autowired
@Qualifier("redissonClient4")
private RedissonClient redissonClient4;
@Autowired
@Qualifier("redissonClient5")
private RedissonClient redissonClient5;2.3.3、使用Redis紅鎖
/*
假設(shè)有五臺redis機器， A B C D E
線程1: A B C D E（獲取到鎖）
線程2: C D E（獲取到鎖）
線程3: C（未獲取到鎖）
*/
RLock lock1 = null;
RLock lock2 = null;
RLock lock3 = null;
RLock lock4 = null;
RLock lock5 = null;
try {
lock1 = redissonClient1.getLock(lockKey);
lock2 = redissonClient2.getLock(lockKey);
lock3 = redissonClient3.getLock(lockKey);
lock4 = redissonClient4.getLock(lockKey);
lock5 = redissonClient5.getLock(lockKey);
// 紅鎖的寫法
RedissonRedLock redissonRedLock = new RedissonRedLock(lock1, lock2, lock3, lock4, lock5);
boolean tryLock = redissonRedLock.tryLock(0, TimeUnit.SECONDS);
if (tryLock) {
LOG.info("恭喜，搶到鎖了！");
} else {
LOG.info("很遺憾，沒搶到鎖");
}
} catch (InterruptedException e) {
LOG.error("發(fā)生異常", e);
} finally {
LOG.info("釋放鎖！");
//當lock不等于null并且lock是當前線程的時候去釋放鎖
if (null != lock && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}注意：
- 按照順序獲取鎖、不然會出現(xiàn)每個線程都拿不到鎖的情況。
- 當redis宕機后，切換主備或者重啟時間需大于鎖的時間，不然會有線程同時獲取到鎖（比如線程1獲取到a,b,c，獲得了鎖后c宕機重啟了，如果數(shù)據(jù)沒有備份，c中沒有key,線程2有可能獲取到了c,d,e，也獲取到了鎖）。
- 盡可能的獲取到更多redis實例的鎖。
- 獲取鎖的時間要注意，需要設(shè)置超時時間，如果超時時間內(nèi)拿不到鎖，結(jié)束線程
到此這篇關(guān)于Redis分布式鎖解決超賣問題的文章就介紹到這了,更多相關(guān)Redis分布式鎖超賣內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要給大家介紹了關(guān)于Redis搭建集群之Sentinel的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-11-11
Redis Redisson lock和tryLock的原理分析
這篇文章主要介紹了Redis Redisson lock和tryLock的原理分析，具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-04-04
Springboot/Springcloud項目集成redis進行存取的過程解析
大家都知道Redis支持五種數(shù)據(jù)類型：string（字符串），hash（哈希），list（列表），set（集合），zset(sorted set：有序集合)，本文重點給大家介紹Springboot/Springcloud項目集成redis進行存取的過程，需要的朋友參考下吧2021-12-12
這篇文章主要介紹了Redis教程(十四)：內(nèi)存優(yōu)化介紹,本文講解了特殊編碼、BIT和Byte級別的操作、盡可能使用Hash等內(nèi)容,需要的朋友可以參考下2015-05-05
這篇文章主要介紹了Redis的主從同步解析，見識淺薄，僅供參考。2017-10-10
這篇文章主要介紹了Redis持久化深入詳解，講解的還是比較詳細的，有感興趣的同學可以學習下2021-03-03
這篇文章詳細介紹了caffeine_redis 自定義二級緩存，文中有相關(guān)的背景前提與出現(xiàn)的問題，感興趣的同學可以參考一下2023-04-04
Redis過期事件監(jiān)聽器的完整實現(xiàn)步驟
要使用 Redis 過期事件監(jiān)聽器來更新數(shù)據(jù)庫狀態(tài),我們需要確保 Redis 的事件通知已啟用,并實現(xiàn)監(jiān)聽器來捕獲過期的鍵,并根據(jù)需要更新數(shù)據(jù)庫,本文給大家介紹了Redis過期事件監(jiān)聽器的完整實現(xiàn)步驟,需要的朋友可以參考下2024-10-10
這篇文章主要給大家分享介紹了關(guān)于Redis獲取某個大key值的一個腳本實例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧。2018-04-04
本文主要介紹了Redis實現(xiàn)附近商鋪的項目實戰(zhàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-01-01