zookeeper的投票结果为什么有两个投票器?

发布于 2022-09-07 03:40:21 字数 1375 浏览 29 评论 0

    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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文