zookeeper 请求处理流程

zk集群中，有3种角色，分别是Leader、Fllower和Observer。

1 Leader

Leader服务器是整个zk集群的核心，主要工作是如下两个：

1、事务请求的唯一调度者和处理者，保证集群中事务处理的顺序性。
2、集群内部各服务器的调度者。

使用责任链模式来处理客户端请求是zk服务器的一大特色，每个服务器启动的时候，都会进行请求处理链的初始化，Leader服务器请求处理链如下图：

PreQuestProcessor：Leader服务器的预处理器，zk中“事务”通常指那些创建节点、更新节点、删除节点、建立会话等请求，PreQuestProcessor会判断是否是事务请求，如果是事务请求，会进行事务头和事务体的创建、会话检查、ACL和版本检查等。
ProposalRequestProcessor：事务投票处理器，非事务请求直接交给CommitProcessor处理；事务处理除了接交给CommitProcessor处理，还会创建对应的Proposal提议，发给Follower进行投票，同时将事务请求请求交给SyncRequestProcessor进行事务日志的记录。
SyncRequestProcessor：事务日志记录处理器，将事务日志写入到日志文件中，同时出发zk进行数据快照。
AckRequestprocessor：Leader特有处理器，负责在SyncRequestProcessor完成事务日志记录后，向Proposal投票收集器发送ACK反馈，通知完成了对该Proposal的事务日志记录。
CommitProcessor：事务提交处理器，对于非事务请求，直接交个下一级处理器；对于事务请求，会等待集群内针对Proposal的投票直到Proposal可以被提交。利用CommitProcessor，每个服务器可以很好的控制事务请求的顺序处理。
ToBeCommitProcessor：内部有一个toBoApplied队列，存储已经被CommitProcessor处理过可被提交的Proposal。ToBeCommitProcessor处理器将这些请求交付给FinalRequestProcessor处理器进行处理，等待FinalRequestProcessor处理完成后，再将其从toBoApplied队列中移除。
FinalRequestProcessor：最后一个处理器，对于事务请求，将事务应用到内存数据库中，然后响应客户端请求。

LearnerHandler

Leader与每个Follower/Observer都建立一个TCP长连接，同时会为每个TCP长连接创建一个名为LearderHandler的实体，用来表示Leader与它们之间的连接信息。LearderHandler主要负责Leader和Follower/Observer之间的一系列网络通信，包括数据同步、请求转发和Proposal投票。

2 Follower

Follower是Leader的跟随者，主要职责有以下3个：

处理非事务请求，转发事务请求到Leader服务器。
参与事务请求Proposal投票。
参与Leader选举投票。

和Leader一样，Follower也采用了责任链模式处理请求，由于不需要事务请求的投票处理，流程相对简单一点。

FollowerRequestprocessor：Follower的第一个请求处理器，识别请求是否是事务请求，如果是事务请求，那么Follower将事务请求转发给Leader服务器，Leader收到该事务请求后，就会将其提交到请求处理链，按照正常事务请求进行处理。
SendAckRequestProcessor：SendAckRequestProcessor处理器的职责和Leader中AckRequestprocessor处理器的职责类似，都是向Leader反馈ACK消息以表明自身完成了事务日志的记录工作。二者唯一区别就是，AckRequestprocessor处理器和Leader在同一个处理器上，因此它的ACK反馈动作仅仅是本地操作；而SendAckRequestProcessor处理器需要通过ACK消息形式反馈给Leader服务器。

3 Observer

Observer是zk自3.3.0版本引入的新角色，其工作原理和Follower类似，对于非事务请求都可以独自处理，对于事务请求，发送给Leader处理。和Follower唯一区别就是，Observer不参与投票，包括事情请求proposal的投票和leader选举的投票。另外，Observer的请求处理链和Follower类似。

需要注意的是，虽然上图中在初始化阶段会将SyncRequestProcessor处理器组装上去，但是在实际的运行过程中，Leader服务器不会讲事务请求发送个Observer服务器。

ThinkInOpenSource / zookeeper