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

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐