Follower 初始化

選舉完成后，節(jié)點(diǎn)狀態(tài)被初始化為FOLLOWING，之后創(chuàng)建follower節(jié)點(diǎn)，跟隨leader并從leader同步數(shù)據(jù)。

1、Follower 相關(guān)類(lèi)

• Follower：follower的控制邏輯
• FollowerZookeeperServer：客戶(hù)端請(qǐng)求處理、同步leader數(shù)據(jù)

2、follower控制邏輯

在follower 初始化完成后，通過(guò) follower#followLeader 來(lái)跟隨leader。

1、尋找leader節(jié)點(diǎn)

尋找leader節(jié)點(diǎn)通過(guò)Learner#findLeader實(shí)現(xiàn)。遍歷所有節(jié)點(diǎn)，通過(guò)投票信息找出leaderId。

2、連接leader

通過(guò)Learner#connectToLeader 和上一步找到的leader建立連接，如果失敗默認(rèn)會(huì)重試不辭

3、同步新的選舉周期

這一步和leader的數(shù)據(jù)交互都是同步的，有以下幾個(gè)步驟：

• 1、發(fā)送FOLLOWERINFO（serverId，zxid，協(xié)議版本等）給leader
• 2、收到 LEADERINFO 數(shù)據(jù)后，解析出leader的 newEpoch；回復(fù) ACKEPOCH 數(shù)據(jù)包（包括follower 的lastLoggedZxid）給leader。
• 3、將 leader# newEpoch 封裝成zxid 返回。

4、向Leader同步數(shù)據(jù)

通過(guò)Learner#syncWithLeader 實(shí)現(xiàn)數(shù)據(jù)同步。這一步leader 會(huì)根據(jù) follower 之前回復(fù)的ack數(shù)據(jù)包中l(wèi)astLoggedZxid 來(lái)確定同步策略（參考leader初始化篇）。

1、數(shù)據(jù)同步前處理

在數(shù)據(jù)開(kāi)始同步前，follower會(huì)根據(jù)leader 發(fā)送的數(shù)據(jù)同步策略預(yù)先做一些處理

• DIFF：等待差異化同步
• SNAP：清除follower db，使用來(lái)自leader的數(shù)據(jù)覆蓋本地?cái)?shù)據(jù)
• TRUNC：將數(shù)據(jù)回滾到leader#zxid

2、同步數(shù)據(jù)

• 1、將收到PROPOSAL 數(shù)據(jù)包放到packetsNotCommitted 隊(duì)列中
• 2、收到COMMIT時(shí)，取出packetsNotCommitted 首節(jié)點(diǎn)將其提交，之后移除首節(jié)點(diǎn)，將其加入到packetsCommitted 中
• 3、處理NEWLEADER；leader將需要同步的數(shù)據(jù)都發(fā)給follower之后，會(huì)緊接著發(fā)送一個(gè)NEWLEADER 數(shù)據(jù)包給follower，意味著follower收到這個(gè)類(lèi)型的數(shù)據(jù)包之后表示數(shù)據(jù)已同步完成，然后會(huì)回復(fù)ACK給leader。
• 4、處理UPTODATE；在leader收到大多數(shù)follower發(fā)送的ACK消息之后，會(huì)啟動(dòng)自身服務(wù)，，啟動(dòng)完成之后會(huì)發(fā)送UPTODATE數(shù)據(jù)包給follower。follower收到這個(gè)數(shù)據(jù)包時(shí)，表示數(shù)據(jù)已經(jīng)同步完，并且leader 服務(wù)已經(jīng)開(kāi)始對(duì)外服務(wù)。此時(shí)follower退出同步數(shù)據(jù)任務(wù)，開(kāi)始啟動(dòng)自身服務(wù)。

3、啟動(dòng) FollowerZookeeperServer

• 1、創(chuàng)建并啟動(dòng)SessionTracker（LearnerSessionTracker）
• 2、設(shè)置請(qǐng)求處理器；
• 3、注冊(cè)JMX，修改當(dāng)前節(jié)點(diǎn)狀態(tài)為RUNNING

4、處理snapshot 到 uptodate 之間的數(shù)據(jù)

再以snapshot的方式同步數(shù)據(jù)時(shí)，開(kāi)始同步數(shù)據(jù)到follower 收到uptodate數(shù)據(jù)包之間有可能leader也有數(shù)據(jù)變更，這時(shí)需要將這部分?jǐn)?shù)據(jù)提交。

經(jīng)過(guò)以上的步驟之后，follower 服務(wù)啟動(dòng)完成。作為follower 它一方面需要處理來(lái)自客戶(hù)端的請(qǐng)求，一方面也需要處理來(lái)自leader 的心跳數(shù)據(jù)和proposal和commit數(shù)據(jù)。