ZooKeeper之java客户端访问-入门介绍(二)

2014-11-24 00:44:48 · 作者: · 浏览: 1
n */ public static void main(String[] args) throws IOException, InterruptedException, KeeperException { BaseZookeeper baseZookeeper = new BaseZookeeper(); String host = "192.168.183.128:2181"; // 连接zookeeper baseZookeeper.connectZookeeper(host); System.out.println("--------connect zookeeper ok-----------"); // 创建节点 byte [] data = {1, 2, 3, 4, 5}; String result = baseZookeeper.createNode("/test", data); System.out.println(result); System.out.println("--------create node ok-----------"); // 获取某路径下所有节点 List children = baseZookeeper.getChildren("/"); for (String child : children) { System.out.println(child); } System.out.println("--------get children ok-----------"); // 获取节点数据 byte [] nodeData = baseZookeeper.getData("/test"); System.out.println(Arrays.toString(nodeData)); System.out.println("--------get node data ok-----------"); // 更新节点数据 data = "test data".getBytes(); baseZookeeper.setData("/test", data, 0); System.out.println("--------set node data ok-----------"); nodeData = baseZookeeper.getData("/test"); System.out.println(Arrays.toString(nodeData)); System.out.println("--------get node new data ok-----------"); baseZookeeper.closeConnect(); System.out.println("--------close zookeeper ok-----------"); } }


从命令行中看操作后的结果,如下:

1:根目录下节点

\

2:查看test节点信息



OK,测试结果到此结束。