zk中leader和follower启动时信息交互分析
本篇内容主要讲解“zk中leader和follower启动时信息交互分析”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“zk中leader和follower启动时信息交互分析”吧!
创新互联建站主要从事网页设计、PC网站建设(电脑版网站建设)、wap网站建设(手机版网站建设)、成都响应式网站建设、程序开发、网站优化、微网站、成都微信小程序等,凭借多年来在互联网的打拼,我们在互联网网站建设行业积累了丰富的网站制作、成都网站设计、网站设计、网络营销经验,集策划、开发、设计、营销、管理等多方位专业化运作于一体。
QuorumPeer中读取节点状态信息,不同状态下设置不同角色
1 Leader启动Follower接收器LearnerCnxAcceptor
LearnerCnxAcceptor负责接收非leader连接请求,线程中创建LearnerHandler处理器
2 Learner发起和leader的连接
Follower.followLeader()
Observer.observeLeader()
3 leader启动时会创建LearnerHandler
每个learnerHandler实例都对应一个leader和learner之间的连接,负责消息通信和
数据同步
4 向leader注册
learner和leader连接后。会向leader注册,即learner服务器基础信息
LearnerInfo zxid,sid发送给leader服务器
5 leader 接收到learner信息 服务器算出最新epoch
@Override public long getEpochToPropose(long sid, long lastAcceptedEpoch) throws InterruptedException, IOException { synchronized (connectingFollowers) { if (!waitingForNewEpoch) { return epoch; } if (lastAcceptedEpoch >= epoch) { epoch = lastAcceptedEpoch + 1; } if (isParticipant(sid)) { connectingFollowers.add(sid); } QuorumVerifier verifier = self.getQuorumVerifier(); if (connectingFollowers.contains(self.getId()) && verifier.containsQuorum(connectingFollowers)) { waitingForNewEpoch = false; self.setAcceptedEpoch(epoch); connectingFollowers.notifyAll(); } else { long start = Time.currentElapsedTime(); if (sid == self.getId()) { timeStartWaitForEpoch = start; } long cur = start; long end = start + self.getInitLimit() * self.getTickTime(); while (waitingForNewEpoch && cur < end && !quitWaitForEpoch) { connectingFollowers.wait(end - cur); cur = Time.currentElapsedTime(); } if (waitingForNewEpoch) { throw new InterruptedException("Timeout while waiting for epoch from quorum"); } } return epoch; } }
到此,相信大家对“zk中leader和follower启动时信息交互分析”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
网页标题:zk中leader和follower启动时信息交互分析
网站网址:http://scyanting.com/article/pdhcce.html