ZkServer.java 文件源码

/**
 * 通过官方的QuorumPeerMain启动类启动真集群模式
 * 会执行quorumPeer.join();
 * 需要在不同的服务器上执行
 * @param config
 * @throws IOException
 * @throws AdminServer.AdminServerException
 */
public void startCluster(QuorumPeerConfig config) throws IOException, AdminServer.AdminServerException {
    QuorumPeerMain main = new QuorumPeerMain();
    main.runFromConfig(config);
}