簡介

在分布式計算中，主節點選舉是為了把某個進程作為主節點來控制其它節點的過程。在選舉結束之前，我們不知道哪個節點會成為主節點。curator對于主節點選舉有兩種實現方式，本文示例演示Latch的實現示例。

官方文檔：http://curator.apache.org/curator-recipes/leader-latch.html

javaDoc：http://curator.apache.org/apidocs/org/apache/curator/framework/recipes/leader/LeaderLatch.html

代碼示例

zookeeper的選舉是通過爭搶最小節點來實現的，這里添加了爭搶結果的監聽，如果當前節點編程主節點則觸發isLeader，如果當前節點從主節點變成非主節點則觸發notLeader

import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.framework.recipes.leader.LeaderLatch; import org.apache.curator.framework.recipes.leader.LeaderLatchListener; import org.apache.curator.retry.ExponentialBackoffRetry;public class LatchDemo {private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 3));private static String path = "/master";private static String id = "0001";public static void main(String[] args) throws Exception {// curator客戶端啟動 client.start();// 創建選舉實例LeaderLatch latch = new LeaderLatch(client, path, id);// 添加選舉監聽latch.addListener(new LeaderLatchListener() {@Overridepublic void isLeader() {// 如果成為master則觸發System.out.println("is leader");}@Overridepublic void notLeader() {// 如果從主節點變成非主節點則觸發System.out.println("not leader");}});// 加入選舉 latch.start();// curator客戶端關閉 client.close();} }

主節點選舉出了Curator客戶端需要star以外，latch也需要start，當然latch也會配對著一個close。start意味著參加選舉，close意味著退出選舉。

?

轉載于:https://www.cnblogs.com/lay2017/p/10264300.html

總結

以上是生活随笔為你收集整理的五、curator recipes之选举主节点Leader Latch的全部內容，希望文章能夠幫你解決所遇到的問題。

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