zookeeper客户端发送数据源码

ZooKeeper? 入口类 客户度初始化链接??

重点 start() 方法?

ClientCnxn 类中

对应的run 实现

startConnect（）方法

clientCnxnSocket.connect(addr)方法

建立连接之后 接受数据

doio（）方法

EventThread??eventThread

watch.process()

ZooKeeper? 向服务端写数据

?create()

cnxn.submitRequest() 发送数据

数据放入阻塞队列? ?

sendThread?doio（）方法里 从outgongQueue队列里轮询发送的数据包 异步处理