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

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM