华大集团 北京网站建设百度网盟推广官方网站

在上一篇文章中讲到QuorumCnxManager，它负责zookeeper服务器在选举期间最底层的网络通信，整个网络涉及到的类如下：

整个网络建立的过程如下：

1. 选举前创建好QuorumCnxManager实例，并在QuorumCnxManager构造函数中创建好Listener实例
2. 调用Listener.start()方法启动监听线程
3. Listener获得CPU资源后执行run()方法，建立ListenerHandler，开始监听来自其他服务器的连接请求
4. 当ListenerHandler监听到来自其他服务器的连接请求，创建当前服务器与目标服务器一对一的SendWorker和RecvWorker，并将SendWorker保存到QuorumCnxManager.senderWorkerMap中
5. 进行选举的时候会向集群中的所有服务器发送自己的选票，通过QuorumCnxManager.toSend()方法向QuorumCnxManager.queueSendMap中存放待发送的信息，等待SendWorker异步发送
6. 在QuorumCnxManager.toSend()中会检测senderWorkerMap中是否存在目标服务器的发送线程SendWorker，如果不存在则调用connectOne()方法创建连接，connectOne()中会创建QuorumConnectionReqThread线程并将其放入connectionExecutor线程池中异步建立连接
7. 当QuorumConnectionReqThread获得CPU资源后执行run()方法，接着调用QuorumCnxManager.initiateConnection()方法进行连接，连接建立成功后创建一对一的SendWorker和RecvWorker，并将SendWorker保存到QuorumCnxManager.senderWorkerMap中
8. RecvWorker接收到来自客户端的投票消息，将消息以Message的格式保存在QuorumCnxManager.recvQueue中
9. 选举期间会循环调用QuorumCnxManager.pollRecvQueue()方法从QuorumCnxManager.recvQueue中获取来自其他服务器的投票并进行处理。

QuorumCnxManager的工作原理大致如此，下文开始逐一具体分析这些类。