文章目錄

• 需求
• Leader Election
• Case
• Code
• 源碼分析

---

需求

---

Leader Election

https://curator.apache.org/getting-started.html

Demo示例

---

Case

官方demo

https://github.com/apache/curator/tree/master/curator-examples/src/main/java/leader

---

Code

我們自己也寫個demo 吧

<dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>5.0.0</version><exclusions><exclusion><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.8</version></dependency> import org.apache.curator.RetryPolicy; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.framework.recipes.leader.LeaderSelector; import org.apache.curator.framework.recipes.leader.LeaderSelectorListener; import org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter; import org.apache.curator.retry.ExponentialBackoffRetry;import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit;public class LeaderSelectorTest {private static final String CONNECT_STR="192.168.126.135:2181";private static RetryPolicy retryPolicy=new ExponentialBackoffRetry( 5*1000, 10 );private static CuratorFramework curatorFramework;private static CountDownLatch countDownLatch = new CountDownLatch(1);public static void main(String[] args) throws InterruptedException {String appName = System.getProperty("appName");CuratorFramework curatorFramework = CuratorFrameworkFactory.newClient(CONNECT_STR, retryPolicy);LeaderSelectorTest.curatorFramework = curatorFramework;curatorFramework.start();LeaderSelectorListener listener = new LeaderSelectorListenerAdapter(){// 選舉 leader后的回調(diào)@Overridepublic void takeLeadership(CuratorFramework client) throws Exception{// this callback will get called when you are the leader// do whatever leader work you need to and only exit// this method when you want to relinquish leadershipSystem.out.println(" LEADER . 【"+appName +"】, Pre Warm Cache ");// 模擬業(yè)務(wù)耗時操作TimeUnit.SECONDS.sleep(5);}};LeaderSelector selector = new LeaderSelector(curatorFramework, "/cache_warmer_leader", listener);selector.autoRequeue(); // not required, but this is behavior that you will probably expectselector.start();countDownLatch.await();} }

zk中的數(shù)據(jù)

---

源碼分析

我們來看下 curator是怎么實現(xiàn)的？

《新程序員》：云原生和全面數(shù)字化實踐50位技術(shù)專家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的Apache ZooKeeper - Leader Election使用场景的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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