獲取節點內容

獲取節點內容的方法定義

public byte[] getData(String path, boolean watch, Stat stat)

其中:
- path:要獲取內容的節點路徑
- watch:是否設定監控,也就是是否需要回調
- stat:節點狀態
使用示例(異常自行處理)

/**
 * 根據節點路徑獲取節點內容
 *
 * @param path
 * @return 如果返回空,獲取失敗
 */
public String getData(String path) {
    Stat stat = new Stat();
    try {
        byte
 
[] data = zooKeeper.getData(path, false, stat);
        String value = new String(data, "UTF-8");
        return value;
    } catch (KeeperException e) {
        e.printStackTrace();
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }
    return
 
 null;
}

如果想要非同步讀取節點,也就是為讀取節點的內容設定監控點,可以使用如下API

public void getData(String path, boolean watch, DataCallback cb, Object ctx)
public void getData(final String path, Watcher watcher,DataCallback cb, Object ctx)

其中：
- DataCallback cb:非同步回撥函式
- Object ctx:自定義的引數資訊,可以在DataCallback中的processResult方法中使用
對於第一個方法,使用如下:

zooKeeper.getData(path, true, new AsyncCallback.DataCallback() {
    public void processResult(int rc, String path, Object ctx, byte[] data, Stat stat) {
        System.out.println(new String(data));
    }
},null);

由於zookeeper的觸發操作屬於單次操作,當一個監視點被一個事件觸發時,就會產生一個通知資訊,並且只會產生一次.如果想要對該節點一直設定監控,那麼應該使用第二個方法

zooKeeper.getData(path, new Watcher() {
    public void process(WatchedEvent event) {
        System.out.println("*****************************");
        System.out.println(event);
    }
}, new AsyncCallback.DataCallback() {
    public void processResult(int rc, String path, Object ctx, byte[] data, Stat stat) {
        System.out.println("*****************************");
        System.out.println(new String(data));
    }
}, null);

對節點內容重新賦值

所謂重新賦值,也就是對節點內容做修改

方法定義

public Stat setData(final String path, byte data[], int version) throws KeeperException, InterruptedException //同步獲取
public void setData(final String path, byte data[], int version,StatCallback cb, Object ctx) //非同步獲取

其中
- version指的時節點版本號,當version=-1時表示忽略版本號比對
- StatCallback cb:非同步回撥函式
- Object ctx:自定義的引數資訊,可以在StatCallback中的processResult方法中使用

Stat stat = zooKeeper.setData(path, "random1".getBytes(), -1);
if (stat != null) {
    //getData
}

獲取子節點

獲取子節點的包含8個API，使用方法和getData()基本相同

public List<String> getChildren(final String path, Watcher watcher) throws KeeperException, InterruptedException //同步
public List<String> getChildren(String path, boolean watch) throws KeeperException, InterruptedException //同步
public void getChildren(final String path, Watcher watcher,ChildrenCallback cb, Object ctx) //非同步
public void getChildren(final String path, Watcher watcher,ChildrenCallback cb, Object ctx) //非同步
public void getChildren(String path, boolean watch, ChildrenCallback cb,Object ctx) //非同步
public void getChildren(String path, boolean watch, ChildrenCallback cb,Object ctx) //非同步
public List<String> getChildren(final String path, Watcher watcher,Stat stat) //同步
public List<String> getChildren(String path, boolean watch, Stat stat) throws KeeperException, InterruptedException //同步
public void getChildren(final String path, Watcher watcher,Children2Callback cb, Object ctx) //非同步
public void getChildren(String path, boolean watch, Children2Callback cb,Object ctx) //非同步

刪除節點

同樣的 包含一個同步刪除和一個非同步刪除

public void delete(final String path, int version) throws InterruptedException, KeeperException //同步
public void delete(final String path, int version, VoidCallback cb,Object ctx) //非同步

使用示例

zk中原節點列表

[zk: 192.168.1.6:2181,192.168.1.6:2182,192.168.1.6:2183(CONNECTED) 16] ls /
[path1, zookeeper]

執行程式碼

Stat stat = new Stat();
zooKeeper.getData(path,false,stat);
zooKeeper.delete(path,stat.getVersion());

zk中節點列表

[zk: 192.168.1.6:2181,192.168.1.6:2182,192.168.1.6:2183(CONNECTED) 17] ls /
[zookeeper]