参考
总结
事件顺序:
- leader把proposal发给followers
- leader写日志, 并回复自己ack。followers开始写日志, 并回复leader ack
- leader收到过半ack后,异步向followers发送commit,并将事务应用到DataTree上
- followers收到commit后,将事务应用到DataTree上
LeaderZooKeeperServer启动CommitProcessor线程。后者对committed请求包装成CommitWorkRequest交给线程池执行。
ProposalRequestProcessor
CommitProcessor
收集ACK
往前看
往后看
commit后
这里会判断ACK是否过半,未过半则失败,这里假设判断成功。
- 调用commit方法,异步发commit给所有成员
-
异步让commitProcessor确保日志写入
commitProcessor取出
取出committedRequests异步交给下一个处理器Leader.ToBeAppliedRequestProcessor -> FinalRequestProcessor