Zookeeper KeeperErrorCode = ConnectionLoss
服务启动时发现报如下错误：org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
error是在调用zk.exists（）时抛出的。
于是开始google，发现问题是原因是：new zookeeper之后，zookeeper的还没有连接好，就去调用，当然会抛错。
继续查找资料，比较优雅的解决方案为如下：
waitUntilConnected(zooKeeper)；
public static void waitUntilConnected(ZooKeeper zooKeeper) {
CountDownLatch connectedLatch = new CountDownLatch(1);
Watcher watcher = new ConnectedWatcher(connectedLatch);
zooKeeper.register(watcher);
if (States.CONNECTING == zooKeeper.getState()) {
try {
connectedLatch.await();
} catch (InterruptedException e) {
throw new IllegalStateException(e);
}
}
}
static class ConnectedWatcher implements Watcher {
private CountDownLatch connectedLatch;
ConnectedWatcher(CountDownLatch connectedLatch) {
this.connectedLatch = connectedLatch;
}
@Override
public void process(WatchedEvent event) {
if (event.getState() == KeeperState.SyncConnected) {
connectedLatch.countDown();
}
}
}
页:
[1]