首页 > 代码库 > Zookeeper连接后验证节点是否存在
Zookeeper连接后验证节点是否存在
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();
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。