ZooKeeper的request和response对象

在我们了解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(); //返回节点数据
    }