您的位置:首页 > 编程语言 > PHP开发

Zookeeper源码分析(8)- CommitProcessor

2014-03-26 17:34 447 查看
这个processor主要负责将已经完成本机submit的request和已经在集群中达成commit的request匹配,并将匹配后的request交给nextProcessor(即ToBeAppliedRequestProcessor)处理

这是个异步处理的processor,它有两个入口:

一个是前面的processor调用的processRequest,它把request放到队列queuedRequests中

另一个是leader在收到follower的ack包后,调用的processAck函数,如果leader收到了足够的ack包,他会调用这个processord的commit函数,这个函数把请求放入到队列committedRequests中

这个processor还会启动一个线程,他的主要是逻辑就是匹配queuedRequests和committedRequests中的request,匹配是基于两个队列的对首比较的,然后比较两个队列对首的以下元素:

request的txnHeader

request的record

request的zxid

如果都匹配上了就把这个request发给ToBeAppliedRequestProcessor处理
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: