ZooKeeper的request和response对象

menny

　　在我们了解request和response对象之前我们要先了解一下org.apache.zookeeper.ClientCnxn、org.apache.zookeeper.proto.ReplyHeader。
　　ClientCnxn做了什么
　　从源码的说明上我们可以了解到ClientCnxn用于管理客户端的 socket i/o，并维护可用服务器的列表，提供连接服务。我们所有与Zookeeper Server交互的操作都是由ClientCnxn完成的。

    //org.apache.zookeeper.ZooKeeper
public ZooKeeper(String connectString, int sessionTimeout, Watcher watcher,
long sessionId, byte[] sessionPasswd)
throws IOException
{
LOG.info("Initiating client connection, connectString=" + connectString
+ " sessionTimeout=" + sessionTimeout
+ " watcher=" + watcher
+ " sessionId=" + sessionId
+ " sessionPasswd="
+ (sessionPasswd == null ? "<null>" : "<hidden>"));
watchManager.defaultWatcher = watcher;
cnxn = new ClientCnxn(connectString, sessionTimeout, this, watchManager, sessionId, sessionPasswd);
cnxn.start();
}
　　ReplyHeader是什么
　　从名称上我们可以读懂这个类包含了请求的返回信息。成员变量err可以通过get方法得到，用于记录错误码，0表示操作成功。

        if (r.getErr() != 0) {
if (r.getErr() == KeeperException.Code.NONODE.intValue()) {
return null;
}
throw KeeperException.create(KeeperException.Code.get(r.getErr()),
clientPath);
}
　　ZooKeeper.getData中的request、response
　　org.apache.zookeeper.proto.GetDataRequest类中包含两个成员变量 String path 和 boolean watch。path是请求的节点路径，watch表示对节点是否进行观察。可以通过 GetDataRequest(String path, boolean watch) 构造方法和 get/set 方法进行操作。

  GetDataRequest request = new GetDataRequest();
request.setPath(serverPath);
request.setWatch(watcher != null);
　　org.apache.zookeeper.proto.GetDataResponse类中包含两个成员变量byte[] data和Stat stat。data用于存储请求完成后返回的节点数据，stat用于存储请求完成后返回的节点状态信息。当请求完成后我们可以调用get方法来取得数据。

  GetDataResponse response = new GetDataResponse();
...
if (stat != null) {
DataTree.copyStat(response.getStat(), stat);
}
return response.getData();
　　当我们具有了request和response后就可以通过ClientCnxn的submitRequest方法得到节点数据了。

    public byte[] getData(final String path, Watcher watcher, Stat stat)
throws KeeperException, InterruptedException
{
final String clientPath = path;
PathUtils.validatePath(clientPath);
// the watch contains the un-chroot path
WatchRegistration wcb = null;
if (watcher != null) {
wcb = new DataWatchRegistration(watcher, clientPath); //封装观察对象
}
final String serverPath = prependChroot(clientPath); //得到节点的服务器全路径
RequestHeader h = new RequestHeader(); //定义请求头对象
h.setType(ZooDefs.OpCode.getData); //设置本次请求类型为得到值的操作
GetDataRequest request = new GetDataRequest(); //实例化request对象和属性定义
request.setPath(serverPath);
request.setWatch(watcher != null);
GetDataResponse response = new GetDataResponse(); //实例化respinse对象
ReplyHeader r = cnxn.submitRequest(h, request, response, wcb); //进行请求并得到回复信息
if (r.getErr() != 0) {
throw KeeperException.create(KeeperException.Code.get(r.getErr()),
clientPath);
}
if (stat != null) {
DataTree.copyStat(response.getStat(), stat); //将成功后返回的节点状态信息转写到用户指定的Stat对象中
}
return response.getData(); //返回节点数据
}