只允许myid大的连接小的，避免重复连接
isReadable
run方法，追加事务日志
QuornmPeer.start（）
放
增删改查
start
创建一个管理器Manager--qcm
取
获取vote
启动recvWorker
反序列化
将选票包装成Notification放到queue中
SyncRequestProcessor
zk 思维导图单机启动流程 ： https://www.processon.com/view/link/630529371efad40752c48716?pw=Jackclient建立连接，创建node流程： https://www.processon.com/view/link/63052994f346fb0714ba0433?pw=Jack查询数据，添加监听和回调： https://www.processon.com/view/link/630891fc1efad40752cbfbd3?pw=Jack集群源码：https://www.processon.com/view/link/6308b3d5e0b34d072661cccb?pw=Jackdata数据同步：https://www.processon.com/view/link/630f282ff346fb0714cc42f1?pw=Jackzab协议：https://www.processon.com/view/link/631398b0e401fd5080c4328a?pw=Jack
sendThread.start()
case： notification
eventQueue
1.移除watch2.给客户端发送个notification
FinalRequestProcessor
isWriteable
创建recvWorker
包装Request
for循环向所有节点发送选票
队列
FastLeaderElection#start()
优先选择zxid大的。zxid一样选择myid大的。
new Zookeeper()
链式调用
执行方法
发送选票到sendQueue中
使用选举算法进行选举
发送选票
结果返回true
offer
SendWorker#run()
myid和传过来的sid比较
case Looking
读操作：从dataTree上面读node如果getNode()包含watch，server端还会维护节点和watch关系。
起个线程
sid和myid不一样，说明要通过网络发送
读配置
放-写操作
创建netty连接工厂
准备leader选举startLeaderElection（）
集群启动
客户端启动
acceptConnections()
取出来执行
while(running)
RequestProcessor
PrepRequestProcessor
将vote信息封装成Notification
WorkerSender开启线程发送vote
实例化QuoraPeer
设置选举类型type为3设置myid
socket发送过去
sendQueue
eventThread.start()
runFromConfig
quornmPeer.start()
监听端口数据，直到有数据进来，否则一直accept阻塞在这里
唤醒通知处理
processEvent，从事先维护好的列表中取出回调，调用回调方法。服务端不需要知道你是具体回调的过程
workerReceiver开启线程接收vote
recvQueue<Notification>
netty监听2181
如果当前机器状态为looking
单机zkServer启动
start()
super.start()线程启动
启动server监听程序：netty/jetty
服务端发送watch通知
font color=\"#323232\
满足条件myid<sid
处理数据
获取选举端口端口
更新下次要推荐的leader和zxid
如果sid==myid，给自己投一票
nio建立服务端和客户端连接
解析配置
recvQueue
不断从queue中获取数据，通过网络发送出去
SendThread.run()
loadDataBase()
qcm创建监听器listerner
receiveConnection()
创建sendWorker
取event
从recvQueue中获取选票
packet
case 3
启动jetty，查看运维信息8080
自己投给自己
listerner.start()
初始化五个节点，并加载已经含有的节点到dataTree上面
写操作：写到内存DataTree上，后触发回调watch
服务端返回操作结果
epoch每次新一轮选举+1
