Zookeeper Leader 选举

链接监听

runFromConfig(config)

ackstate == QuorumPeer.ServerState.LOOKING

开始选举

createCnxnManager()

开启线程接受选票

服务启动

一样的逻辑

是

new ZKDatabase(quorumPeer.getTxnFactory())

客户端

self.getPeerState() == QuorumPeer.ServerState.LOOKING

ManagedUtil.registerLog4jMBeans()

wsThread.start()

过半逻辑

服务端启动

sid self.getId()

不处理，通常是 BUG 

死循环状态判断switch (getPeerState())

启动线程

sendqueue.offer(notmsg);

n == null

发送选票

connectOne(sid);

初始化和启动

zoo.cfg 解析

quorumPeer.run()

createElectionAlgorithm（）创建选举对象

设置数据库

(ackstate == QuorumPeer.ServerState.LOOKING) && (n.electionEpoch logicalclock.get())选票方处于选举中，并且id 小于自己把结果发给选票方

创建选举通信管理器

JVM 监控

处理链接信息

totalOrderPredicate(..)投票 PK

初始化 quorumPeer

初始化 sendqueue， recvqueue，messenger

ZooKeeperServerMain.main(args);

走 LEADING

放入应用层接受队列

启动日志定时删除

startLeaderElection()

getVoteTracker（..）

是否过半

LOOKING

createNewServerSocket();

recvqueue.offer(n);

send(b);

SendWorker.run

选举完成

轮询

manager.connectAll()与其他节点建立连接

否

else

RecvWorker.run

LEADING

启动 Netty 服务

purgeMgr.start()

recvQueue.offer(msg)

放入投票箱

config.parse(args[0])

注册 log4j JMX mbeans

启动服务 2181 端口

循环

startJvmPauseMonitor()

广播投票

CnxnChannelHandler#channelRead处理客户端请求

quorumPeer.start()

loadDataBase()

单机模式

sendNotifications()

while 循环读取

new QuorumPeerMain()

logicalclock.incrementAndGet()

收集选票

集群模式

创建服务

启动监听器

receiveConnection(client)

线程启动

args.length == 1 && config.isDistributed()

super.start();

main.initializeAndRun(args)

create /a/b

fle.start();

创建 NIO 服务， 默认 NIO ，推荐 Netty

接受选票

ServerCnxnFactory.createFactory()

是否集群模式

return endVote

启动 mesager.start()

启动选举线程

makeLEStrategy().lookForLeader()投票给自己

选举过程

 sendNotifications();

startServerCnxnFactory()

递增本地选举周期

start 方法最后调用 super.start() 启动线程

listener.start();

state 状态

quorumPeer = getQuorumPeer()

判断处理状态

sid == self.getId()

cnxnFactory.start()

选举中

FOLLOWING

closeSocket(sock);id 小的不能直接链接 id 大的机器