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

?

總結(jié)

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

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