分散式鎖-Redission-Lock鎖的使用與原理
阿新 • • 發佈：2020-05-15
# 環境準備
新增 Maven 依賴
```xml
org.redisson
redisson
3.12.0
```
新增配置類
```java
@Configuration
public class MyRedissonConfig {
@Bean(destroyMethod = "shutdown")
RedissonClient redisson() throws IOException {
Config config = new Config();
config.useSingleServer().setAddress("redis://192.168.56.10:6379");
return Redisson.create(config);
}
}
```
基本使用程式碼如下：
```java
@GetMapping("/hello")
@ResponseBody
public String hello() {
//獲取Lock鎖，設定鎖的名稱
RLock lock = redisson.getLock("my-lock");
//開啟
lock.lock();
try {
System.out.println("上鎖：" + Thread.currentThread().getId());
//模擬業務處理20秒
TimeUnit.SECONDS.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
System.out.println("解鎖：" + Thread.currentThread().getId());
//釋放
lock.unlock();
}
return "hello";
}
```
# 分析
當我們傳送 `/hello` 請求後等待 20 秒得到響應結果，會在 Redis 中儲存鎖的資訊（如下圖所示），期間，其它使用者傳送 `/hello` 請求時會被阻塞，只有前一個請求結束後釋放鎖，當前請求才會進入。
**思考1：如果在業務處理過程中程式突然終止，鎖沒有得到釋放，是否會一直阻塞下去？**
經過實驗，在業務處理的20秒中，將服務手動停止，重新整理 Redis 中 my-lock 的資訊，發現 TTL 不斷的減小，直到失效，傳送其它請求能夠正常執行，這說明，即使不釋放鎖，Redis 設定的過期時間到了也會自動刪除鎖的資訊。
```java
//獲取當前執行緒id
long threadId = Thread.currentThread().getId();
//獲取此執行緒的鎖
Long ttl = tryAcquire(leaseTime, unit, threadId);
//如果獲取不到，則說明鎖已經釋放了，直接返回
if (ttl == null) {
return;
}
while (true) {
ttl = tryAcquire(leaseTime, unit, threadId);
//判斷是否能獲取到鎖
if (ttl == null) {
break;
}
...
}
```
**思考2：過期時間是多少？如果我們的業務處理時間超過了過期時間，豈不是還沒處理完就把鎖的資訊給刪了？**
正常啟動服務訪問 `/hello`，重新整理 my-lock 的資訊，我們發現，TTL 每次減少到 20 就再次變為 30，直到業務處理完成，my-lock 被刪除。查詢相關原始碼如下：
```java
while (true) {
//嘗試獲取鎖
ttl = tryAcquire(leaseTime, unit, threadId);
//如果獲取不到，說明執行該執行緒執行結束，就終止迴圈
if (ttl == null) {
break;
}
//如果獲取到了就繼續迴圈
if (ttl > renewExpirationAsync(long threadId) {
return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
"if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +
"redis.call('pexpire', KEYS[1], ARGV[1]); " +
"return 1; " +
"end; " +
"return 0;",
Collections.