zk中选举Leader时的网络IOQuorumCnxManager是什么意思

本篇内容介绍了“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图

属性

方法

初始化连接

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是什么意思”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站，小编将为大家输出更多高质量的实用文章！