zookeeper的投票结果为什么有两个投票器?
private boolean termPredicate(HashMap<Long, Vote> votes, Vote vote) { //判断是否可以结束投票了
SyncedLearnerTracker voteSet = new SyncedLearnerTracker();
voteSet.addQuorumVerifier(self.getQuorumVerifier());//把自己加进去,当一张选票
if (self.getLastSeenQuorumVerifier() != null
&& self.getLastSeenQuorumVerifier().getVersion() > self //如果LastSeenQuorumVerifier的version比现在的version还大,那也算一个选票(估计是担心member有变化,所以让几个都参与投票计数)
.getQuorumVerifier().getVersion()) {
voteSet.addQuorumVerifier(self.getLastSeenQuorumVerifier());//把LastSeenQuorumVerifier投票器也加进去了
}
/*
* First make the views consistent. Sometimes peers will have different
* zxids for a server depending on timing.
*/
for (Map.Entry<Long, Vote> entry : votes.entrySet()) {//遍历投票结果
if (vote.equals(entry.getValue())) {//如果投给这个voter
voteSet.addAck(entry.getKey());
}
}
return voteSet.hasAllQuorums();//只有所有人都同意了,才说明这次投票没问题了
}
为什么zk判断投票结束需要两个投票器呢?
//last committed quorum verifier
public QuorumVerifier quorumVerifier;
//last proposed quorum verifier 最近的且最大的这个提议的投票器内容(会在平时数据提议的时候逐步递增)
public QuorumVerifier lastSeenQuorumVerifier = null; //这个东西是只增大不减小的
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论