【zookeeper 获取节点数据getData源码解析】

zookeeper 获取节点信息，zk提供了四个构造函数，其中两个是同步请求，另外两个是异步请求。

public byte[] getData(String path, Watcher watcher, Stat stat)
public byte[] getData(String path, boolean watch, Stat stat)
public void getData(String path, Watcher watcher, DataCallback cb, Object ctx)
public void getData(String path, boolean watch, DataCallback cb, Object ctx)

在这四个构造函数当中，重点主要讲解第一个和第三个构造函数。第二个构造函数间接调用了第一个构造函数，通过参数是否监听标识来判断是否使用默认的监听对象；对于第四个构造函数也是如此，间接也调用了第三个构造函数。

   //第二个构造函数public byte[] getData(String path, boolean watch, Stat stat) throws KeeperException, InterruptedException {return this.getData(path, watch ? this.watchManager.defaultWatcher : null, stat);}// 第四个构造函数public void getData(String path, boolean watch, DataCallback cb, Object ctx) {this.getData(path, watch ? this.watchManager.defaultWatcher : null, cb, ctx);}

1 同步请求获取节点数据

 public byte[] getData(String path, Watcher watcher, Stat stat) throws KeeperException, InterruptedException {// 验证节点路径的合法性PathUtils.validatePath(path);// 初始化监听注册对象为空ZooKeeper.WatchRegistration wcb = null;// 判断监听对象是否为空，如果不为空，new一个数据监听注册对象if (watcher != null) {wcb = new ZooKeeper.DataWatchRegistration(watcher, path);}// 拼接zk根节点String serverPath = this.prependChroot(path);// 封装请求头RequestHeader h = new RequestHeader();h.setType(4);GetDataRequest request = new GetDataRequest();request.setPath(serverPath);request.setWatch(watcher != null);GetDataResponse response = new GetDataResponse();// 通过客户端cnxn将该次的请求添加到sendThread线程队列中ReplyHeader r = this.cnxn.submitRequest(h, request, response, wcb);if (r.getErr() != 0) {throw KeeperException.create(Code.get(r.getErr()), path);} else {if (stat != null) {DataTree.copyStat(response.getStat(), stat);}return response.getData();}}

重点在于
this.cnxn.submitRequest(h, request, response, (ZooKeeper.WatchRegistration)null);这个方法的处理逻辑，继续看下submitRequest 做了什么东西。该方法是在ClientCnxn类中，客户端与服务端的交互处理主要在该类中。

 public ReplyHeader submitRequest(RequestHeader h, Record request, Record response, WatchRegistration watchRegistration) throws InterruptedException {       // new 一个响应头，主要是接收从服务器响应回来的信息ReplyHeader r = new ReplyHeader();// 将请求数据组装成一个packet，跟服务端交互最小的单元，并且添加到请求队列里ClientCnxn.Packet packet = this.queuePacket(h, r, request, response, (AsyncCallback)null, (String)null, (String)null, (Object)null, watchRegistration);synchronized(packet) {// 同步请求，等待服务器响应回来while(!packet.finished) {packet.wait();}return r;}}

请求节点数据的源码跟创建节点的源码逻辑是不是很类似，每次请求都会将该请求添加到发送消息队列，由客户端发送线程去发送请求，并响应回来到客户端。只不过在zk获取节点数据时候，我们可以注册一个监听对象，当获取节点对象的内容发生变化时，客户端能够获取到服务器最新的数据。比如说集群里某个客户端的配置信息发生改变时，集群里的其他客户端能够第一时间感知，并获取最新配置信息。
DataWatchRegistration 的父类是WatchRegisistration ，该父类有四个子类，分别对应不同的监听注册类型，根据不同的操作类型将watcher对象注册到不同的注册器里

2 异步请求获取节点数据

 public void getData(String path, Watcher watcher, DataCallback cb, Object ctx) {PathUtils.validatePath(path);ZooKeeper.WatchRegistration wcb = null;if (watcher != null) {wcb = new ZooKeeper.DataWatchRegistration(watcher, path);}String serverPath = this.prependChroot(path);RequestHeader h = new RequestHeader();h.setType(4);GetDataRequest request = new GetDataRequest();request.setPath(serverPath);request.setWatch(watcher != null);GetDataResponse response = new GetDataResponse();this.cnxn.queuePacket(h, new ReplyHeader(), request, response, cb, path, serverPath, ctx, wcb);}

同步和异步请求的区别在于，客户端发送数据后，有没有等待服务器响应回来；对于异步请求而言，关注的是，只要将获取数据的请求添加到客户端发送消息队列里就行，等待服务器响应回来后，会自动调用之前传入的回调接口并执行processResult方法。

即可以比对下异步和同步的代码，可以看到同步请求会多异步请求一个操作，就是一直在等待服务器的响应，判断packet状态是否是成功，如果是成功则返回服务器响应回来的数据。

思考：客户端如何注册监听？请求回来后客户端如何回调监听?服务端怎么样处理监听？