// From StandardLockInternalsDriver // 在Zookeeper中創建臨時順序節點 public String createsTheLock(CuratorFramework client, String path, byte[] lockNodeBytes) throws Exception{ String ourPath; // lockNodeBytes不為null則作為數據節點內容，否則采用默認內容（IP地址） if ( lockNodeBytes != null ){ // 下面對CuratorFramework的一些細節做解釋，不影響對分布式鎖主邏輯的解釋，可跳過 // creatingParentContainersIfNeeded：用于創建父節點，如果不支持CreateMode.CONTAINER // 那么將采用CreateMode.PERSISTENT // withProtection：臨時子節點會添加GUID前綴 ourPath = client.create().creatingParentContainersIfNeeded() // CreateMode.EPHEMERAL_SEQUENTIAL：臨時順序節點，Zookeeper能保證在節點產生的順序性 // 依據順序來激活分布式鎖，從而也實現了分布式鎖的公平性，后續繼續分析 .withProtection().withMode(CreateMode.EPHEMERAL_SEQUENTIAL).forPath(path, lockNodeBytes); } else { ourPath = client.create().creatingParentContainersIfNeeded().withProtection().withMode(CreateMode.EPHEMERAL_SEQUENTIAL).forPath(path); } return ourPath; }

?

總結

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

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