分布式（五）——zk客户端

客户端

• 组件
• 一次会话创建的过程
• 初始化
• 会话创建
• 回应处理
• HostProvider
• ClientCnxn：网络I/O

上图就是客户端初始化，并与zk服务端创建连接的过程。

组件

1. ClientWatchManager
2. Zookeeper
3. ClientCnxn
4. HostProvider

一次会话创建的过程

初始化

• 初始化Zookeeper对象，设置默认的Watcher。
• 初始化HostProvider
• 初始化ClientCnxn，同时他会实例化里面的两个线程（SendThread、EventThread）

会话创建

• 启动SendThread 和EventThread
• sendThread 会从HostProvider中取出zk服务端的地址，并委托给clientCnxnSocket与zk服务端创建tcp长连接。
• clientCnxnSocket 创建tcp连接成功后，sendThread会创建connectRequest请求，同时会将请求封装成Packet对象，放入到OutgoingQueue中。
• clientCnxnSocket 会将OutgoingQueue里面的Packet对象取出进行序列化，再传输给zk服务端

回应处理

• 接收到服务端发来响应，如果客户端还没有初始化完成，则会直接交给readConnectResult方法来处理
• clientCnxnSocket对响应进行反序列化，并获取ConnectResult中的sessionId。
• 连接成功后，后通知sendThread进行客户端会话参数的设置，并更新客户端的状态，并在HostProvider里面设置连接的zk地址是可以连接的。
• 生成事件：syncConnected-None。SendThread生成该事件，并将事件传递给EventThread
• 查询watcher，如果是syncConnected-None 事件，直接获取初始化节点设置的默认Watcher，并将起添加到EventThread的waitingEvents队列中去。
• EventThread不断的从waitingEvents队列中获取Watcher对象，执行他的process方法。

HostProvider

关于客户端从HostProvider中取一个zk服务端的地址，如果有多个，他则会将多个随机排列后，放入一个环中，每次绕着环来获取。

ClientCnxn：网络I/O

Pack类里面的有request 的属性也有 response的属性。
在SendThread中，请求会被封装成Packet对象放在outgoingQueue中，如果outgoingQueue中的请求发送完毕后，会将Packet对象立马添加到PendingQueue中，等待响应。

• 如果是客户端还未进行初始化，则会将incomingBuffer序列化成ConnectResponse对象
• 如果是服务端的通知，则会序列化成WatcherEvent对象，并传递给eventThread
• 如果是客户端的请求，则会从pendingQueue中获取Packet对象。