掃二維碼與項(xiàng)目經(jīng)理溝通
我們在微信上24小時(shí)期待你的聲音
解答本文疑問/技術(shù)咨詢/運(yùn)營咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流
作者:程序員小航 2021-07-03 17:45:57
開發(fā)
前端
分布式
Redis 基于 Redis 的 Redisson 分布式聯(lián)鎖 RedissonMultiLock 對象可以將多個(gè) RLock 對象關(guān)聯(lián)為一個(gè)聯(lián)鎖,每個(gè) RLock 對象實(shí)例可以來自于不同的 Redisson 實(shí)例。

目前創(chuàng)新互聯(lián)已為成百上千家的企業(yè)提供了網(wǎng)站建設(shè)、域名、虛擬空間、網(wǎng)站運(yùn)營、企業(yè)網(wǎng)站設(shè)計(jì)、五大連池網(wǎng)站維護(hù)等服務(wù),公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
基于 Redis 的 Redisson 分布式聯(lián)鎖 RedissonMultiLock 對象可以將多個(gè) RLock 對象關(guān)聯(lián)為一個(gè)聯(lián)鎖,每個(gè) RLock 對象實(shí)例可以來自于不同的 Redisson 實(shí)例。
當(dāng)然,這是官網(wǎng)的介紹,具體是什么?一起看看聯(lián)鎖 MultiLock 使用以及源碼吧!
按照官方文檔的說法,這里 Redisson 客戶端可以不是同一個(gè)。當(dāng)然,一般工作中也不會說不用一個(gè)客戶端吧。
在閱讀 MultiLock 加鎖之前,小伙伴應(yīng)該已經(jīng)閱讀過普通加鎖的相關(guān)文章。
源碼入口:org.redisson.RedissonMultiLock#lock()
默認(rèn)超時(shí)時(shí)間 leaseTime 沒有設(shè)置,所以為 -1。
這塊方法太長,咱們拆分進(jìn)行閱讀。
調(diào)用 tryLock 方法,其中參數(shù) waitTime = 4500,leaseTime = -1,unit = MILLISECONDS。
下面看一下 tryLock 里面有什么邏輯?
leaseTime != -1 不滿足,這部分直接跳過。
waitTime != -1 條件滿足,remainTime = 4500,lockWaitTime = 4500。
所以,failedLocksLimit() 這個(gè)方法直接返回 0,就是必須全部加鎖成功。
這里才是重點(diǎn):
遍歷所有的鎖,依次加鎖。
加鎖邏輯就和可重入鎖加鎖并無區(qū)別了。所以 Lua 腳本就不進(jìn)行分析了。
上面就是 tryLock 加鎖之后的結(jié)果。
加鎖成功,則將成功的鎖放進(jìn) acquiredLocks 集合中;
加鎖失敗,需要判斷 failedLocksLimit,因?yàn)檫@里是 0,所以會直接對成功加鎖集合 acquiredLocks 中的所有鎖執(zhí)行鎖釋放,同時(shí)清空成功集合,恢復(fù)迭代器。
每次加鎖之后,會更新鎖剩余時(shí)間 remainTime,如果 remainTime 小于等于 0 了,則說明加鎖超時(shí),直接返回 false。
這樣就會執(zhí)行外部的 while (true) 邏輯,然后重新再走一遍 RedissonMultiLock#tryLock。
看完加鎖邏輯,鎖釋放就更容易理解了。
直接遍歷釋放鎖即可,lock.unlockAsync() 是調(diào)用的 RedissonBaseLock#unlockAsync() 方法。
根據(jù)我的理解,畫圖如下:
總體而言,就是將 key1、key2、key3 …… keyN 放到一個(gè) List 集合中,然后迭代循環(huán)加鎖,直到所有的都成功。解鎖的時(shí)候就是再遍歷鎖進(jìn)行釋放鎖。
本文轉(zhuǎn)載自微信公眾號「程序員小航」,可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系程序員小航公眾號。

我們在微信上24小時(shí)期待你的聲音
解答本文疑問/技術(shù)咨詢/運(yùn)營咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流