當前位置：首頁 > 科技 > 軟件

Redisson雜談，你學到了什么？

來源：責編：時間：2023-10-16 17:09:00 213觀看

導讀一.Redisson 簡介Redisson 是一個基于 Netty 通信框架的高性能 Redis 客戶端，實現了分布式和可擴展的 Java 數據結構，提供很多分布式相關操作服務以及大量便利的工具方法，讓開發者可以把精力放在開發業務，避免重復造輪子

一.Redisson 簡介

Redisson 是一個基于 Netty 通信框架的高性能 Redis 客戶端，實現了分布式和可擴展的 Java 數據結構，提供很多分布式相關操作服務以及大量便利的工具方法，讓開發者可以把精力放在開發業務，避免重復造輪子。

二.Redisson 優點

1.通信框架基于 Netty，使用多路復用。吞吐量高。

2.兼容支持 Redis 集群模式，Reids 哨兵模式等，天然適配分布式服務。

3.提供多種分布式對象的封裝，如：Bloom Filter，Object Bucket，Bitset，AtomicLong，和 HyperLogLog 等。

4.提供分布式鎖實現包括：

RedissonFairLock 公平鎖，

RedissonLock 非公平鎖，

RedissonRedLock 紅鎖（基于紅鎖算法，當集群中大多數（ N/2 + 1 ）加鎖成功了，則認為加鎖成功，

目前已被棄用，Redisson 官方不再建議使用）。

三.RedissonLock 分布式鎖相關部分源碼解析

RedissonLock 作為分布式鎖，實現了可重入鎖。阻塞鎖，非阻塞鎖。并且 Redisson 存在看門狗機制，可以對未手動設置超時時間的鎖實現自動續期。

1.Trylock 加鎖

加鎖代碼邏輯

/**** @param waitTime 獲取鎖的最大等待時間，默認 -1，* @param leaseTime 鎖的過期時間，默認 -1* @param unit* @param threadId* @return*/private RFuture<Boolean> tryAcquireOnceAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId) {  RFuture<Boolean> acquiredFuture;  if (leaseTime > 0) {    //若手動設置了鎖的過期時間，則加鎖時以當前傳入過期時間為準    //執行Lua腳本，加鎖    acquiredFuture = tryLockInnerAsync(waitTime, leaseTime, unit,     threadId,RedisCommands.EVAL_NULL_BOOLEAN);                                                   } else {    //若未手動設置，則默認過期時間等于配置的lockWatchdogTimeout，lockWatchdogTimeout默認為30s。    //然后執行Lua腳本，加鎖    acquiredFuture = tryLockInnerAsync(waitTime, internalLockLeaseTime,    TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_NULL_BOOLEAN);  }  CompletionStage<Boolean> f = acquiredFuture.thenApply(acquired -> {  //lock acquired  //若鎖成功獲取到  if (acquired) {    if (leaseTime > 0) {      internalLockLeaseTime = unit.toMillis(leaseTime);      } else {      //若未手動設置過期時間，則執行看門狗任務，自動續期      scheduleExpirationRenewal(threadId);    }  }  return acquired;  });  return new CompletableFutureWrapper<>(f);}

加鎖 Lua 腳本如下：

if (redis.call('exists', KEYS[1]) == 0) then " +  "redis.call('hincrby', KEYS[1], ARGV[2], 1); " +  "redis.call('pexpire', KEYS[1], ARGV[1]); " +  "return nil; " +  "end; " +  "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +  "redis.call('hincrby', KEYS[1], ARGV[2], 1); " +  "redis.call('pexpire', KEYS[1], ARGV[1]); " +  "return nil; " +  "end; " +  "return redis.call('pttl', KEYS[1]);

其中 KEYS[1] 是鎖邏輯名稱，ARGV[1] 是 key 的過期時間，ARGV[2]是鎖的線程級別名稱（ uuid + 線程id ，uuid 是每個 Redisson 客戶端創建時唯一生成的）。

由此可看出，鎖利用 Hash 結構實現，其中 Hash 的 key 是鎖的邏輯名稱，field 是鎖的線程級別名稱，value 是鎖的重入次數。

加鎖 Lua 腳本的含義：

先判斷當前邏輯鎖名稱的 key 是否存在，

若不存在，在 Hash 結構中設置這個鎖，鎖重入次數加 1，然后給 key 設置一個過期時間，最后返回 null。

若存在，并且已經被當前線程持有，就鎖可重入次數加 1，并且重新設置 key 的過期時間,最后返回 null，

若當前鎖被其他線程持有，返回 key 剩余過期時間。

2.Lock 阻塞鎖

Lock 阻塞鎖與 Trylock 底層調用代碼基本一致。多了一個等待鎖被其他線程釋放后，重新嘗試加鎖的過程。

代碼如下：

private void lock(long leaseTime, TimeUnit unit, boolean interruptibly) throws InterruptedException {  long threadId = Thread.currentThread().getId();  Long ttl = tryAcquire(-1, leaseTime, unit, threadId);  // lock acquired  if (ttl == null) {    return;  }  //訂閱釋放鎖消息  CompletableFuture<RedissonLockEntry> future = subscribe(threadId);  pubSub.timeout(future);  RedissonLockEntry entry;  if (interruptibly) {    entry = commandExecutor.getInterrupted(future);  } else {    entry = commandExecutor.get(future);  }  try {    while (true) {      //重新嘗試取鎖      ttl = tryAcquire(-1, leaseTime, unit, threadId);      // lock acquired      if (ttl == null) {        break;      }      // waiting for message，      if (ttl >= 0) {        try {          //當鎖仍然被其他線程占有時，調用          //java.util.concurrent.Semaphore#tryAcquire方法進行信號量阻塞，          //當線程阻塞等待時間超過最大超時時間（ttl即鎖的key的剩余存活時間）          //或者 監聽到鎖釋放消息后，信號量被釋放后，線程不再阻塞          entry.getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);        } catch (InterruptedException e) {          if (interruptibly) {            throw e;          }          entry.getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);        }      } else {        if (interruptibly) {          //嘗試從信號量獲取一個許可          entry.getLatch().acquire();        } else {          entry.getLatch().acquireUninterruptibly();        }      }    }  } finally {  //取消訂閱鎖釋放消息  unsubscribe(entry, threadId);}

大致流程如下：

1.先獲取鎖，若獲取鎖成功，直接返回。

2.若獲取失敗，訂閱釋放鎖消息。

3.進入 while 循環，重新嘗試獲取鎖。若獲取鎖成功，則跳出循環，并不再訂閱釋放鎖消息。

4.若重新獲取鎖失敗，進行信號量阻塞，直到鎖被其他占有線程釋放（監聽鎖釋放消息的監聽器中，有喚醒信號量的邏輯）或者到達阻塞超時時間，然后繼續這個 while 循環。

3.Unlock 解鎖

代碼如下

public RFuture<Void> unlockAsync(long threadId) {  //執行解鎖lua腳本  RFuture<Boolean> future = unlockInnerAsync(threadId);  CompletionStage<Void> f = future.handle((opStatus, e) -> {    //取消看門狗任務    cancelExpirationRenewal(threadId);    if (e != null) {      throw new CompletionException(e);    }    if (opStatus == null) {      IllegalMonitorStateException cause = new IllegalMonitorStateException      ("attempt to unlock lock, not locked by current thread by node id: "      + id + " thread-id: " + threadId);      throw new CompletionException(cause);    }    return null;  });  return new CompletableFutureWrapper<>(f);}

1.其中解鎖 Lua 腳本如下：

if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then " +  "return nil;" +  "end; " +  "local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); " +  "if (counter > 0) then " +  "redis.call('pexpire', KEYS[1], ARGV[2]); " +  "return 0; " +  "else " +  "redis.call('del', KEYS[1]); " +  "redis.call('publish', KEYS[2], ARGV[1]); " +  "return 1; " +  "end; " +  "return nil;

其中 KEYS[1] 為鎖的邏輯名稱，KEYS[2] 為通道名稱，ARGV[1] 為 0， ARGV[2] 為鎖的過期時間，默認 30s，ARGV[3] 為鎖的線程級別名稱。

解鎖 Lua 腳本含義：

解鎖時，先判斷當前鎖是否被當前線程持有，

若不是，則返回 null。

若是，鎖的可重入次數減1。

然后繼續判斷鎖的可重入次數是否大于 0，若大于 0，繼續給這個鎖 key 續期 30s，并且最后返回 0。

若不大于 0，刪除這個鎖的 key，并向指定通道發布這個解鎖消息，并且返回 1。

2.如果這個鎖有看門狗任務在定時續期，當解鎖成功時會取消這個定時續期任務。

4.看門狗機制

當某個鎖內的任務的執行時間不可預估時，可能執行時間很長，也可能很短。此時若直接設置一個固定的鎖過期時間，可能會導致任務執行時間遠遠大于鎖的過期時間，導致任務還未執行完成，但是鎖已經過期了。那其他線程又可以獲取到鎖，然后執行該任務了，最終導致線程安全問題。

為應對這種情況，定期給鎖續期的看門狗機制出現了。

代碼：

//真正看門狗續期任務private void renewExpiration() {  ExpirationEntry ee = EXPIRATION_RENEWAL_MAP.get(getEntryName());  if (ee == null) {    return;  }  //創建一個延時任務，底層實現是netty時間輪。當每過了lockWatchdogTimeout/3的時間，執行該任務  Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {    @Override    public void run(Timeout timeout) throws Exception {      ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName());        if (ent == null) {          return;        }        Long threadId = ent.getFirstThreadId();        //若當前鎖已經被當前線程釋放，則鎖不再續期        if (threadId == null) {          return;        }        //調用Lua腳本，判斷當前鎖是否被當前線程占有，若是則返回true,        //并且重新設置key的過期時間，默認30s        CompletionStage<Boolean> future = renewExpirationAsync(threadId);        future.whenComplete((res, e) -> {          if (e != null) {            log.error("Can't update lock " + getRawName() + " expiration", e);            EXPIRATION_RENEWAL_MAP.remove(getEntryName());            return;            }            //當鎖仍然被當前線程占有，說明業務代碼還在執行，則遞歸調用續期任務            if (res) {              // reschedule itself              log.info("續期任務執行"+ "threadId：" +threadId);              renewExpiration();            } else {              //否則移除該續期任務，直接在EXPIRATION_RENEWAL_MAP移除ExpirationEntry              cancelExpirationRenewal(null);            }        });    }  }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS);    ee.setTimeout(task);}

當沒有顯式指定鎖過期時間時候，就默認 key 過期時間 30s，然后定時任務每 10 秒（ lockWatchdogTimeout/3 ）進行一次調用，執行鎖續期動作,若這個線程還持有這個鎖，就對這個線程持有的鎖進行續期操作（通過 pexpire 續期 key 30s），若途中持有鎖的線程手動被 unlock 或者機器宕機才會取消這個任務。否則會一直續期。

四.總結

Redisson 作為一個 Redis 客戶端，基于 Redis、Lua 和 Netty 建立起了一套完善的分布式解決方案，比如分布式鎖的實現，分布式對象的操作等。本文主要簡單講述了在 Redisson 中分布式鎖的實現。其實在 Redisson 中還有很多值得深挖的點。比如：Redisson 中使用了大量 Netty 的特性。大家有興趣的話，可以仔細研究一下。

五.參考文章

https://github.com/redisson/redisson/wiki

https://cloud.tencent.com/developer/article/1500854

本文鏈接：http://www.tebozhan.com/showinfo-26-13605-0.htmlRedisson雜談，你學到了什么？

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇：為什么 HTTP/3 正在吞噬世界

下一篇：超好用的Java常用工具類StringUtils(帶代碼實例)，提升開發效率

標簽：

熱門焦點

天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

這幾年除了手機作為智能生活終端最主要的核心之外，第二個可以成為中心點的產品是什么？——是智能音箱。手機在執行命令的時候有兩種操作方式，手和智能語音助手，而智能音箱只
分布式系統中的CAP理論，面試必問，你理解了嘛？

對于剛剛接觸分布式系統的小伙伴們來說，一提起分布式系統，就感覺高大上，深不可測。而且看了很多書和視頻還是一臉懵逼。這篇文章主要使用大白話的方式，帶你理解一下分布式系統
量化指標是與非：挽救被量化指標扼殺的技術團隊

作者 | 劉新翠整理 | 徐杰承本文整理自快狗打車技術總監劉新翠在WOT2023大會上的主題分享，更多精彩內容及現場PPT，請關注51CTO技術棧公眾號，發消息【WOT2023PPT】即可直接領取
如何通過Python線程池實現異步編程？

線程池的概念和基本原理線程池是一種并發處理機制，它可以在程序啟動時創建一組線程，并將它們置于等待任務的狀態。當任務到達時，線程池中的某個線程會被喚醒并執行任務，執行完任
年輕人的“職場羞恥感”，無處不在

作者：馮曉亭陶淘李欣張琳馬舒葉來源：燃次元“人在職場，應該選擇什么樣的著裝？”近日，在網絡上，一個與著裝相關的帖子引發關注，在該帖子里，一位在高級寫字樓亞洲金
四年持續更迭堅持探索行業無人之境，HarmonyOS 4帶來五大升級多項創新

除了華為每年新發布的旗艦手機系列，上億花粉更加期待鴻蒙系統每次的跨版本大更新。8月4日，HarmonyOS 4于HDC 2023正式發布，這也是該系統歷經四年的再
華為和江淮汽車合作開發百萬元問界MPV？雙方回應來了

8月1日消息，郭明錤今天在社交平臺發文稱，華為正在和江淮汽車合作，開發售價在100萬元的問界MPV，預計在2024年第2季度量產，銷量目標為上市首年交付5萬輛。
華為將推出盤古數字人大模型可幫助用戶12小時完成數字人生成

在今日舉行的2023年華為云數字文娛AI創新峰會上，華為云全球Marketing與銷售服務總裁石冀琳表示，華為云將在后續推出盤古數字人大模型，可幫助用戶12小
微軟發布Windows 11新版引入全新任務欄狀態

近日，微軟發布了Windows 11新版，而Build 22563更新主要引入了幾周前曝光的平板模式任務欄等，系統更流暢了。更新中，Windows 11加入了專門針對平板優化的任務欄

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

Redisson雜談，你學到了什么？

一.Redisson 簡介

二.Redisson 優點

三.RedissonLock 分布式鎖相關部分源碼解析

1.Trylock 加鎖

2.Lock 阻塞鎖

3.Unlock 解鎖

4.看門狗機制

四.總結

五.參考文章

天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

分布式系統中的CAP理論，面試必問，你理解了嘛？

量化指標是與非：挽救被量化指標扼殺的技術團隊

如何通過Python線程池實現異步編程？

年輕人的“職場羞恥感”，無處不在

四年持續更迭堅持探索行業無人之境，HarmonyOS 4帶來五大升級多項創新

華為和江淮汽車合作開發百萬元問界MPV？雙方回應來了

華為將推出盤古數字人大模型可幫助用戶12小時完成數字人生成

微軟發布Windows 11新版引入全新任務欄狀態

最新推薦

猜你喜歡

熱門推薦

相關資訊