zk集群版服務啟動實現Leader和Follower之間數據交互

本篇內容主要講解“zk集群版服務啟動實現Leader和Follower之間數據交互”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“zk集群版服務啟動實現Leader和Follower之間數據交互”吧!

集群版服務啟動過程

LeaderElection算法

完成自己投票和投票算法的獲取

集群特有，zookeeper首先會根據自身服務器id(sid)

最新的zxid(lastloggedZxid)和當前的服務器epoch(currentEpoch)

來生成一個初始化投票

初始化過程中，每個服務都會給自己投票，然后，根據zoo.cfg的配置

創建相應Leader選舉算法實現

zk配置中提供默認三種算法(Leaderelection,AuthFastLeaderElection,FastLeaderElection).通過zoo.cfg的electionalg屬性指定，默認支持FastLeaderElection

在初始化階段，會創建選舉需要的網絡i/o層 QuorumCnxManager,等待其他服務的連接

@Override
public synchronized void start() {
    if (!getView().containsKey(myid)) {
        throw new RuntimeException("My id " + myid + " not in the peer list");
    }
    //加載數據庫
    loadDataBase();
    //啟動服務連接工廠
    startServerCnxnFactory();
    try {
        adminServer.start();
    } catch (AdminServerException e) {
        LOG.warn("Problem starting AdminServer", e);
        System.out.println(e);
    }
    //開始選舉
    startLeaderElection();
    startJvmPauseMonitor();
    super.start();
}

public synchronized void startLeaderElection() {
    try {
        if (getPeerState() == ServerState.LOOKING) {
            //認為當前是leader
            currentVote = new Vote(myid, getLastLoggedZxid(), getCurrentEpoch());
        }
    } catch (IOException e) {
        RuntimeException re = new RuntimeException(e.getMessage());
        re.setStackTrace(e.getStackTrace());
        throw re;
    }

    this.electionAlg = createElectionAlgorithm(electionType);
}

Leader和Follower啟動交互過程

到此，相信大家對“zk集群版服務啟動實現Leader和Follower之間數據交互”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！