// From StandardLockInternalsDriver public PredicateResults getsTheLock(CuratorFramework client, List<String> children, String sequenceNodeName, int maxLeases) throws Exception{ // 之前創建的臨時順序節點在排序后的子節點列表中的索引 int ourIndex = children.indexOf(sequenceNodeName); // 校驗之前創建的臨時順序節點是否有效 validateOurIndex(sequenceNodeName, ourIndex); // 鎖公平性的核心邏輯 // 由InterProcessMutex的構造函數可知，maxLeases為1，即只有ourIndex為0時，線程才能持有鎖，或者說該線程創建的臨時順序節點激活了鎖 // Zookeeper的臨時順序節點特性能保證跨多個JVM的線程并發創建節點時的順序性，越早創建臨時順序節點成功的線程會更早地激活鎖或獲得鎖 boolean getsTheLock = ourIndex < maxLeases; // 如果已經獲得了鎖，則無需監聽任何節點，否則需要監聽上一順序節點（ourIndex-1） // 因為鎖是公平的，因此無需監聽除了（ourIndex-1）以外的所有節點，這是為了減少羊群效應，非常巧妙的設計！！ String pathToWatch = getsTheLock ? null : children.get(ourIndex - maxLeases); // 返回獲取鎖的結果，交由上層繼續處理（添加監聽等操作） return new PredicateResults(pathToWatch, getsTheLock); } static void validateOurIndex(String sequenceNodeName, int ourIndex) throws KeeperException{ if ( ourIndex < 0 ){ // 容錯處理，可跳過 // 由于會話過期或連接丟失等原因，該線程創建的臨時順序節點被Zookeeper服務端刪除，往外拋出NoNodeException // 如果在重試策略允許范圍內，則進行重新嘗試獲取鎖，這會重新重新生成臨時順序節點 // 佩服Curator的作者將邊界條件考慮得如此周到！ throw new KeeperException.NoNodeException("Sequential path not found: " + sequenceNodeName); } }

?

總結

以上是生活随笔為你收集整理的Curator实现分布式锁的基本原理-getTheLock的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。