apache-zookeeper - Apache Curator LeaderSelector:如何通过不退出takeLeadership()方法来避免放弃领导？

我正在尝试实现一个简单的基于领导者选举的系统，其中应用程序的主要业务逻辑在当选的领导者节点上运行。作为获得领导力的一部分，主要业务逻辑将启动各种其他服务。我正在使用Apache Curator LeaderSelector配方来实现领导者选择过程。

在我的系统中，被选择为领导者的节点将保持领导地位，直到故障迫使另一个领导者被选中为止。换句话说，一旦我获得领导权，我就不想放弃它。

根据Curator LeaderSelection文档，当takeLeadership()方法返回时，领导将被放弃。我想避免这种情况，现在我只是通过引入一个等待循环来阻止返回。

我的问题是:

这是实施领导的正确方法吗？

等待循环(如下面的代码示例所示)是正确的阻止方式吗？

public class MainBusinessLogic extends LeaderSelectorListenerAdapter {
  private static final String ZK_PATH_LEADER_ROOT = "/some-path";
  private final CuratorFramework client;
  private final LeaderSelector leaderSelector;

  public MainBusinessLogic() {
    client = CuratorService.getInstance().getCuratorFramework();
    leaderSelector = new LeaderSelector(client, ZK_PATH_LEADER_ROOT, this);
    leaderSelector.autoRequeue();
    leaderSelector.start();
  }

  @Override
  public void takeLeadership(CuratorFramework client) throws IOException {
    // Start various other internal services...
    ServiceA serviceA = new ServiceA(...);
    ServiceB serviceB = new ServiceB(...);
    ...
    ...
    serviceA.start();
    serviceB.start();
    ...
    ...

    // We are done but need to keep leadership to this instance, else all the business
    // logic and services will start on another node.
    // Is this the right way to prevent relinquishing leadership???
    while (true) {
      synchronized (this) {
        try {
          wait();
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    }
  }
}

最佳答案

LeaderLatch代替wait()，您可以执行以下操作:

Thread.currentThread().join();

但是，是的，这是正确的。

顺便说一句-如果您喜欢其他方法，则可以将LeaderLatch与LeaderLatchListener一起使用。