首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

zookeeper领导者选举源码分析

QuorumCnxManager主要负责和其他节点数据传输 sendqueue:选票发送队列,用于保存待发送的选票。 recvqueue:选票接收队列,用于保存接收到的外部投票。 WorkerReceiver:选票接收器。其会不断地从QuorumCnxManager中获取其他服务器发来的选举消息,并将其转换成一个选票,然后保存到recvqueue中,在选票接收过程中,如果发现该外部选票的选举轮次小于当前服务器的,那么忽略该外部投票,同时立即发送自己的内部投票。 WorkerSender:选票发送器,不断地从sendqueue中获取待发送的选票,并将其传递到底层QuorumCnxManager中。 recvQueue:当前节点接受信息的列队 senderWorkerMap:每台节点对应的senderworker,<Long, SendWorker>,Long为服务器myid,SendWorker用于从queueSendMap存的Queue取数据发送给其他节点的,是个线程

01
领券