如何利用动物园管理员实现高可用性服务(2个节点)

Question

我需要提供一个H/A机制。

我知道动物园管理员可以被选为领袖选举。

我在为这个流程寻找合适的模式：

我需要实现一个调用流的服务。当它启动流时，流是一个循环流，它必须验证它是领导者。(根据它的ip地址)。

我理解，我可以将一个值放入一个动物园管理员中，它定义了输入实例，并在1循环结束时或在一段时间内将其释放。

这是正确的模式吗？

而且，如果我使用如下这样的东西，似乎会出现种族状况问题：

...
...
List<String> names = zk.getChildren( path, false );
String id = null;
// See whether we have already run for election in this process
for ( String name : names ) {
{
   if ( name.startsWith( myIP ) ) {
      id = name;
      break;
   }
}
if ( id == null ) {
id = zk.create( path + "/" + myIP, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
}
boolean isLeader = id != null;

例如：

两个服务读取null，第二个以上重写第一个签名，它们都运行任务。

你能帮忙吗？

谢谢

Answer 1

正确使用ZooKeeper可能很困难，需要对其API和语义进行一些研究。有一些不错的高级库，比如Curator，它们已经实现了一些常见的算法，比如领导人选举。ZooKeeper文档也有一个领导人选举的配方。