集群間消息通信

集群間消息通信2消息類型數(shù)據(jù)同步型服務器初始化型請求處理型會話管理型3數(shù)據(jù)同步型DIFF：用于通知Learner服務器、Leader即將與其進行“DIFF”方式的數(shù)據(jù)同步TRUNC：用于觸發(fā)Learner服務器進行內(nèi)存數(shù)據(jù)庫的回滾操作SNAP：用于通知Learner服務器，Learner即將與其進行“全量”方式的數(shù)據(jù)同步UPTODATE：用來告訴Learner服務器，已經(jīng)完成了數(shù)據(jù)同步，可以開始對外提供服務了4服務器初始化型OBSERVERINFO：該信息通常是由Observer服務器在啟動的時候發(fā)送給Leader的，用于向Leader服務器注冊自己，同時向Leader服務器表明當前Learner服務器的角色是Observer。消息中包含了當前Observer服務器的SID和已經(jīng)處理的最新ZXID。5服務器初始化型FOLLOWERINFO：該信息通常是由Follower服務器在啟動的時候發(fā)送給Leader的，用于向Leader服務器注冊自己，同時向Leader服務器表明當前Learner服務器的角色是Follower。消息中包含了當前Follower服務器的SID和已經(jīng)處理的最新ZXID。6服務器初始化型LEADERINFO：在Learner連接上Leader后，會向Leader發(fā)送LearnerInfo消息（包含了OBSERVERINFO和FOLLOWERINFO兩類消息），Leader服務器在接收到該消息后，也會將Leader服務器的基本信息發(fā)送給這些Learner，這個消息就是LEADERINFO，通常包含了當前Leader服務器的最新EPOCH值。7服務器初始化型ACKEPOCH：Learner在接收到Leader發(fā)來的LEADERINFO消息后，會將自己最新的ZXID和EPOCH以ACKEPOCH消息的形式發(fā)送給Leader。8服務器初始化型NEWLEADER：該消息通常用于Leader服務器向Learner發(fā)送一個階段性的標識消息——Leader會在和Learner完成一個交互流程后，向Learner發(fā)送NEWLEADER消息，同時帶上當前Leader服務器處理的最新ZXID。這一系統(tǒng)交互流程包括：足夠多的Follower服務器連接上Leader或是完成數(shù)據(jù)同步。9請求處理型REQUEST：該消息是ZooKeeper的請求轉發(fā)消息。在ZooKeeper中，所有的事務請求去必須由Leader服務器來處理。當Learner服務器接收到客戶端的事務請求后，就會將請求以REQUEST消息的形式轉發(fā)給Leader服務器來處理。10請求處理型PROPOSAL：該消息是ZooKeeper實現(xiàn)ZAB算法的核心所在，即ZAB協(xié)議中的提議。在處理事務請求的時候，Leader服務器會將事務請求以PROPOSAL消息的形式創(chuàng)建投票發(fā)送給集群中所有的Follower服務器來進行事務日志的記錄。11請求處理型ACK：服務器在接收到來自Leader的PROPOSAL消息后，會進行事務日志的記錄。如果完成了事務日志的記錄，那么就會以ACK消息的反饋給Leader。12請求處理型COMMIT：該消息用于通知集群中所有的Follower服務器，可以進行事務請求的提交了。Leader服務器在接收到過半的Follower服務器發(fā)來的ACK消息后，就進入事務請求的最終提交流程——生成COMMIT消息，告知所有的Follower服務器進行事務請求的提交。13請求處理型INFORM：ZooKeeper特別設計了INFORM消息，該消息不僅能夠通知Observer已經(jīng)可以提交事務請求，同時還會在消息中攜帶事務請求的內(nèi)容。SYNC：該消息用于通知Learner服務器已經(jīng)完成了Sync操作。14會話管理型PING：該消息用于Leader同步Learner服務器上的客戶端心跳檢測，用以激活存活的客戶端。Leader服務器無法直接收到所有客戶端的心跳檢測，需要委托給Learner來保存這些客戶端的心跳檢測的客戶端列表，同樣以PING消息的形式反饋給Leader服務器，由Leader服務器來負責逐個對這些客戶端進行會話激活。15會話管理型REVALI