策展人-如何知道当前节点是否为领导者

Question

只是想知道是否有任何API可以知道在Curator框架中使用CuratorFramework类的特定节点是领导者。我正在使用LeaderLatch，但即使节点是leader（由Zookeeper框架选择），也无法工作。

注意：在集群设置中配置了3个节点。

Zookeeper框架将负责选择节点。我需要知道选定的策展人客户是否指向领导者。

String zkConnString = "172.18.54.211:2181";

RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
CuratorFramework client1 = CuratorFrameworkFactory.newClient(zkConnString, retryPolicy);
client1.start();

 LeaderLatch leaderLatch = new LeaderLatch(client1, "/FirstNode");
 try {
    leaderLatch.start();

} catch (Exception e1) {
    e1.printStackTrace();
}

System.out.println("has leader ship ? "+leaderLatch.hasLeadership());

输出是

has leader ship ? false

如果领导相应的微服务失败，则需要选择其他领导。每个微服务都可以被视为一个Z节点。如果Z节点被删除，将触发并监听NODEREMOVED事件。

LEADER不应该是微服务关闭节点。

Answer 1

我认为您需要通过以下代码向LeadLatch添加侦听器：

    leaderLatch.addListener(new LeaderLatchListener {
      override def isLeader(): Unit = {
        println(s"I am the lead $i")
      }

      override def notLeader(): Unit = {
        println(s"i am not the leader any more $i")
      }
    })

Answer 2

根据文件记载，领导人选举是不同步的。这意味着，在你开始领导人选举后，领导人信息不一定立即可用。

你应该先等待领导人选举完成。

不幸的是，我无法找到使用org/apache/curator/框架/食谱/领导者包中的类获取选举完成信息的干净方法：该应用编程接口仅提供检查领导层变更的方法。

我能找到的最接近的查询是（使用Java8）：

new LeaderSelector(clientFramework, path, new NoOpLeaderSelectorListener())
    .getParticipants().stream()
    .filter(Participant::isLeader)
    .map(Participant::getId)
    .findAny()
    .ifPresent(<... do something with leader node Id ...>);

但我仍然不清楚这是否会比最初的变体更确定地产生正确的结果。

它将做的是：

1. 使用进程间通信从框架中查询当前节点
2. 使用配置的Sorter对节点进行排序
3. 将排序后的第一个节点标记为该查询的领导节点

还有一个类似的查询：

new LeaderSelector(clientFramework, path, new NoOpLeaderSelectorListener())
  .getLeader()

第一个查询和第二个查询的区别在于，如果没有节点，则返回dummy participant is object，而第一个查询相对透明地返回Optional。empty（）如果没有节点。

Answer 3

我认为当第三个实例开始时，LeaderLatch（第一，第二）的状态已经改变。

leaderLatch.hasLeadership()

应在足够多的实例（第3个）启动后执行。

或者注册一个回调方法。

实现接口LeaderLatchListener并重写isLeader（）或notLeader（）是个好主意。