码迷,mamicode.com
首页 > 其他好文 > 详细

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

时间:2014-08-22 12:34:16      阅读:546      评论:0      收藏:0      [点我收藏+]

标签:blog   java   os   io   strong   for   问题   div   

  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();

 

Zookeeper连接后验证节点是否存在,布布扣,bubuko.com

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

标签:blog   java   os   io   strong   for   问题   div   

原文地址:http://www.cnblogs.com/onliny/p/3929029.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!