如何为动态大小的ZooKeeper集群初始化策展人框架？

Question

我刚刚在独立模式下使用Apache Curator和ZooKeeper实现了一个分布式锁。我草签了策展人框架如下：

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有一个生成器，允许您指定EnsembleProvider而不是connectionString，并包括EnsembleTracker。这将使您的连接字符串保持最新，但您需要以某种方式保留数据，以确保应用程序在重新启动时能够找到集成。我建议实现一个装饰EnsembleProvider，它封装了一个FixedAssembleProvider，并将配置写入属性文件。

例子：

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