我刚刚在独立模式下使用 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 就会失去与整个集群的连接(我刚刚尝试过)。
最佳答案
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();
关于java - 如何为具有动态大小的 ZooKeeper 集群初始化 CuratorFramework?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56005634/