189 8069 5689
本篇内容介绍了“zk中选举Leader时的网络IO QuorumCnxManager是什么意思”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！
创新互联公司主要从事网页设计、PC网站建设（电脑版网站建设）、wap网站建设（手机版网站建设）、响应式网站、程序开发、网站优化、微网站、小程序制作等，凭借多年来在互联网的打拼，我们在互联网网站建设行业积累了丰富的成都网站设计、网站制作、网站设计、网络营销经验，集策划、开发、设计、营销、管理等多方位专业化运作于一体。
每台服务启动过程中，会启动一个QuorumCnxManager，负责各台服务器之间底层Leader选举过程中的网络通信
当集群中有服务器服务中断时，zk会重新选举leader
内部类
Message定义消息结构 包含了sid和内容ByteBuffer
ByteBuffer buffer;long sid;
InitialMessage
QuorumConnectionReqThread 发送连接请求类
QuorumConnectionReceiverThread
Listener 端口上的监听
SendWorker发送线程，从发送队列取出消息，发送给对应sid机器
一旦发现针对当前服务sid的消息队列为空，那么要从最近发送的消息中取出一条再次发送
为了保证服务端服务正常，zk能够保证重复消息进行正确处理
RecvWorker 接收消息的线程 不断从网络io中读取数据放入接收队列
类UML图
属性
RECV_CAPACITY | 线程队列最大容量 |
SEND_CAPACITY | 发送容量 |
PACKETMAXSIZE | 包最大1024*512 |
observerCounter | 观察者个数 |
QuorumPeer | 集群数 |
mySid | ip地址 |
connectionExecutor | 连接线程池服务执行者 |
authServer | 已验证server |
authLearner | 学习者 |
connectionThreadCnt | 处理连接的个数 |
recvQueue | 接收队列 |
方法
初始化连接
public void initiateConnection(final Socket sock, final Long sid) {
try {
startConnection(sock, sid);
} catch (IOException e) {
LOG.error("Exception while connecting, id: {}, addr: {}, closing learner connection", new Object[]{sid, sock.getRemoteSocketAddress()}, e);
closeSocket(sock);
return;
}
}
接收连接
public void receiveConnection(final Socket sock) {
DataInputStream din = null;
try {
din = new DataInputStream(new BufferedInputStream(sock.getInputStream()));
handleConnection(sock, din);
} catch (IOException e) {
LOG.error("Exception handling connection, addr: {}, closing server connection", sock.getRemoteSocketAddress());
closeSocket(sock);
}
}“zk中选举Leader时的网络IO QuorumCnxManager是什么意思”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！