Zookeeper连接后验证节点是否存在

191145692

　　Zookeeper连接后验证节点是否存在
　　初学Zookeeper，在配置完集群之后，为了验证集群对于某台机器挂掉之后的影响，出现了一下问题。
　　集群由3台机器组成，通过“sh bin/zkServer.sh stop”关闭了其中一台（ip1）。
　　然后在以下代码中测试：



        // 创建一个与服务器的连接
ZooKeeper zk = new ZooKeeper("ip1:2189,ip2:2189,ip3:2189", 1000, new Watcher() {
// 监控所有被触发的事件
@Override
public void process(WatchedEvent event) {
System.out.println("已经触发了" + event.getType() + "事件！");
}
});
// 取出子目录节点列表
System.out.println(zk.getChildren("/testRootPath", true));
// 关闭连接
zk.close();

　　经过测试，偶尔会出现以下异常：



Exception in thread "main" org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /testRootPath
at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1468)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1496)

　　而上述代码在集群完全正常时是毫无问题的。
　　Zookeeper连接后，此处的State应当是CONECTING。连接中的时候去验证是否存在节点会报错。解决的方法也很简单，就是等到Zookeeper客户端以及完全连接上服务器，State为CONECTED之后再进行其他操作。
　　修改后代码如下：



        final CountDownLatch connectedSignal = new CountDownLatch(1);
// 创建一个与服务器的连接
ZooKeeper zk = new ZooKeeper("ip1:2189,ip2:2189,ip3:2189", 1000, new Watcher() {
// 监控所有被触发的事件
@Override
public void process(WatchedEvent event) {
System.out.println("已经触发了" + event.getType() + "事件！");
if (event.getState() == KeeperState.SyncConnected) {
connectedSignal.countDown(); // 倒数-1
}
}
});
// 等待连接完成
connectedSignal.await();
// 取出子目录节点列表
System.out.println(zk.getChildren("/testRootPath", true));
// 关闭连接
zk.close();