【Redisson】鎖可重入原理

目錄

一、基本原理

二、源碼解析:

(2)獲取鎖

(1)釋放鎖:


? ? ? ?

????????之前給大家介紹過redisson的分布式鎖,用redisson來實現比自己手搓簡單的分布式鎖有很多好處,因為這些可重入、可重試的邏輯較為復雜,他們的lua腳本不可能讓我們在開發時自己實現,這樣太耗時間了。所以redisson就幫我們實現了可重入和可重試。但我們也要知道他的原理,這期我們先講可重入。


上一篇:

【Redisson】快速實現分布式鎖-CSDN博客


一、基本原理

基本原理:

(1)獲取鎖的時候,還是使用setnx命令,如果該鎖還沒有被獲取過,直接set,也就是獲取鎖成功

(2)當該線程第二次獲取鎖時,因為鎖已經被獲取了,也就是setnx返回false。這時候,先不直接返回獲取鎖失敗的邏輯,而是先判斷該鎖的value值是不是自己,如果是,那么就獲取鎖成功。

(3)有一個計數器,每次獲取鎖成功計數器就+1,每次釋放鎖的時候計數器就-1。當計數器為0的時候表明該線程所有重入的鎖都被釋放完畢了,就可以刪除這個key。那么其他線程就可以獲取鎖了

(4)因為key的value值既要記錄線程標識,也要記錄重入次數。所以String類型的結構就不滿足了。需要使用到hash結構

(5)注意:每次釋放鎖時,如果value值不是0,說明該鎖還是被該線程占用的。也就是釋放重入鎖的時候,要重置鎖的有效期

圖解:



二、源碼解析:

(2)獲取鎖

<T> RFuture<T> tryLockInnerAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) {return this.commandExecutor.syncedEvalNoRetry(this.getRawName(), LongCodec.INSTANCE, command, "local mode = redis.call('hget', KEYS[1], 'mode');" +"   if (mode == false) then " +"       redis.call('hset', KEYS[1], 'mode', 'read');" +"       redis.call('hset', KEYS[1], ARGV[2], 1);" +"       redis.call('set', KEYS[2] .. ':1', 1);" +"        redis.call('pexpire', KEYS[2] .. ':1', ARGV[1]);" +"       redis.call('pexpire', KEYS[1], ARGV[1]);" +"       return nil;" +"   end;" +"   if (mode == 'read') or (mode == 'write' and redis.call('hexists', KEYS[1], ARGV[3]) == 1) then" +"        local ind = redis.call('hincrby', KEYS[1], ARGV[2], 1);" +"        local key = KEYS[2] .. ':' .. ind;redis.call('set', key, 1);" +"        redis.call('pexpire', key, ARGV[1]);" +"        local remainTime = redis.call('pttl', KEYS[1]);" +"        redis.call('pexpire', KEYS[1], math.max(remainTime, ARGV[1]));" +"        return nil;" +"   end;" + "return redis.call('pttl', KEYS[1]);",Arrays.asList(this.getRawName(), this.getReadWriteTimeoutNamePrefix(threadId)), new Object[]{unit.toMillis(leaseTime), this.getLockName(threadId), this.getWriteLockName(threadId)});}

解析:

(1)釋放鎖:

解析:?

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/909172.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/909172.shtml
英文地址,請注明出處:http://en.pswp.cn/news/909172.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

BERT 模型微調與傳統機器學習的對比

BERT 微調與傳統機器學習的區別和聯系&#xff1a; 傳統機器學習流程 傳統機器學習處理文本分類通常包含以下步驟&#xff1a; 特征工程&#xff1a;手動設計特征&#xff08;如 TF-IDF、詞袋模型&#xff09;模型訓練&#xff1a;使用分類器&#xff08;如 SVM、隨機森林、邏…

(12)-Fiddler抓包-Fiddler設置IOS手機抓包

1.簡介 Fiddler不但能截獲各種瀏覽器發出的 HTTP 請求&#xff0c;也可以截獲各種智能手機發出的HTTP/ HTTPS 請求。 Fiddler 能捕獲Android 和 Windows Phone 等設備發出的 HTTP/HTTPS 請求。同理也可以截獲iOS設備發出的請求&#xff0c;比如 iPhone、iPad 和 MacBook 等蘋…

芯科科技Tech Talks技術培訓重磅回歸:賦能物聯網創新,共筑智能互聯未來

聚焦于Matter、藍牙、Wi-Fi、LPWAN、AI/ML五大熱門無線協議與技術 為年度盛會Works With大會賦能先行 隨著物聯網&#xff08;IoT&#xff09;和人工智能&#xff08;AI&#xff09;技術的飛速發展&#xff0c;越來越多的企業和個人開發者都非常關注最新的無線連接技術和應用…

docker-compose容器單機編排

docker-compose容器單機編排 開篇前言 隨著網站架構的升級&#xff0c;容器的使用也越來越頻繁&#xff0c;應用服務和容器之間的關系也越發的復雜。 這個就要求研發人員能更好的方法去管理數量較多的服務器&#xff0c;而不能手動挨個管理。 例如一個LNMP 架構&#xff0c;就…

LeetCode--29.兩數相除

解題思路&#xff1a; 1.獲取信息&#xff1a; 給定兩個整數&#xff0c;一個除數&#xff0c;一個被除數&#xff0c;要求返回商&#xff08;商取整數&#xff09; 限制條件&#xff1a;&#xff08;1&#xff09;不能使用乘法&#xff0c;除法和取余運算 &#xff08;2&#…

中山大學GaussianFusion:首個將高斯表示引入端到端自動駕駛多傳感器融合的新框架

摘要 近年來由于端到端自動駕駛極大簡化了原有傳統自動駕駛模塊化的流程&#xff0c;吸引了來自工業界和學術界的廣泛關注。然而&#xff0c;現有的端到端智駕算法通常采用單一傳感器&#xff0c;使其在處理復雜多樣和具有挑戰性的駕駛場景中受到了限制。而多傳感器融合可以很…

《哈希算法》題集

1、模板題集 滿足差值的數字對 2、課內題集 字符統計 字符串統計 優質數對 3、課后題集 2006 Equations k倍區間 可結合的元素對 滿足差值的數字對 異常頻率 神秘數對 費里的語言 連連看 本題集為作者&#xff08;英雄哪里出來&#xff09;在抖音的獨家課程《英雄C入門到精…

Cordova移動應用對云端服務器數據庫的跨域訪問

Cordova移動應用對云端服務器數據庫的跨域訪問 當基于類似 Cordova這樣的跨平臺開發框架進行移動應用的跨平臺開發時&#xff0c;往往需要訪問部署在公網云端服務器上的數據庫&#xff0c;這時就涉及到了跨域數據訪問的問題。 文章目錄 Cordova移動應用對云端服務器數據庫的跨…

mysql知識點3--創建和使用數據庫

mysql知識點3–創建數據庫 創建數據庫 在MySQL中創建數據庫使用CREATE DATABASE語句。語法如下&#xff1a; CREATE DATABASE database_name;其中database_name為自定義的數據庫名稱。例如創建名為test_db的數據庫&#xff1a; CREATE DATABASE test_db;可以添加字符集和排…

林業資源多元監測技術守護綠水青山

在云南高黎貢山的密林中&#xff0c;無人機群正以毫米級精度掃描古樹年輪&#xff1b;福建武夷山保護區&#xff0c;衛星遙感數據實時追蹤著珍稀動植物的棲息地變化&#xff1b;海南熱帶雨林里&#xff0c;AI算法正從億萬條數據中預測下一場山火的風險……這些科幻場景&#xf…

一階/二階Nomoto模型(野本模型)為何“看不到”船速對回轉角速度/角加速度的影響?

提問 圖中的公式反映的是舵角和力矩之間的關系&#xff0c; 其中可以看到力矩&#xff08;可以理解為角加速度&#xff09;以及相應導致的回轉角速度和當前的舵速&#xff08;主要由船速貢獻&#xff09;有關&#xff0c;那么為什么一階Nomoto模型&#xff08;一階野本&#xf…

深入剖析 C++ 默認函數:拷貝構造與賦值運算符重載

目錄 1. 簡單認識C 類的默認函數 1.1 默認構造函數 1.2 析構函數 1.3 拷貝構造函數 2. 拷貝構造函數的深入理解 拷貝構造的特點: 實際運用 3. 賦值運算符重載的深入理解 3.1.運算符重載 3.2樣例 1.比較運算符重載 2.算術運算符重載 3.自增和自減運算符重載 4.輸…

板凳-------Mysql cookbook學習 (十--3)

5.16 用短語來進行fulltext查詢 mysql> select count(*) from kjv where match(vtext) against(God); ---------- | count(*) | ---------- | 0 | ---------- 1 row in set (0.00 sec)mysql> select count(*) from kjv where match(vtext) against(sin); -------…

python爬蟲ip封禁應對辦法

目錄 一、背景現象 二、準備工作 三、代碼實現 一、背景現象 最近在做爬蟲項目時&#xff0c;爬取的網站&#xff0c;如果發送請求太頻繁的話&#xff0c;對方網站會先是響應緩慢&#xff0c;最后是封禁一段時間。一直是拒絕連接&#xff0c;導致程序無法正常預期的爬取數據…

【AIGC】Qwen3-Embedding:Embedding與Rerank模型新標桿

Qwen3-Embedding&#xff1a;Embedding與Rerank模型新標桿 一、引言二、技術架構與核心創新1. 模型結構與訓練策略&#xff08;1&#xff09;多階段訓練流程&#xff08;2&#xff09;高效推理設計&#xff08;3&#xff09;多語言與長上下文支持 2. 與經典模型的性能對比 三、…

算法競賽階段二-數據結構(32)數據結構簡單介紹

數據結構的基本概念 數據結構是計算機存儲、組織數據的方式&#xff0c;旨在高效地訪問和修改數據。它是算法設計的基礎&#xff0c;直接影響程序的性能。數據結構可分為線性結構和非線性結構兩大類。 線性數據結構 線性結構中&#xff0c;數據元素按順序排列&#xff0c;每…

Windows桌面圖標修復

新建文本文件&#xff0c;粘入以下代碼&#xff0c;保存為.bat文件&#xff0c;管理員運行這個文件 duecho off taskkill /f /im explorer.exe CD /d %userprofile%\AppData\Local DEL IconCache.db /a start explorer.exe echo 執行完成上面代碼作用是刪除桌面圖標緩存庫&…

13.react與next.js的特性和原理

&#x1f7e1; 一句話總結 React 專注于構建組件&#xff0c;而 Next.js 是基于 React 的全棧框架&#xff0c;提供了頁面路由、服務端渲染和全棧能力&#xff0c;讓你能快速開發現代 Web 應用。 React focuses on building UI components, while Next.js is a full-stack fra…

全棧監控系統架構

全棧監控系統架構 可觀測性從數據層面可分為三類&#xff1a; 指標度量(Metrics)&#xff1a;記錄系統的總體運行狀態。事件日志(Logs)&#xff1a;記錄系統運行期間發生的離散事件。鏈路追蹤(Tracing)&#xff1a;記錄一個請求接入到結束的處理過程&#xff0c;主要用于排查…

云服務運行安全創新標桿:阿里云飛天洛神云網絡子系統“齊天”再次斬獲獎項

引言 為認真落實工信部《工業和信息化部辦公廳關于印發信息通信網絡運行安全管理年實施方案的通知》&#xff0c;2025年5月30日中國信息通信研究院于浙江杭州舉辦了“云服務運行安全高質量發展交流會”&#xff0c;推動正向引導&#xff0c;鞏固云服務安全專項治理成果。會上&a…