Curator leader 选举(一)-白红宇

Curator leader 选举(一)

阅读量：4970 次

发布时间：2019-06-12

本文共 4812 字，大约阅读时间需要 16 分钟。

要想使用Leader选举功能，需要添加recipes包，可以在maven中添加如下依赖：

<groupId>org.apache.curator</groupId>

<artifactId>curator-recipes</artifactId>

</dependency>

当然了，由于recipes需要使用framework，所以你肯定还要添加如下依赖：

<groupId>org.apache.curator</groupId>

<artifactId>curator-framework</artifactId>

</dependency>

最后，为了简化测试也为了便于学习，可以添加test依赖：

<groupId>org.apache.curator</groupId>

<artifactId>curator-test</artifactId>

</dependency>

LeaderLatch使用流程

recipes包里面提供了Leader选举实现，Spark中的master选举使用的就是reciples包里面的LeaderLatch，使用他们可以极大的简化代码，使你将注意力更多的放在核心业务逻辑上。Leader选举的实现在org.apache.curator.framework.recipes.leader包中，这个包提供了两组Leader选举：

1.LeaderLatch,LeaderLatchListener

2.LeaderSelector,LeaderSelectorListener,LeaderSelectorListenerAdapter

这两组类都可以实现Leader选举，spark 使用的是第一种。再这篇文章里，只介绍第一种。

第一组使用起来非常简单，使用思路大致如下：假设你有3个节点，姑且叫做node0，node1，node2。你需要为每一个node创建一个CuratorFramework，LeaderLatch，LeaderLatchListener，如下：

node0:

1.CuratorFramework client=CuratorFrameworkFactory.newClient(.....);client.start();

2.new LeaderLatch(client,path)->addListener(LeaderLatchListener )->start()

node1:

1.CuratorFramework client=CuratorFrameworkFactory.newClient(.....);client.start();

2.new LeaderLatch(client,path)->addListener(LeaderLatchListener )->start()

node2:

1.CuratorFramework client=CuratorFrameworkFactory.newClient(.....);client.start();

2.new LeaderLatch(client,path)->addListener(LeaderLatchListener )->start()

你首先要创建CuratorFramework，然后并启动它，一个CuratorFramework就是一个ZooKeeper客户端。然后创建LeaderLatch，并制定刚才创建的CuratorFramework和一个leaderPath，leaderPath是一个ZooKeepe路径，node0，node1，node2中的leaderPath必须一致。创建好LeaderLatch之后，需要为他注册一个LeaderLatchListener回掉，如果某个node成为leader，那么会调用这个node的LeaderLatchListener的isLeader()，因此你可以在这里写自己的业务逻辑。最后，调用LeaderLatch的start()，这个LeaderLatch将参加选举了。

可以参考如下代码：

import java.util.ArrayList;import java.util.List;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;import org.apache.curator.test.TestingServer;import org.apache.curator.utils.CloseableUtils;public class LeaderDemo {    public static void main(String[]args) throws Exception{        List
     
      leaders=new ArrayList
      
       ();        List
       
        clients=new ArrayList
        
         ();                TestingServer server=new TestingServer();                        try{            for(int i=0;i<10;i++){              CuratorFramework client=CuratorFrameworkFactory.newClient(server.getConnectString(),new ExponentialBackoffRetry(20000,3));              clients.add(client);                            LeaderLatch leader=new LeaderLatch(client,"/francis/leader");              leader.addListener(new LeaderLatchListener(){                @Override                public void isLeader() {                    // TODO Auto-generated method stub                    System.out.println("I am Leader");                }                @Override                public void notLeader() {                    // TODO Auto-generated method stub                    System.out.println("I am not Leader");                }});                                          leaders.add(leader);                      client.start();              leader.start();            }                        Thread.sleep(Integer.MAX_VALUE);        }finally{                        for(CuratorFramework client:clients){              CloseableUtils.closeQuietly(client);                }                        for(LeaderLatch leader:leaders){                CloseableUtils.closeQuietly(leader);            }                        CloseableUtils.closeQuietly(server);        }                        Thread.sleep(Integer.MAX_VALUE);    }}