如何使用 Curator TestingServer 启动 zookeeper ensemble答案

【问题标题】：How to start zookeeper ensemble using Curator TestingServer如何使用 Curator TestingServer 启动 zookeeper ensemble
【发布时间】：2021-03-12 12:50:43
【问题描述】：

我只是想用Curator frame work 或zookeeper 的java 实现来启动一个zookeeper ensemble（Leader - follower）。

最初我检查了二进制模式，它在下面显示的示例配置中运行良好。

zoo.cfg

tickTime=2000
dataDir=/var/lib/zookeeper/
clientPort=2181
initLimit=5
syncLimit=2
server.1=zoo1:2888:3888
server.2=zoo2:2888:3888
server.3=zoo3:2888:3888

和 myid 文件相应地创建，并且 zookeeper 合奏按我的预期创建（领导者 - 追随者创建）。

Connections: 4
Outstanding: 0
Zxid: 0x30000052a
Mode: leader
Node count: 158
Proposal sizes last/min/max: 146/36/1471

当我尝试使用带有类的 org.apache.zookeeper.server.quorum.QuorumPeerConfig 配置来实现相同目标时，

org.apache.zookeeper.server.ZooKeeperServerMain

ZooKeeperServerMain zkServer = new ZooKeeperServerMain();
        final ServerConfig configuration = new ServerConfig();
        configuration.readFrom(peerConfig);
        new Thread(() -> {
            try {
                zkServer.runFromConfig(configuration);
                Thread.sleep(2000);
            } catch (Exception e) {
                logger.error("ZooKeeper Failed", e);
            }
        }).start();

org.apache.curator.test.TestingServer

InstanceSpec spec = new InstanceSpec(zkDataDir, clientPort, electionPort, -1, true, serverId, tickTime, maxClientCnxns, customProperties);

zkServer = new TestingServer(spec, true);

两者都以独立模式启动zookeeper，似乎这两个实现都不关心配置server.1=..... server.2=.... server.3=..... 。

我在这里缺少什么？如何在leader follower模式下使用java启动zookeeper？

注意：我是与 zookeeper 相关的东西和文档的新手，仍然让我感到困惑。请指导我。谢谢... :)

【问题讨论】：

标签： java apache-zookeeper distributed-computing apache-curator

【解决方案1】：

Curator TestingServer 可以被视为常规 ZooKeeper 服务器。因此，leader-follower 可以使用它进行测试，例如使用 Curator LeaderLatch。

Leader-follower unit test example

Leader-follower implementation example

注意：我是这个项目的作者。

【讨论】：