Zookeeper实例ZkClient API-获取节点数据内容

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;

/**
*
* @ClassName: Get_Data_Sample
* @Description: TODO(ZkClient获取节点数据)
* @author
* @date 2017年6月14日 下午1:03:46
*
*/
public class Get_Data_Sample {
public static void main(String[] args) throws Exception {

String path = "/zk-book";
ZkClient zkClient = new ZkClient("localhost:2181", 5000);
zkClient.createEphemeral(path, "123");

zkClient.subscribeDataChanges(path, new IZkDataListener() {
public void handleDataDeleted(String dataPath) throws Exception {
System.out.println("Node " + dataPath + " deleted.");
}
public void handleDataChange(String dataPath, Object data) throws Exception {
System.out.println("Node " + dataPath + " changed, new data: " + data);
}
});

// System.out.println(zkClient.readData(path));
zkClient.writeData(path,"456");
Thread.sleep(1000);
zkClient.delete(path);
Thread.sleep( Integer.MAX_VALUE );
}
}

输出：
Node /zk-book changed, new data: 456
Node /zk-book deleted.

注意：

getData方法有一个 boolean returnNullIfPathNotExists参数，这样如果当指定的节点不存在就不会抛异常而是返回null.通过调用getData()接口，就可以获得指定节点的内容，这里方法的返回值，在ZkClient内部已经被反序列化成了指定对象。

扩展









参考

1.《从Paxos到Zookeeper：分布式一致性原理与实践》

2. http://javadox.com/com.101tec/zkclient/0.4/org/I0Itec/zkclient/ZkClient.html