全新的分布式鎖，幾行程式碼搞定，簡單且強大

👉 歡迎 ，你將獲得: 專屬的計畫實戰 / Java 學習路線 / 一對一提問 / 學習打卡 / 贈書福利

新計畫: 仿小紅書 (微服務架構)正在更新中... , 全棧前後端分離部落格計畫 2.0 版本完結啦， 演示連結 ： http://116.62.199.48/ 。全程手摸手，後端 + 前端全棧開發，從 0 到 1 講解每個功能點開發步驟，1v1 答疑，直到計畫上線。 目前已更新了255小節，累計39w+字，講解圖：1716張，還在持續爆肝中.. 後續還會上新更多計畫，目標是將Java領域典型的計畫都整一波，如秒殺系統, 線上商城, IM即時通訊，Spring Cloud Alibaba 等等，

前言：分布式鎖是分布式系統中一個極為重要的工具。目前有多種分布式鎖的設計方案，比如借助 redis，mq，資料庫，zookeeper 等第三方服務系統來設計分布式鎖。tldb 提供的分布式鎖，主要是要簡化這個設計的過程，提供一個簡潔可靠，類似使用程式中物件鎖的方式來獲取分布式鎖。

tldb 提供分布式鎖使用方法：

1. lock 阻塞式請求鎖

2. trylock 嘗試加鎖，若鎖已被占用，則失敗返回，反之，則獲取該鎖

3. unlock 釋放已經獲取的鎖

   tldb 提供的分布式鎖功能主要在 MQ 模組中實作，呼叫的方法在 MQ 客戶端實作，客戶端的實作實際非常簡單，除了目前已經實作的幾種語言 java，golang，python，javaScript 寫的 simpleClient，其實其他開發者有興趣也可以實作其他語言的 MQ 客戶端，完全沒有技術門檻。分布式鎖由 tldb 伺服器控制，所以它相對客戶端來說，也是跨語言的，如，用 java 客戶端上鎖的物件，其他語言同樣無法獲取該物件鎖。

Lock （string,int） 方法的使用

tldb 提供的是以字串為鎖物件的獨占鎖， 如，lock ("abc",3) 必須提供兩個參數：

1. 第一個參數為鎖物件，即伺服器對 「abc」 物件分配一個鎖，所有對 "abc" 物件請求加鎖的執行緒爭用一個獨占鎖，該方法為一個阻塞方法，請求到鎖則返回，如果鎖被其他執行緒占用，則一直阻塞直至獲取到鎖。

2. 第二個參數為持有該分布式鎖的最長時間，單位為秒，例如 lock ("abc",3)，意思是，如果超過 3 秒還沒有呼叫 unlock 釋放該鎖，伺服器將強制釋放該鎖，繼續將鎖分配給其他請求的執行緒。

UnLock （string） 方法的使用

TryLock （string,int） 方法的使用

以下以 go 為例使用分布式鎖

因為 tldb 分布式的實作是在 MQ 模組，所以 go 程式必須使用 tlmq-go, tldb 的 mq 客戶端進行呼叫鎖方法。

import "github.com/donnie4w/tlmq-go/cli"


呼叫 lock 的程式：lock 方法是阻塞的

sc := cli.NewMqClient("ws://127.0.0.1:5001", "mymq=123")
sc.Connect()
//以上為 客戶端連線MQ伺服器
key, err := sc.Lock("testlock", 3)
//lock中兩個參數，第一個參數為字串，即tldb伺服器為「testlock」分配一個全域的分布式鎖
//第二個參數3為客戶端持有該鎖的最長時間，表示超過3秒沒有釋放鎖時，tldb伺服器將在伺服端強制釋放該鎖，並分配給其他請求鎖的執行緒
if err!=nil{
//獲取鎖失敗，需檢視tldb能正常存取
}else{
defer sc.UnLock(key) //獲取鎖成功後，必須在程式最後呼叫Unlock
//執行業務邏輯程式
}


呼叫 tryLock 的程式，trylock 是非阻塞的

sc := cli.NewMqClient("ws://127.0.0.1:5001", "mymq=123")
sc.Connect()
if key, ok := sc.TryLock("testlock2", 3); ok {
//ok為true，表示已經成功獲取到分布式鎖
defer sc.UnLock(key) //在程式最後釋放鎖物件
...
}

go 用自旋的方式使用 trylock 獲取分布式鎖，實作程式的阻塞等待

sc := cli.NewMqClient("ws://127.0.0.1:5001", "mymq=123")
sc.Connect()
var key string
for {
if v, ok := sc.TryLock("testlock", 3); ok {
key = v
break
 } else {
<-time.After(100* time.Millisecond)
 }
}
defer sc.UnLock(key)
...//業務邏輯程式碼


這段程式應該比較易於理解，就是每隔 100 毫秒，迴圈獲取字串 「testlock」 的分布式鎖直至成功。

以下以 java 為例 java 客戶端為 tlmq-j ：https://github.com/donnie4w/tlmq-j

maven 配置

<dependency>
<groupId>io.github.donnie4w</groupId>
<artifactId>tlmq-j</artifactId>
<version>0.0.2</version>
</dependency>


呼叫 lock 方法

MqClient mc = new SimpleClient("ws://127.0.0.1:5001", "mymq=123");
mc.connect();
//java連線伺服器
String key = null;
try{
key = mc.lock("testlock", 3); //獲取分布式
... //執行業務邏輯程式
}finally {
if (key!=null){
mc.unLock(key); //釋放分布式鎖
}
}


呼叫 trylock 方法

MqClient mc = new SimpleClient("ws://127.0.0.1:5001", "mymq=123");
mc.connect();
String key = null;
try{
key = mc.tryLock("testlock", 3); //獲取分布式
... //執行業務邏輯程式
} finally {
if (key!=null){
mc.unLock(key); //釋放分布式鎖
}
}


以下是 tldb 分布式鎖的功能測試數據： 多執行緒並行 呼叫 lock 獲取同一個物件鎖後，程式的執行數據：

多執行緒並行使用自旋的方式呼叫 trylock 與 lock 獲取同一個物件鎖：

👉 歡迎 ，你將獲得: 專屬的計畫實戰 / Java 學習路線 / 一對一提問 / 學習打卡 / 贈書福利

新計畫: 仿小紅書 (微服務架構)正在更新中... , 全棧前後端分離部落格計畫 2.0 版本完結啦， 演示連結 ： http://116.62.199.48/ 。全程手摸手，後端 + 前端全棧開發，從 0 到 1 講解每個功能點開發步驟，1v1 答疑，直到計畫上線。 目前已更新了255小節，累計39w+字，講解圖：1716張，還在持續爆肝中.. 後續還會上新更多計畫，目標是將Java領域典型的計畫都整一波，如秒殺系統, 線上商城, IM即時通訊，Spring Cloud Alibaba 等等，

1. 

2. 

3. 

4. 

最近面試BAT，整理一份面試資料【Java面試BATJ通關手冊】，覆蓋了Java核心技術、JVM、Java並行、SSM、微服務、資料庫、數據結構等等。

獲取方式：點「在看」，關註公眾號並回復 Java 領取，更多內容陸續奉上。

PS：因公眾號平台更改了推播規則，如果不想錯過內容，記得讀完點一下「在看」，加個「星標」，這樣每次新文章推播才會第一時間出現在你的訂閱列表裏。

點「在看」支持小哈呀，謝謝啦