是否可以在进程中启动Zookeeper服务器实例，例如用于单元测试？

Question

调用org.apache.zookeeper.server.quorum.QuorumPeerMain.main（）无法正常工作。

Answer 1

要开始，ZooKeeper您必须执行ZooKeeperServerMain课程。

您可以使用以下代码以ZooKeeper嵌入式模式启动。

Properties startupProperties = ...

QuorumPeerConfig quorumConfiguration = new QuorumPeerConfig();
try {
    quorumConfiguration.parseProperties(startupProperties);
} catch(Exception e) {
    throw new RuntimeException(e);
}

zooKeeperServer = new ZooKeeperServerMain();
final ServerConfig configuration = new ServerConfig();
configuration.readFrom(quorumConfiguration);

new Thread() {
    public void run() {
        try {
            zooKeeperServer.runFromConfig(configuration);
        } catch (IOException e) {
            log.error("ZooKeeper Failed", e);
        }
    }
}.start();