在单独的线程中启动 zookeeper

Question

我正在尝试以这种方式将多个嵌入式 Zookeeper 服务器从 Java 应用程序启动到单独的线程中：

String port1 = "2181";
String directory1 = new File(System.getProperty("java.io.tmpdir"), "zookeeper/data1").getAbsolutePath();
final ServerConfig config1 = new ServerConfig();
config1.parse(new String[] { port1, directory1 });
new Thread(new Runnable() {      
  @Override
  public void run()
  {
    try{
      ZooKeeperServerMain zk = new ZooKeeperServerMain()
      zk.runFromConfig(config1);
    }catch(Exception e){
      e.printStackTrace();
    }        
  }
}).run();    

当我这样启动zk时，主进程被阻塞，其余指令不执行！ 有没有在单独的线程中启动 zookeeper 的正确方法？

Answer 1

您在Thread 上调用run() 而不是start()。

new Thread(new Runnable() {      
@Override
public void run()
{
  try{
    ZooKeeperServerMain zk = new ZooKeeperServerMain()
    zk.runFromConfig(config1);
  }catch(Exception e){
    e.printStackTrace();
  }        
}
}).start();