outgoingQueue
工作线程
消息加入等待队列
pendingQueue
服务端
均衡负载接口，用于对zookeeper集群进行均衡负载
<interface>HostProvider
发送消息
<interface>ClientWatchManager
+ materialize(): return Set<Watcher>
ClientCnxnSocketNetty
+ attribute1:type = defaultValue+ attribute2:type- attribute3:type
+ operation1(params):returnType- operation2(params)- operation3()
SendThread
- clientCnxnSocket:type = ClientCnxnSocket+ attribute2:type- attribute3:type
- run(): return void- startConnect(InetSocketAddress addr):return void- primeConnection()- operation3()
将消息转化为事件
ZKWatchManager
sendThread
Zookeeper
- watchManager:ZKWatchManager- hostProvider:HostProvider- cnxn:ClientCnxn
消息检验
回应消息
ZooKeeperThread
EventThread
- waitingEvents:LinkedBlockingQueue<Object>
ClientCnxn
- sendThread :SendThread- eventThread: EventThread- outgoingQueue:LinkedBlockingDeque<Packet>- pendingQueue:Queue<Packet>
ClientCnxnSocket
waitingEvents
ClientCnxnSocketNIO
从等待队列获取消息进行检验
zookeeper
获取事件
获取消息
eventThread
返回服务端结果
