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

?

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。