#使⽤bin/zkCli.sh 连接到zk集群
[zk: localhost:2181(CONNECTED) 2] get /zookeeper
cZxid = 0x0
ctime = Wed Dec 31 19:00:00 EST 1969
mZxid = 0x0
mtime = Wed Dec 31 19:00:00 EST 1969
pZxid = 0x0
cversion = -1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 0
numChildren = 1

 cZxid 就是 Create ZXID，表示节点被创建时的事务ID。
 ctime 就是 Create Time，表示节点创建时间。
 mZxid 就是 Modified ZXID，表示节点最后⼀次被修改时的事务ID。
 mtime 就是 Modified Time，表示节点最后⼀次被修改的时间。
 pZxid 表示该节点的⼦节点列表最后⼀次被修改时的事务 ID。只有⼦节点列表变更才会更新 pZxid，
⼦节点内容变更不会更新。
 cversion 表示⼦节点的版本号。
 dataVersion 表示内容版本号。
 aclVersion 标识acl版本
 ephemeralOwner 表示创建该临时节点时的会话 sessionID，如果是持久性节点那么值为 0
 dataLength 表示数据⻓度。
 numChildren 表示直系⼦节点数。

　  创建顺序节点：create -s /zk-test 123
　　创建临时节点：create -e /zk-temp 123
　　创建永久节点：create /zk-permanent 123
　　读取节点：ls path   其中，path表示的是指定数据节点的节点路径
　　获取内容：get path
　　更新节点：set path data
　　删除节点： delete path

<dependency>
 <groupId>org.apache.zookeeper</groupId>
 <artifactId>zookeeper</artifactId>
 <version>3.4.14</version>
</dependency> 
<dependency>
 <groupId>com.101tec</groupId>
 <artifactId>zkclient</artifactId>
 <version>0.2</version>
 </dependency>

package com.hust.grid.leesf.zkclient.examples;
import java.io.IOException;
import org.I0Itec.zkclient.ZkClient;
public class CreateSession {
/*
 创建⼀个zkClient实例来进⾏连接
 */
 public static void main(String[] args) {
 　　ZkClient zkClient = new ZkClient("127.0.0.1:2181");
　　 System.out.println("ZooKeeper session created.");
 }
}

package com.hust.grid.leesf.zkclient.examples;
import org.I0Itec.zkclient.ZkClient;
public class Create_Node_Sample {
 public static void main(String[] args) {
 ZkClient zkClient = new ZkClient("127.0.0.1:2181");
 System.out.println("ZooKeeper session established.");
 //createParents的值设置为true，可以递归创建节点
 zkClient.createPersistent("/lg-zkClient/lg-c1",true);
 System.out.println("success create znode.");
 }
}

package com.hust.grid.leesf.zkclient.examples;
import org.I0Itec.zkclient.ZkClient;
public class Del_Data_Sample {
 public static void main(String[] args) throws Exception {
 String path = "/lg-zkClient/lg-c1";
 ZkClient zkClient = new ZkClient("127.0.0.1:2181", 5000);
 zkClient.deleteRecursive(path);
 System.out.println("success delete znode.");
 }
}

import org.I0Itec.zkclient.IZkChildListener;
import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.client.ZooKeeperSaslClient;
import java.util.List;
/*
演示zkClient如何使⽤监听器
*/
public class Get_Child_Change {
 public static void main(String[] args) throws InterruptedException {
 //获取到zkClient
 final ZkClient zkClient = new ZkClient("linux121:2181");
 //zkClient对指定⽬录进⾏监听(不存在⽬录:/lg-client)，指定收到通知之后的逻辑
 //对/lag-client注册了监听器，监听器是⼀直监听
 zkClient.subscribeChildChanges("/lg-client", new IZkChildListener() {
 //该⽅法是接收到通知之后的执⾏逻辑定义
 public void handleChildChange(String path, List<String> childs)
throws Exception {
 //打印节点信息
 System.out.println(path + " childs changes ,current childs " +
childs);
 }
 });
 //使⽤zkClient创建节点，删除节点，验证监听器是否运⾏
 zkClient.createPersistent("/lg-client");
 Thread.sleep(1000); //只是为了⽅便观察结果数据
 zkClient.createPersistent("/lg-client/c1");
 Thread.sleep(1000);
 zkClient.delete("/lg-client/c1");
 Thread.sleep(1000);
 zkClient.delete("/lg-client");
 Thread.sleep(Integer.MAX_VALUE);
 /*
 1 监听器可以对不存在的⽬录进⾏监听
 2 监听⽬录下⼦节点发⽣改变，可以接收到通知，携带数据有⼦节点列表
 3 监听⽬录创建和删除本身也会被监听到
 */
 }
}

/lg-zkClient 's child changed, currentChilds:[]
/lg-zkClient 's child changed, currentChilds:[c1]
/lg-zkClient 's child changed, currentChilds:[]
/lg-zkClient 's child changed, currentChilds:null

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;
//使⽤监听器监听节点数据的变化
public class Get_Data_Change {
 public static void main(String[] args) throws InterruptedException {
 // 获取zkClient对象
 final ZkClient zkClient = new ZkClient("linux121:2181");
 //设置⾃定义的序列化类型,否则会报错！！
 zkClient.setZkSerializer(new ZkStrSerializer());
 //判断节点是否存在，不存在创建节点并赋值
 final boolean exists = zkClient.exists("/lg-client1");
 if (!exists) {
 zkClient.createEphemeral("/lg-client1", "123");
 }
 //注册监听器，节点数据改变的类型，接收通知后的处理逻辑定义
 zkClient.subscribeDataChanges("/lg-client1", new IZkDataListener() {
 public void handleDataChange(String path, Object data) throws
Exception {
 //定义接收通知之后的处理逻辑
 System.out.println(path + " data is changed ,new data " +
data);
 }
 //数据删除--》节点删除
 public void handleDataDeleted(String path) throws Exception {
 System.out.println(path + " is deleted!!");
 }
 });
 //更新节点的数据，删除节点，验证监听器是否正常运⾏
 final Object o = zkClient.readData("/lg-client1");
 System.out.println(o);
 zkClient.writeData("/lg-client1", "new data");
 Thread.sleep(1000);
 //删除节点
 zkClient.delete("/lg-client1");
 Thread.sleep(Integer.MAX_VALUE);
 }
}

import org.I0Itec.zkclient.exception.ZkMarshallingError;
import org.I0Itec.zkclient.serialize.ZkSerializer;
public class ZkStrSerializer implements ZkSerializer {
 //序列化，数据--》byte[]
 public byte[] serialize(Object o) throws ZkMarshallingError {
　　return String.valueOf(o).getBytes();
 }
 //反序列化，byte[]--->数据
 public Object deserialize(byte[] bytes) throws ZkMarshallingError {
 return new String(bytes);
 }
}