zk源碼閱讀39:Leader和Follower服務器啟動期交互概述

摘要

之前講解了leader選舉况凉,選舉完了之后,leader與learner的角色明確了各拷,要先完成一些啟動期的交互刁绒,主要是數(shù)據(jù)同步過程,這里大概介紹一下各步驟所對應的源碼在哪烤黍,后續(xù)對類進行詳細的分析

啟動期交互步驟

步驟可參考源碼分析26的,啟動概述

image.png

0.創(chuàng)建Leader服務器和Follower服務器

在選舉出leader時知市,服務器角色明確了
QuorumPeer#run

不同服務器角色的創(chuàng)建

1.Leader服務器啟動Follower接收器LearnerCnxAcceptor(leader端)

運行期間,Leader服務器需要和所有其余的服務器(統(tǒng)稱為Learner)保持連接以確集群的機器存活情況蚊荣,LearnerCnxAcceptor負責接收所有非Leader服務器的連接請求初狰。

Leader#lead

cnxAcceptor = new LearnerCnxAcceptor();//等待learner的連接
cnxAcceptor.start();

2.Learner服務器開始和Leader建立連接。(learner端)

所有Learner會找到Leader服務器互例,并與其建立連接奢入。

以Follower為例

Follower#followLeader
Learner#connectToLeader

3.Leader服務器創(chuàng)建LearnerHandler(leader端)

Leader接收到來自其他機器連接創(chuàng)建請求后,會創(chuàng)建一個LearnerHandler實例媳叨,每個LearnerHandler實例都對應一個Leader與Learner服務器之間的連接腥光,其負責Leader和Learner服務器之間幾乎所有的消息通信和數(shù)據(jù)同步。

Leader.LearnerCnxAcceptor#run
LearnerHandler#run

4.向Leader注冊(learner端)

Learner完成和Leader的連接后糊秆,會向Leader進行注冊武福,即將Learner服務器的基本信息(LearnerInfo),包括SID和ZXID痘番,發(fā)送給Leader服務器捉片。

Follower#followLeader
Learner#registerWithLeader

5.Leader解析Learner信息,計算新的epoch(leader端)

Leader接收到Learner服務器基本信息后汞舱,會解析出該Learner的SID和ZXID伍纫,然后根據(jù)ZXID解析出對應的epoch_of_learner,并和當前Leader服務器的epoch_of_leader進行比較昂芜,如果該Learner的epoch_of_learner更大莹规,則更新Leader的epoch_of_leader = epoch_of_learner + 1。然后LearnHandler進行等待泌神,直到過半Learner已經(jīng)向Leader進行了注冊良漱,同時更新了epoch_of_leader后,Leader就可以確定當前集群的epoch了欢际。

LearnerHandler#run
Leader#getEpochToPropose

6.發(fā)送Leader狀態(tài)母市。(leader端)

計算出新的epoch后,Leader會將該信息以一個LEADERINFO消息的形式發(fā)送給Learner损趋,并等待Learner的響應窒篱。

LearnerHandler#run

QuorumPacket newEpochPacket = new QuorumPacket(Leader.LEADERINFO, ZxidUtils.makeZxid(newEpoch, 0), ver, null); //發(fā)送leader狀態(tài),以LEADERINFO的形式

7.Learner發(fā)送ACK消息。(learner端)

Learner接收到LEADERINFO后,會解析出epoch和ZXID墙杯,然后向Leader反饋一個ACKEPOCH響應配并。

Learner#registerWithLeader

if (qp.getType() == Leader.LEADERINFO)
...
QuorumPacket ackNewEpoch = new QuorumPacket(Leader.ACKEPOCH, lastLoggedZxid, epochBytes, null);//8.接受完了leader狀態(tài)之后,要發(fā)送ACK消息

8.數(shù)據(jù)同步(leader,learner端)

Leader收到Learner的ACKEPOCH后高镐,即可進行數(shù)據(jù)同步溉旋。
這個后面源碼詳細講,涉及DIFF嫉髓,SNAP观腊,TRUNC等操作

learner端

Follower#followLeader
Learner#syncWithLeader

leader端

LearnerHandler#run

9.啟動Leader和Learner服務器。(learner和leader)

當有過半Learner已經(jīng)完成了數(shù)據(jù)同步算行,那么Leader和Learner服務器實例就可以啟動了梧油。

leader端

Leader#lead
Leader#startZkServer

learner
Learner#syncWithLeader

zk.startup();

問題

什么時候出現(xiàn)第5步中的learner的epoch比leader高的情況

何時出現(xiàn)該情況,執(zhí)行 epoch_of_leader = epoch_of_learner + 1
其中epoch_of_learner 是learner的 acceptedEpoch

因為選舉的時候是按currentEpoch來的州邢,大部分情況currentEpoch是acceptedEpoch相等的
什么時候會出現(xiàn)learner的leader的acceptedEpoch高儡陨??量淌?

refer

http://blog.csdn.net/xhh198781/article/details/6587558
http://www.aboutyun.com/thread-10286-1-1.html
http://ju.outofmemory.cn/entry/138169

最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末骗村,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子呀枢,更是在濱河造成了極大的恐慌胚股,老刑警劉巖,帶你破解...
    沈念sama閱讀 217,084評論 6 503
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件裙秋,死亡現(xiàn)場離奇詭異琅拌,居然都是意外死亡,警方通過查閱死者的電腦和手機摘刑,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,623評論 3 392
  • 文/潘曉璐 我一進店門进宝,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人泣侮,你說我怎么就攤上這事即彪〗舫” “怎么了活尊?”我有些...
    開封第一講書人閱讀 163,450評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長漏益。 經(jīng)常有香客問我蛹锰,道長,這世上最難降的妖魔是什么绰疤? 我笑而不...
    開封第一講書人閱讀 58,322評論 1 293
  • 正文 為了忘掉前任铜犬,我火速辦了婚禮,結果婚禮上,老公的妹妹穿的比我還像新娘癣猾。我一直安慰自己敛劝,他們只是感情好,可當我...
    茶點故事閱讀 67,370評論 6 390
  • 文/花漫 我一把揭開白布纷宇。 她就那樣靜靜地躺著夸盟,像睡著了一般。 火紅的嫁衣襯著肌膚如雪像捶。 梳的紋絲不亂的頭發(fā)上上陕,一...
    開封第一講書人閱讀 51,274評論 1 300
  • 那天,我揣著相機與錄音拓春,去河邊找鬼释簿。 笑死,一個胖子當著我的面吹牛硼莽,可吹牛的內容都是我干的庶溶。 我是一名探鬼主播,決...
    沈念sama閱讀 40,126評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼沉删,長吁一口氣:“原來是場噩夢啊……” “哼渐尿!你這毒婦竟也來了?” 一聲冷哼從身側響起矾瑰,我...
    開封第一講書人閱讀 38,980評論 0 275
  • 序言:老撾萬榮一對情侶失蹤砖茸,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后殴穴,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體凉夯,經(jīng)...
    沈念sama閱讀 45,414評論 1 313
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 37,599評論 3 334
  • 正文 我和宋清朗相戀三年采幌,在試婚紗的時候發(fā)現(xiàn)自己被綠了劲够。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,773評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡休傍,死狀恐怖征绎,靈堂內的尸體忽然破棺而出,到底是詐尸還是另有隱情磨取,我是刑警寧澤人柿,帶...
    沈念sama閱讀 35,470評論 5 344
  • 正文 年R本政府宣布,位于F島的核電站忙厌,受9級特大地震影響凫岖,放射性物質發(fā)生泄漏。R本人自食惡果不足惜逢净,卻給世界環(huán)境...
    茶點故事閱讀 41,080評論 3 327
  • 文/蒙蒙 一哥放、第九天 我趴在偏房一處隱蔽的房頂上張望歼指。 院中可真熱鬧,春花似錦甥雕、人聲如沸踩身。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,713評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽惰赋。三九已至,卻和暖如春呵哨,著一層夾襖步出監(jiān)牢的瞬間赁濒,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,852評論 1 269
  • 我被黑心中介騙來泰國打工孟害, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留拒炎,地道東北人。 一個月前我還...
    沈念sama閱讀 47,865評論 2 370
  • 正文 我出身青樓挨务,卻偏偏與公主長得像击你,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子谎柄,可洞房花燭夜當晚...
    茶點故事閱讀 44,689評論 2 354

推薦閱讀更多精彩內容