本篇部落格介紹一下Zookeeper原生客戶端API提供的獲取子節點列表方法。

獲取子節點列表方法

方法

Zookeeper原生客戶端API提供了以下8中獲取子節點列表的方法，每個方法的使用說明參考註釋內容：

/**
 * 返回指定路徑下面的子節點列表。
 * 如果watcher不為null，並且呼叫成功（沒有異常），會將watcher註冊在指定的path
 * 上。當path（父節點）被刪除或者path下面建立/刪除子節點，將觸發通知watcher。
 * 
 * 返回結果列表不保證有序性。
 */
public List<String> getChildren(final
 
 String path, Watcher watcher)

/**
 * 使用說明同上一個方法。
 */
public List<String> getChildren(String path, boolean watch)

/**
 * getChildren(String, Watcher)的非同步版本
 */
public void getChildren(final String path, Watcher watcher,
            ChildrenCallback cb, Object ctx)

/**
 * getChildren(String, boolean)的非同步版本
 */
 

public void getChildren(String path, boolean watch, ChildrenCallback cb,
            Object ctx)

/**
 * 為指定的路徑返回stat和子節點列表。
 * 
 */
public List<String> getChildren(final String path, Watcher watcher,
            Stat stat)

/**
 * 使用說明同上一個方法。
 */
public List<String> getChildren(String path, boolean
 
 watch, Stat stat)

/**
 * getChildren(String, Watcher, Stat)的非同步版本
 */
public void getChildren(final String path, Watcher watcher,
            Children2Callback cb, Object ctx)

/**
 * getChildren(String, boolean, Stat)的非同步版本
 */
public void getChildren(String path, boolean watch, Children2Callback cb,
            Object ctx)

引數說明

具體案例

package com.secbro.learn;

import org.apache.zookeeper.*;

import java.util.List;
import java.util.concurrent.CountDownLatch;

/**
 * 獲得子節點列表的方法
 * Created by zhuzs on 2017/3/26.
 */
public class TestGetChildrenMethod implements Watcher {

    private static CountDownLatch countDownLatch = new CountDownLatch(1);

    private static ZooKeeper zooKeeper;
    public static void main(String[] args) throws Exception {
        zooKeeper = new ZooKeeper("127.0.0.1:2181", 5000, new TestGetChildrenMethod());
        countDownLatch.await();

        // 建立父節點/test
        zooKeeper.create("/test", "123".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        // 在父節點/test下面建立a1節點
        zooKeeper.create("/test/a1", "456".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

        // 同步獲得結果
        List<String> childrenList = zooKeeper.getChildren("/test", true);
        System.out.println("同步getChildren獲得資料結果：" + childrenList);

        // 非同步獲得結果
        zooKeeper.getChildren("/test",true,new MyChildren2Callback(),null);

        // 在父節點/test下面建立a2節點
        zooKeeper.create("/test/a2", "456".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

        Thread.sleep(10000);

    }

    public void process(WatchedEvent event) {
        if (Event.KeeperState.SyncConnected == event.getState()) {
            if(Event.EventType.None == event.getType() && null == event.getPath()){ // 連線時的監聽事件
                countDownLatch.countDown();
            } else if (event.getType() == Event.EventType.NodeChildrenChanged){ // 子節點變更時的監聽
                try {
                    System.out.println("重新獲得Children，並註冊監聽：" + zooKeeper.getChildren(event.getPath(),true));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
class MyChildren2Callback implements AsyncCallback.Children2Callback{

    public void processResult(int rc, String path, Object ctx, List<String> children, Stat stat) {
        System.out.println("非同步獲得getChildren結果，rc=" + rc
                + "；path=" + path + "；ctx=" + ctx + "；children=" + children +"；stat=" + stat);
    }
}

輸出結果：

同步getChildren獲得資料結果：[a1]
非同步獲得getChildren結果，rc=0；path=/test；ctx=null；children=[a1]；stat=14277,14277,1490498559704,1490498559704,0,1,0,0,3,1,14278

重新獲得Children，並註冊監聽：[a1, a2]

上面的例子，先建立了一個父節點test，然後在其下面建立了a1子節點，並註冊監聽。當父節點test下面建立了新的a2子節點之後，監聽事件觸發。但此時需要重新主動獲取該父節點下面的子節點，並繼續註冊監聽事件。

上面只提供了新增子節點的案例，其實刪除子節點或刪除父節點同樣會觸發監聽事件。