我正在使用 LeaderLatch 进行领导者选举。在本地安装 ZooKeeper 后,当只有一个实例时,我有大约 30 秒的时间来选举领导者,而当领导者出现故障时(当我终止进程时),几乎同时选举新的领导者。这应该像这样工作吗?我可以加快速度吗?
我使用以下代码:
CuratorFramework curator = CuratorFrameworkFactory.newClient("127.0.0.1", new ExponentialBackoffRetry(100, 3));
curator.start();
LeaderLatch leaderLatch = new LeaderLatch(curator, "/test/t");
leaderLatch.addListener(new LeaderLatchListener() {
@Override
public void isLeader() {
System.out.println("Leader");
}
@Override
public void notLeader() {
}
});
leaderLatch.start();