java - 如何为具有动态大小的 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

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();