首页  流程图  详情

zookeeper源码解析流程图

2022-04-13 14:48:31   0  举报





zookeeper源码解析流程图，轻松学习zk源码

源码学习

ZooKeeper流程图

作者其他创作

大纲/内容

makeLEStrategy().lookForLeader()

readonlymode.enabled

receiveConnection(client);

NO，当前节点胜

处理连接信息

sid：sendqueue

sid：senderworker

NO使用选举策略选举leader

建立新socket连接

recvqueue.offer(n)

sid= din.readLong()

循环将选票信息发送出去

quorum属性填充

选票信息校验

n.electionEpoch < logicalclock.get() 说明发票的机器刚刚加入集群，这种选票一般会废弃掉

Messenger.start()

sid：recevierworker

this.wrThread.start()

YES

sid等于self.id 警告：配置可能错误

发送消息

sendqueue

判断当前server状态是否是LOOKING状态

ServerCnxnFactory.createFactory()

创建选举的server socket(选举用的是普通的socket通信BIO)

self.getPeerState() == ServerState.LOOKING

选票PK，选举周期落后，认为是中途加入集群不，不能会直接选举自己。需要用接收到的选票和自己PK

解析配置文件，加载到内存中

n.electionEpoch logicalclock.get()

判断

判断选举地址是否为null

n.electionEpoch = logicalclock.get()

process(m)

根据配置文件：zookeeper.serverCnxnFactory中配置创建通讯方式

判断其他节点是否发送选票

sId < self.id

原子操作：增加选举年龄、初始化选票（首次选择自己）

startServerCnxnFactory()

sendqueue.offer(notmsg)

放入recvqueue

执行发送线程

n.electionEpoch == logicalclock.get()

send

wokerReceiver.run()

electionAddr == null

启动核心方法

配置集群节点的通信方式

workerReceier

判断选票状态（发送发状态）

recvqueue

启动初始化zk方法

接收选票放入recvQueue

adminServer.start()

QuorumCnxManager.Listener listener = qcm.listener

notification == null

self.setPeerState((proposedLeader == self.getId()) ? ServerState.LEADING: learningState())

//将当前的节点的选举周期替换为选票的选举周期logicalclock.set(n.electionEpoch)//清空该节点的接收的选票箱记录recvset.clear()

将接收到的选票放入recvQueue中异步处理

quorumPeer.start()

如果发送选票方还没有leader就将本机认为的leader发送给他（中途新加机器的情况）

根据配置文件：zookeeper.serverCnxnFactory中配置创建通讯方式。如果没有配置默认使用NIO方式。PS：ZK官方推荐使用NETTY进行节点之间的通讯。

workerSender.run()

(ackstate == QuorumPeer.ServerState.LOOKING) && (n.electionEpoch < logicalclock.get())

manager.connectAll()

不是looking状态说明现在已经有leader了，不需要再选举

启动监听

sw.finish()

validVoter(n.sid) && validVoter(n.leader)

YES，接收到的选票胜

集群Leader选举流程

开启清除快照文件任务

根据前面的配置知道这里是FLE策略选举

QuorumPeerMain

添加到sendqueue中

执行接收线程

Vote current = self.getCurrentVote()

添加到sendqueue

recvQueue

config.parse(args[0])

this.wsThread.start()

workerSender

启动选举

SendWorker sw = senderWorkerMap.get(sid)

startLeaderElection()

sendNotifications()

从接收队列里面取选票

super.start()

加粗条件表示双方共用，未加粗条件表示左边独用

listener.start()

n == null

socket读取选票信息

NETTY

半数选举leader逻辑

是否只读

循环从recvqueue中获取其他节点的选票

recvWorker.run()

LOOKING

NIOServerCnxnFactory

fastLeaderElection.lookForLeader()

将PK后接收到的选票放入选recvqueue中

queueSendMap.size() == 0

注意：socket连接是双向的，只要连接一次双方server都能够进行通信，为了减少不必要的连接，都尽量只连接一次。zookeeper作者有一个规则：那就是在zk中的socket连击只能是由myId大的zk去连接myId小的zk。因此如果zk发现连接自己的socket的myid比自己小就会删除senderWorkerMap中对应的sw同时删除此次socket连接，会重新通过myid较大的zk去连接myid小的zk。

创建监听器

发送选票

从发送队列里面取选票

connectOne(sid)

sid self.id

获取选票

开始选举

zk sever1

received

zk sever2

purgeMgr.start()

closeSocket(socket)