zk报错:java.lang.IllegalStateException: Expected state [STARTED] was [LATENT]

原因:

客户端使用时没有start而直接调用了其他方法

解决办法:

public CuratorFramework getCuratorFramework() throws InterruptedException {
   RetryPolicy retryPolicy = new ExponentialBackoffRetry(Integer.parseInt(zkProp.getSleepTimeMs()),
       Integer.parseInt(zkProp.getMaxRetries()));
   CuratorFramework client = CuratorFrameworkFactory.newClient(zkProp.getAddress(), retryPolicy);
   // start()开始连接,没有此会报错
   client.start();
   // 阻塞直到连接成功
   client.blockUntilConnected();
   return client;
}
Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐