12.zookeeper原理解析-服务器端处理流程之处理器链

这部分内容我们主要讲解zookeeper请求在zookeeper server端的处理流程，对于不同角色的zookeeper具有不同的处理流程， ZookeepeerServer的start方法中会调用setupRequestProcessors()来初始化处理器链，它被子类覆写实现。
![](https://321cc.cn/usr/uploads/2023/04/628273991.png)

1.      LeaderZooKeeperServer
![](https://321cc.cn/usr/uploads/2023/04/1366775830.png)

看如上代码主要建立了如下的两个处理器流链

(1)    PrepRequestProcessor(线程) => ProposalRequestProcessor(调initialize) =>CommitProcessor(线程) => Leader.ToBeAppliedRequestProcessor=>FinalRequestProcessor

(2)  ProposalRequestProcessor构造器设置另一处理器链, initialize方法启动SyncRequestProcessor线程 SyncRequestProcessor(线程）=> AckRequestProcessor
![](https://321cc.cn/usr/uploads/2023/04/405033811.png)

2.      FollowerZooKeeperServer
![](https://321cc.cn/usr/uploads/2023/04/878528690.png)

看如上代码主要建立了如下的两个处理器流链

(1)  FollowerRequestProcessor  => CommitProcessor(线程)  =>FinalRequestProcessor（线程）

(2)  SyncRequestProcessor（线程）=> SendAckRequestProcessor
![](https://321cc.cn/usr/uploads/2023/04/990626862.png)

3.      ObserverZooKeeperServer
![](https://321cc.cn/usr/uploads/2023/04/243078107.png)

(1)    ObserverRequestProcessor => CommitProcessor(线程)  =>FinalRequestProcessor（线程）

(2)    SyncRequestProcessor（线程）=>  SendAckRequestProcessor

(3)    看如上代码主要建立了如下的两个处理器流链
![](https://321cc.cn/usr/uploads/2023/04/601299092.png)

热门标签

热门文章

最新评论