04.ZooKeeper读书笔记之开源客户端（ZkClient）

jsnjzlw

　　本节，我们介绍的是ZkClient和Curator两个开源的zookeeper客户端产品。
　　好，首先我们创建一个maven工程，将jar引进来，下面是maven的依赖：
　　

<dependencies>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
</dependencies>
　　
　　


　　



1、创建会话　　
　　（1）zkServers 指的是zk的服务器列表，由英文状态逗号分开的host：port字符串组成，每一个都代表一台zk机器，例如192,168,11,160:2181,192,168,11,161:2181...
　　（2）sessionTimeout 会话超时时间，单位为毫秒，默认为30000ms
　　（3）connectionTimeout 连接创建的超市时间，单位为毫秒，此参数表明如果在这个时间段内还是无法和zk建立连接，那么就放弃连接直接抛出异常
　　（4）connection IZKConnection 接口的实现类
　　（5）zkSerializer 自定义的序列化器
　　


　　在使用zk的api创建连接的时候我们知道，创建连接的过程是一个异步过程，我们需要自己通过线程阻塞来监听链接是否创建成功，而在zkclient里，将异步方式转为了同步方式。这样会更加方便。
　　


　　IZKconnection接口。这个接口是对zk原生接口最直接的包装，也是和zk最直接的交互层，里面包含了增，删，改，查等接口。zkClient有两种实现方式分别是ZkConnection和InMemoryConnection ，而ZkConnection是常用的。
　　


　　ZkSerializer接口。这个接口是用来完成data数据序列化用的，默认情况下zkc使用java自带的序列化方式对对象进行序列化。
　　


　　在zkclient的构造方法里我们没有找到对watcher的传入，那如何实现监听呢，zkclient使用listener来实现watcher注册。下面的代码就可以完成一个zkclient的创建：
　　

public static void main(String[] args) {
ZkClient zk = new ZkClient(&quot;192.168.11.160:2181&quot;, 5000);
System.out.println(zk.getChildren(&quot;/root&quot;));
}


　　
　　2、创建节点
　　


　　


　　


　　（1）path 节点路径 （2）data 数据 （3）mode 节点类型 （4）cal 权限策略 （5）callback 异步回调函数 （6）context 上下文对象 （7）createParents 指定是否创建父节点
　　在这些参数里，和zk自带的api都差不多，其中data因为有了自定义的序列化工具，所以可以传入更为复杂的对象，而新增的createParents参数的作用是可以帮助我们自动的创建父节点，省去了我们要手动的判断其父节点是否存在的麻烦。例如：
　　

public static void main(String[] args) {
ZkClient zk = new ZkClient(&quot;192.168.11.160:2181&quot;, 5000);
zk.createPersistent(&quot;/root/apps/test/test&quot;, true);
}效果如下：


　　
　　


　　


　　3、删除节点
　　刚才我们创建了一个永久的节点，下面我们来使用delete方法删除这个节点
　　


　　


　　

ZkClient zk = new ZkClient(&quot;192.168.11.160:2181&quot;, 5000);
zk.delete(&quot;/root/apps/test&quot;);

但还有一个方法：deleteRecursive 这个方法可以帮助我们逐层遍历删除节点的工作。　　
　　


　　4、获取节点，注册监听



　　


　　这个方法没有注册watcher，所以我们现在先讲一个如何注册listener。下面这个listener接口可以完成节点的监听。
　　


　　

问题是我们如何将这个监听器注册呢，我们可以使用subscribeChildChanges方法完成注册，下面我们来看一下demo：

public class MyZkChildListener implements IZkChildListener{
/**
* parentPath 子节点变更通知对应的父节点的节点路径
* currentChilds 子节点的相对路径列表 如果没有子节点 则为null
*/
public void handleChildChange(String parentPath, List<String> currentChilds)
throws Exception {
System.out.println(&quot;parentPath:&quot;+parentPath+&quot;,currentChilds:&quot;+currentChilds);
}
}
　　
　　问题是我们如何将这个监听器注册呢，我们可以使用subscribeChildChanges方法完成注册，下面我们来看一下demo：问题是我们如何将这个监听器注册呢，我们可以使用subscribeChildChanges方法完成注册，下面我们来看一下demo：
　　

public class ZkClientTest {
static String servers = &quot;192.168.11.160:2181,192.168.11.161:2181&quot;;
static String rootPath = &quot;/root/apps&quot;;
public static void main(String[] args) {
ZkClient zkClient = new ZkClient(servers, 5000);
zkClient.subscribeChildChanges(rootPath,new MyZkChildListener());
try {
zkClient.createPersistent(rootPath + &quot;/test1&quot;);
Thread.sleep(1000);
zkClient.createPersistent(rootPath + &quot;/test2&quot;);
Thread.sleep(1000);
zkClient.delete(rootPath + &quot;/test1&quot;);
Thread.sleep(1000);
zkClient.delete(rootPath + &quot;/test2&quot;);
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
}
}
　　
　　



经过测试，得出以下结论：　　（1）客户端可以对一个不存在的节点进行子节点变更的监听
　　（2）一旦客户端对一个节点注册了子节点列表变更监听之后，那么该节点的字节列表发生变化的时候，服务端都会通知客户端，并将最新的子节点列表发送给客户端。
　　（3）该节点本身的创建或删除会通知到客户端。
　　（4）listener只需要注册一次会一直生效。
　　


　　


　　5、获取与更新数据



　　


　　（1）returnNullIfPathNotExists  默认情况下 在调用这个方法的时候 如果指定的节点不存在会抛出异常，如果设置了这个参数 如果节点不存在就返回null 而不会抛出异常
　　（2）stat 指定数据节点的节点状态信息 用户是在接口中传入一个旧的stat变量 该stat变量会在方法执行过程中被来自服务器响应的新的stat对象替换。
　　来看一下DEMO案例
　　

public class ZkClientTest {
static String servers = &quot;192.168.11.160:2181,192.168.11.161:2181/root/apps&quot;;
static String rootPath = &quot;/root/apps&quot;;
public static void main(String[] args) {
ZkClient zkClient = new ZkClient(servers, 5000);
zkClient.subscribeDataChanges(&quot;/name1&quot;,new IZkDataListener() {
/**
* 数据被删除时触发
*/
public void handleDataDeleted(String dataPath) throws Exception {
System.out.println(&quot;节点数据被删除：&quot;+dataPath);
}
/**
* 数据被修改时触发
*/
public void handleDataChange(String dataPath, Object data) throws Exception {
System.out.println(&quot;节点数据被修改：&quot;+dataPath+&quot;,获取数据：&quot;+data);
}
});
try {
User user = new User();
user.setCode(200);
user.setName(&quot;吕鹏&quot;);
zkClient.create(&quot;/name1&quot;, user, CreateMode.EPHEMERAL);
User data = zkClient.readData(&quot;/name1&quot;);
Thread.sleep(1000);
User user2 = new User();
user2.setCode(200);
user2.setName(&quot;熊哥&quot;);
zkClient.writeData(&quot;/name1&quot;,user2);
Thread.sleep(1000);
zkClient.delete(&quot;/name1&quot;);
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
}
}