Zookeeper的核心是原子廣播，這個(gè)機(jī)制保證了各個(gè)Server之間的同步。實(shí)現(xiàn)這個(gè)機(jī)制的協(xié)議叫做Zab協(xié)議。Zab協(xié)議有兩種模式，它們分別是恢復(fù)模式（選主）和廣播模式（同步）。當(dāng)服務(wù)啟動(dòng)或者在領(lǐng)導(dǎo)者崩潰后，Zab就進(jìn)入了恢復(fù)模式，當(dāng)領(lǐng)導(dǎo)者被選舉出來(lái)，且大多數(shù)Server完成了和leader的狀態(tài)同步以后，恢復(fù)模式就結(jié)束了。狀態(tài)同步保證了leader和Server具有相同的系統(tǒng)狀態(tài)。
為了保證事務(wù)的順序一致性，zookeeper采用了遞增的事務(wù)id號(hào)（zxid）來(lái)標(biāo)識(shí)事務(wù)。所有的提議（proposal）都在被提出的時(shí)候加上了zxid。實(shí)現(xiàn)中zxid是一個(gè)64位的數(shù)字，它高32位是epoch用來(lái)標(biāo)識(shí)leader關(guān)系是否改變，每次一個(gè)leader被選出來(lái)，它都會(huì)有一個(gè)新的epoch，標(biāo)識(shí)當(dāng)前屬于那個(gè)leader的統(tǒng)治時(shí)期。低32位用于遞增計(jì)數(shù)。
每個(gè)Server在工作過程中有三種狀態(tài)：
LOOKING：當(dāng)前Server不知道leader是誰(shuí)，正在搜尋
LEADING：當(dāng)前Server即為選舉出來(lái)的leader
FOLLOWING：leader已經(jīng)選舉出來(lái)，當(dāng)前Server與之同步
Leader選舉流程：
當(dāng)leader崩潰或者leader失去大多數(shù)的follower，這時(shí)候zk進(jìn)入恢復(fù)模式，恢復(fù)模式需要重新選舉出一個(gè)新的leader，讓所有的Server都恢復(fù)到一個(gè)正確的狀態(tài)。Zk的選舉算法有兩種：一種是基于basic paxos實(shí)現(xiàn)的，另外一種是基于fast paxos算法實(shí)現(xiàn)的。系統(tǒng)默認(rèn)的選舉算法為fast paxos。先介紹basic paxos流程：
1 .選舉線程由當(dāng)前Server發(fā)起選舉的線程擔(dān)任，其主要功能是對(duì)投票結(jié)果進(jìn)行統(tǒng)計(jì)，并選出推薦的Server；
2 .選舉線程首先向所有Server發(fā)起一次詢問(包括自己)；
3 .選舉線程收到回復(fù)后，驗(yàn)證是否是自己發(fā)起的詢問(驗(yàn)證zxid是否一致)，然后獲取對(duì)方的id(myid)，并存儲(chǔ)到當(dāng)前詢問對(duì)象列表中，最后獲取對(duì)方提議的leader相關(guān)信息( id,zxid)，并將這些信息存儲(chǔ)到當(dāng)次選舉的投票記錄表中；
4. 收到所有Server回復(fù)以后，就計(jì)算出zxid最大的那個(gè)Server，并將這個(gè)Server相關(guān)信息設(shè)置成下一次要投票的Server；
5. 線程將當(dāng)前zxid最大的Server設(shè)置為當(dāng)前Server要推薦的Leader，如果此時(shí)獲勝的Server獲得n/2 + 1的Server票數(shù)， 設(shè)置當(dāng)前推薦的leader為獲勝的Server，將根據(jù)獲勝的Server相關(guān)信息設(shè)置自己的狀態(tài)，否則，繼續(xù)這個(gè)過程，直到leader被選舉出來(lái)。
通過流程分析我們可以得出：要使Leader獲得多數(shù)Server的支持，則Server總數(shù)必須是奇數(shù)2n+1，且存活的Server的數(shù)目不得少于n+1.
每個(gè)Server啟動(dòng)后都會(huì)重復(fù)以上流程。在恢復(fù)模式下，如果是剛從崩潰狀態(tài)恢復(fù)的或者剛啟動(dòng)的server還會(huì)從磁盤快照中恢復(fù)數(shù)據(jù)和會(huì)話信息，zk會(huì)記錄事務(wù)日志并定期進(jìn)行快照，方便在恢復(fù)時(shí)進(jìn)行狀態(tài)恢復(fù)。
fast paxos流程是在選舉過程中，某Server首先向所有Server提議自己要成為leader，當(dāng)其它Server收到提議以后，解決epoch和zxid的沖突，并接受對(duì)方的提議，然后向?qū)Ψ桨l(fā)送接受提議完成的消息，重復(fù)這個(gè)流程，最后一定能選舉出Leader。
zookeeper數(shù)據(jù)同步過程：
選完leader以后，zk就進(jìn)入狀態(tài)同步過程。
1. leader等待server連接；
2 .Follower連接leader，將最大的zxid發(fā)送給leader；
3 .Leader根據(jù)follower的zxid確定同步點(diǎn)；
4 .完成同步后通知follower 已經(jīng)成為uptodate狀態(tài)；
5 .Follower收到uptodate消息后，又可以重新接受client的請(qǐng)求進(jìn)行服務(wù)了。
工作流程
Leader工作流程
Leader主要有三個(gè)功能：
1 .恢復(fù)數(shù)據(jù)；
2 .維持與Learner的心跳，接收Learner請(qǐng)求并判斷Learner的請(qǐng)求消息類型；
3 .Learner的消息類型主要有PING消息、REQUEST消息、ACK消息、REVALIDATE消息，根據(jù)不同的消息類型，進(jìn)行不同的處理。
PING消息是指Learner的心跳信息；REQUEST消息是Follower發(fā)送的提議信息，包括寫請(qǐng)求及同步請(qǐng)求；ACK消息是Follower的對(duì)提議的回復(fù)，超過半數(shù)的Follower通過，則commit該提議；REVALIDATE消息是用來(lái)延長(zhǎng)SESSION有效時(shí)間。Leader的工作流程簡(jiǎn)圖如下所示，在實(shí)際實(shí)現(xiàn)中，流程要比下圖復(fù)雜得多，啟動(dòng)了三個(gè)線程來(lái)實(shí)現(xiàn)功能。
2.3.2 Follower工作流程
Follower主要有四個(gè)功能：
1. 向Leader發(fā)送請(qǐng)求（PING消息、REQUEST消息、ACK消息、REVALIDATE消息）；
2 .接收Leader消息并進(jìn)行處理；
3 .接收Client的請(qǐng)求，如果為寫請(qǐng)求，發(fā)送給Leader進(jìn)行投票；
4 .返回Client結(jié)果。
Follower的消息循環(huán)處理如下幾種來(lái)自Leader的消息：
1 .PING消息：心跳消息；
2 .PROPOSAL消息：Leader發(fā)起的提案，要求Follower投票；
3 .COMMIT消息：服務(wù)器端最新一次提案的信息；
4 .UPTODATE消息：表明同步完成；
5 .REVALIDATE消息：根據(jù)Leader的REVALIDATE結(jié)果，關(guān)閉待revalidate的session還是允許其接受消息；
6 .SYNC消息：返回SYNC結(jié)果到客戶端，這個(gè)消息最初由客戶端發(fā)起，用來(lái)強(qiáng)制得到最新的更新。
Follower的工作流程簡(jiǎn)圖如下所示，在實(shí)際實(shí)現(xiàn)中，F(xiàn)ollower是通過5個(gè)線程來(lái)實(shí)現(xiàn)功能的。
http://www.it165.net/admin/html/201405/2997.html