如何为具有动态大小的ZooKeeper集群初始化CuratorFramework？

Question

我刚刚在独立模式下使用Apache Curator和ZooKeeper实现了一个分布式锁。我按如下方式初始化了CuratorFramework：

CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2182", retryPolicy);

一切都很好，所以我尝试在集群模式下使用ZooKeeper。我启动了三个实例并初始化了CuratorFramework，如下所示：

CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2182,localhost:2182,localhost:2183", retryPolicy);

如您所见，我只是添加了两个新节点的地址。到目前一切尚好。

但是，当我不知道每个节点的地址和集群的大小时，我该如何初始化客户端，因为我想动态地扩展它？

我可以通过只指定总是启动的第一个节点的地址来初始化它。但如果该节点宕机，Curator将失去与整个集群的连接(我刚刚尝试过)。

Answer 1

你应该总是知道你的Zookeeper实例在哪里。当你不知道某样东西在哪里时，你是无法连接到它的--你怎么能这样做呢？

如果您可以连接到任何实例，您可以获取配置详细信息并定期轮询，以使您的连接详细信息保持最新。

也许你可以看看https://zookeeper.apache.org/doc/r3.5.5/zookeeperReconfig.html#ch_reconfig_rebalancing

Answer 2

CuratorFrameworkFactory具有a builder，它允许您指定EnsembleProvider而不是connectionString，并包含EnsembleTracker。这将使您的connectionString保持最新，但是您需要以某种方式持久化数据，以确保您的应用程序在重新启动时能够找到集成。我建议实现一个封装FixedEnsembleProvider并将配置写入属性文件的装饰性EnsembleProvider。

示例：

EnsembleProvider ensemble = new MyDecoratingEnsembleProvider(new FixedEnsembleProvider("localhost:2182", true));
CuratorFramework client = CuratorFrameworkFactory.builder()
    .ensembleProvider(ensemble)
    .retryPolicy(retryPolicy)
    .ensembleTracker(true)
    .build();