主頁 > 軟體設計 > Raft一致性共識演算法論文學習

Raft一致性共識演算法論文學習

2023-01-08 07:45:12 軟體設計

論文地址:https://pdos.csail.mit.edu/6.824/papers/raft-extended.pdf

看完raft共識演算法,腦袋非常懵,所以寫一篇學習筆記,記錄一下,

raft演算法主要解決三個模塊的問題:領匯入選舉、日志復制和安全性,當然除了這三個方面,論文對于raft的安全機制,集群成員變更和日志壓縮都做了比較詳細的描述,

 

一、復制狀態機

復制狀態機(Replicated state machine)的概念就是,相同的初始狀態 + 相同的輸入 = 相同的結束狀態,也就意味在多節點集群中,從相同的初始狀態開始,執行相同的一串命令,產生相同的最終狀態,

 

在 raft 中,leader將客戶端請求封裝成一個一個 log entry 中,將這些 log 發送到 follow 節點,然后大多數的節點按照同樣的順序應用 log entry 中的 command,依據復制狀態機的理論,大家最后的狀態是會一致的,在分布式場景中,各個節點就是依靠共識演算法,保證命令序列的一致,從而始終保持它們的狀態一致,從而實作高可用性,

論文提及raft演算法的特性有以下幾點:

  • 安全性保證(絕對不會回傳一個錯誤的結果):在非拜占庭錯誤情況下,包括網路延遲、磁區、丟 包、冗余和亂序等錯誤都可以保證正確,(這里的拜占庭錯誤指的是節點的本身就不可靠,變成集群中的惡意節點,它為了阻撓真實資訊的傳遞以及有效一致的達成,會向各個節點發送前后不一致的資訊)
  • 可用性:集群中只要有大多數的機器可運行并且能夠相互通信、和客戶端通信,就可以保證可用, 因此,一個典型的包含 5 個節點的集群可以容忍兩個節點的失敗,服務器被停止就認為是失敗,他們當有穩定的存盤的時候可以從狀態中恢復回來并重新加入集群,
  • 不依賴時序來保證一致性:物理時鐘錯誤或者極端的訊息延遲只有在最壞情況下才會導致可用性問題,
  • 通常情況下,一條指令可以盡可能快的在集群中大多數節點回應一輪遠程程序呼叫時完成,小部分 比較慢的節點不會影響系統整體的性能, 

 

二、狀態變化

在任意時刻,每個服務器節點都只處于 leader,follower或candidate這三個狀態之一,

  • leader:領導者,在通常情況下,系統中只有一個領匯入并且其他的節點全部都是跟隨者,
  • follow:跟隨者,他們不會發送任何請求,只是簡單的回應來自領導者或者候選人的請求,
  • candidate:選舉者,當集群沒有領導者時,跟隨者會轉變成 candidate

 

starts up:集群啟動時

time out, start election:follow 在沒有收到 leader 心跳后開始選舉變成選舉者 candidate;

time out,new election:在當前選舉中沒有出現 leader,此輪次超時后進行下一輪選舉

dicocers current leader or new term:當發現已經選出新的 leader,也就是收到 leader 的心跳資訊,或者發現已經開始新的 term 任期,選舉者狀態 candidate 將會轉化成 follow,

dicover serer with higher term:當前的 leader 可能因為網路磁區的問題和集群中的其他 follow 失去心跳聯系,這時候集群選舉出了新的 leader,這時候 leader 就要變成 follow 狀態,

receives votes from mahority servers:當 candidate 收到集群中大多數的投票時,會被選舉成新的 leader,進入 leader 狀態

這圖展示了 raft 中幾個狀態的轉化,

 

在論文中解釋了 term 任期

 

raft將時間劃分成一個一個的任期,每個任期開始都是一個選舉, 選舉成功后 leader 會管理集群到任期結束,如果任期中沒有選舉成功,那么這個任期會因為沒有領匯入而結束,這時候 candidate 因為選舉超時(也就是沒有選出 leader 的超時時間)而自動開啟下一個任期 term,

他們通過 rpc 請求來進行服務器之間的遠程呼叫和通信,并且基本的一致性演算法只需要兩種型別的 RPCs,請求投票(RequestVote) RPCs 由候選人在選舉期間發起,然后附加條目 (AppendEntries)RPCs 由領匯入發起,用來復制日志和提供一種心跳機制,除此之外在服務器之間傳輸快照增加了第三種 RPC,

  • RequestVote RPC(請求投票):由 candidate 在選舉期間發起,
  • AppendEntries RPC(追加條目):由 leader 發起,用來復制日志和提供一種心跳機制,

在論文中對于 raft 的 rpc 實作有一個演算法濃縮總結:還有一個 rpc 是 state 的狀態查詢 rpc 就不列舉了

 rpc介面 引數 

回傳值

 RequestVote RPC  
 

term

 

候選人的任期號

 

candidateId 

 

請求選票的候選人id

lastLogIndex 

候選人的最后日志條目的索引值 

 

lastLogTerm 

候選人最后日志條目的任期號 

term 

當前任期號,以便于候選人去更新自己的任期號 

voteGranted 

候選人贏得了此張選票時為true

接受者實作

1. 如果 term < currentTerm 回傳 false,如果候選人的任期 term 比接收的 follow 跟隨者的當前任期還小,那就拒絕投票,

2. 如果 votedFor 為慷訓者為 candidateId,并且候選人的日志至少和自己一樣新,那么就投票給他(votedFor指的是這個follow節點把票投給的候選者)

 

rpc介面 引數 回傳值
AppendEntries RPC  

term 

領導者的任期 

leaderId 

領導者ID 因此跟隨者可以對客戶端進行重定向(譯者注:跟隨者根據領導者id 把客戶端的請求重定向到領導者,比如有時客戶端把請求發給了跟隨者而不是 領導者) 

prevLogIndex 

緊鄰新日志條目之前的那個日志條目的索引
 

prevLogTerm 

緊鄰新日志條目之前的那個日志條目的任期

entries[] 

需要被保存的日志條目(被當做心跳使用是 則日志條目內容為空;為了提高效 率可能一次性發送多個) 

leaderCommit 

領導者的已知已提交的最高的日志條目的索引

term

當前任期,對于領導者而言 它會更新自己的任期

success 

prevLogIndexprevLogTerm匹配上了 

 
接受者實作

1.  回傳 false 如果領導者的任期小于接收者的當前任期

2. 回傳 false 如果接收者日志中沒有包含這樣一個條目,即該條目的任期在prevLogIndex上不能和 prevLogTerm匹配上

3. 如果一個已經存在的條目和新條目發生了沖突(因為索引相同,任期不同),那么就洗掉這個已經存在的條目以及它之后的所有條目

4. 追加日志中尚未存在的任何新條目

5. 如果領導者的已知已經提交的最高的日志條目的索引 leaderCommit 大于接收者的已知已經提交的,最高的日志條目的索引 commitIndex 則把接收者的已知已經提交的最高的日志條目的索引 commitIndex 重置為領導者的已知已經提交的最高的日志條目的索引leaderCommit,或者是上一個新條目的索引取兩者的最小值(就是會把follow節點的commitindex之前的都提交了)

除此之外所有的節點需要遵循的演算法規則為:

角色 遵循規則
所有服務者

1. 如果 term < currentTerm 回傳 false

2. 如果 votedFor 為慷訓者為 candidateId,并且候選人的日志至少和自己一樣新,那么就投票給他

follower(5.2)

1. 如果 currentIndex > lastApplied,那么就 lastApplied 加一,并把 log[lastApplied] 應用到狀態機中(commitIndex -

已知已提交的最高的日志條目的索引,初始值為0,單調遞增,lastApplied - 已經被應用到狀態機的最高的日志條目的索引,初始值為0,單調遞增)

candidate

(5.2)

1. 在轉變成候選人后就立即開始選舉程序
  (a) 自增當前的任期號(currentTerm) ,然后給自己投票
  (b) 重置選舉超時計時器
  (c) 發送請求投票的 RPC 給其他所有服務器
2. 如果接收到大多數服務器的選票,那么就變成領匯入如果接收到來自新的領匯入的附加日志 RPC,轉變成跟隨者,如果選舉程序超時,再次發起一輪選舉

leader

1. 一旦成為領匯入:發送空的附加日志 RPC(心跳) 給其他所有的服務器,這里就是 no-op 機制;在一定的空余時間之后不停的重復發送,以阻止跟隨者超時(5.2)
2. 如果接收到來自客戶端的請求:附加條目到本地日志中,在條目被應用到狀態機后回應客戶端(5.3)
3. 如果對于一個跟隨者,最后日志條目的索引值大于等于 nextIndex,那么,發送從 nextIndex 開始的所有日志條目:
(a) 如果成功:更新相應跟隨者的 nextIndex 和 matchIndex(5.3)
(b) 如果因為日志不一致而失敗,減少 nextIndex 重試(5.3)
4. 如果存在一個滿足 N > commitIndex 的 N,并且大多數的 matchIndex[i] ≥ N 成立,并且log[N].term == currentTerm 成立,那么令 commitIndex 等于這個 N(5.3、5.4)

 英文版本

 

三、領導者選舉

raft 內部有一種心跳機制,如果存在 leader,那么它就會周期性的向所有 follower 發送心跳,來維持自己的地位,如果 follower 在一段時間滅有收到心跳,那么它會認為沒有 leader,開始進行下一輪選舉,

開啟下一個選舉后,follow 會轉先增加自己的當前任期,并且轉變成 candidate 狀態,然后投票給自己,向其他節點發送 RequestVote RPC,這里因為有超時控制,follower 會根據超時時間陸續進入下一輪選舉 term,所以不存在同時都變成 candidate 投票給自己的情況,

對于沒有成為 canditate 的 follower 節點,按照先來先得的原則進行投票,

當 s2 宕機后開始投票選舉確認后提交后正式進入term=3的任期

這里的狀態機演示可以在網頁上自行除錯:https://raft.github.io/raftscope/index.html

當 candidate 在等待其他節點投票給自己的時候,此時會有三種結果,上圖是成功當選的結果:

  • 它獲得超過半數投票贏得了選舉 -> 成為主 leader 后發送心跳
  • 其他節點贏得選舉(這里就是上面的 S4 節點),收到新 leader 心跳后,如果新 leader 的任期號不小于自己當前的任期號,那么就從 candidate 變成  follower 狀態
  • 一段時間后如果沒有任何獲勝者,每個candidate 都在一個自己的隨機選舉超時時間后增加任期號開始新一輪的投票,論文中給的隨機選舉超時時間為 150~300ms,

 

四、日志復制

集群中 leader 是肯定有最新的日志的,但是其他節點不清楚,基本都是處于一直追趕 leader 日志進度的情況,

在客戶端提供服務中,客戶端的每一個請求都包含一條被復制狀態機執行的指令,領匯入把這條指令作為一條新的日志條目附加到日志中去,然后并行的發起附加條目 RPC 給其他的服務器,讓他們復制這條日志條目,當這條日志條目被安全的復制

領匯入會應用這條日志條目到它的狀態機中然后把執行的結果回傳給客戶端,如果跟隨者崩潰或者運行緩慢,再或者網路丟包,領匯入會不斷的重復嘗試附加日志條目 RPCs (盡管已經回復了客戶端)直到所有的跟隨者都最終存盤了所有的日志條目,

也就說寫請求會在 leader 進行日志復制給大多數 follower 節點成功后回傳結果, 

一條日志中需要三個資訊:

  • 狀態機指令(就是存盤的資料比如下圖的 x->3)
  • leader 的任期號(term)
  • 日志號(日志索引) 

圖中日志由有序序號標記的條目組成,每個條目都包含創建時的任期號(圖中框中的數字),和一個狀態機需要執行的指令,

一個條目當可以安全的被應用到狀態機中去的時候,就認為是可以提交了, 是的,日志還有兩個狀態,就是 未提交已提交

未提交指的是,當 leader 發送 AppendEntriesRPC 請求給其他節點后,讓他們復制該日志條目,這時候日志的狀態就是未提交的,一但超過半數的節點 follower 回應成功,也就意味著這個日志已經成功復制到大多數節點上了,那么此時leader就會把結果回傳給客戶端,并且在本地也執行復制保存該日志的操作,在leader中此時日志條目是已提交狀態,但是注意的是,此時大多數節點中的日志條目還沒有提交,是的,raft 是使用的累計確認的機制,通過下一個心跳才讓大多數提交當前日志條目的,因為 follower 在下一個心跳來臨之前并不知道該日志是否需要改成已提交的,

當收到S5領導者節點發送的append請求后

 

當S5節點收到大多數節點的回復后會把日志條目設定為已提交發送下一個心跳確認會帶上最后一個確認的日志條目最后

 

 

下面這里討論一下當日志復制程序中如果 leader 和 follow 出現崩潰和緩慢超時的情況,raft 演算法是怎么保證繼續日志復制并且保證每個副本順序一致

  1. 如果有 follower 因為某些原因沒有給 leader 回應,那么 leader 會不斷的重新發送追加條目請求 appendRPC,哪怕 leader 已經回復了客戶端

  2. 如果有 follower 崩潰后恢復,此時 raft 追加條目的一致性檢查生效,保證 follower 能按照順序回復崩潰后缺失的進度

raft的一致性檢查,leader 在每一個發往 follower 的追加條目 appendRPC 中,會放入前一個日志條目的索引prelogIndex任期號term, 如果 follower 找不到這個前一個日志,那么它就會拒絕日志,leader 收到拒絕后,會發送前一個日志條目,從而逐漸定位到 follower 第一個缺失的日志,這里其實對于不同的 raft 實作演算法,會有一定的優化,leader 收到拒絕后可以不是發送前一個日志條目,可以通過二分查找啊,或者下一個發送當前term任期的第一個日志,加快查找的行程,

下圖,S3落后 leader 的日志條目非常多,所以在日志復制時:

第一次,S5發送給S3 appendRPC 時,S3 因為 preIndexIndex(等于8) 和它自己當前的 logCurrentindex(等于6) 不符合,所以第一次的時候 S5 并不能將自己的 index=9 的日志條目復制給 s3

第二次,S5發送給S3 appendRPC 時,preIndexIndex=7,還是和S3的 logCurrentindex(等于6) 不符合,所以還是不能將 index=8 的日志條目復制給 s3

第三次,成功復制,將 index=7 的日志條目復制給 s3

  3. 如果 leader 崩潰,那么崩潰的 leader 可能已經復制到部分 follower ,但是資料還沒有提交 ,而被選出的新leader又可能不具備這些日志,這樣就有部分 follow 中的日志和新 leader 的日志不相同,

raft 在這種情況下,leader 會通過強制 follower 復制它的日志來解決不一致的問題,這意味著 follower 中跟 leader 中沖突的日志條目會被新 leader 的日志條目覆寫(注意這里說是未提交的,也就是虛線的資料,意味著這些資料并沒有提交,所以不違反外部一致性原則)

例如論文中提出的例子

當一個領匯入成功當選時,跟隨者可能是任何情況(a-f),每一個盒子表示是一個日志條 目;里面的數字表示任期號,跟隨者可能會缺少一些日志條目(a-b),可能會有一些未被提交的 日志條目(c-d),或者兩種情況都存在(e-f),例如,場景 f 可能會這樣發生,某服務器在任期 2 的時候是領匯入,已附加了一些日志條目到自己的日志中,但在提交之前就崩潰了,很快這個機器就被重啟了,在任期 3 重新被選為領匯入,并且又增加了一些日志條目到自己的日志中;在任 期 2 和任期 3 的日志被提交之前,這個服務器又宕機了,并且在接下來的幾個任期里一直處于宕機狀態, 

當a-e的任意一個節點當選為 leader 時,都會強制將 f 節點變成和 leader 一致的資料,

總結:

ralf 通過這樣的日志復制機制,leader 不需要任何特殊的操作來使得日志恢復到一致狀態,leader 只需要進行正常的操作,然后日志就能在 appendRPC 回復中通過一致性檢查失敗的時候自動趨于一致,

leader 從來不會覆寫或者洗掉自己的條目,只會讓 follower 強制和 leader 保持一致,這樣可以保證:

  1. 只要過半的服務器鄭航運行,raft 就能接收,復制并應用新的日志條目
  2. 在正常情況下,新的日志條目可以在一個 rpc 來回中杯復制給集群中過半的機器
  3. 單個運行慢的follow(如果不是超過集群的大多數)并不會影響整體的性能,也不會影響資料的一致性

 

五、安全性

上面日志復制實際上是解決資料一致性的問題,那么安全性的問題是什么?論文舉例說,一個跟隨者可能會進入不可用狀態同時領匯入已經提交了若干的日志條目,然后這個跟隨者可能會被選舉為領匯入并且覆寫這些日志條目;因此, 不同的狀態機可能會執行不同的指令序列, 也就是集群中可能選擇一個日志條目落后很多的節點當選成為 leader,并且強制覆寫其他節點的資料,以下規則可以保證在各類宕機問題下都不會出錯:

  1. Leader 宕機:選舉限制
  2. Leader 宕機:新 leader 是否提交之前任期內的日志條目
  3. Follower 和  Candidate 宕機處理
  4. 時間和可用性限制

下面進行逐條的解釋:

  • Leader 宕機:選舉限制

如果一個 follower 落后了 leader 若干條日志(但是沒有漏一整個任期),那么下次選舉時,它依然可能當選為 leader,當它當選為 leader 時,它因為缺失最新的那部分日志,從而導致狀態機和其他節點的不一致,并且永遠無法達成一致,所以此規則對候選人增加了一個限制,也就是被選出來的 leader 必須保證為一定包含了之前各個任期所有被提交的日志條目

在 RequestVoteRPC 中,引數有 lastLogIndex(候選者自己最后一個日志號) 和 lastLogTerm(候選者自己最后一個日志任期)

raft 中收到投票選舉請求的節點,會對比自己日志中最后一條日志的條目索引值,和自己當前的任期號比較新來判斷是否要投票給這個候選者,如果沒有自己的新,它就拒絕投票,

當時這里會出現如下圖的情況:(c)中原本已經復制到大多數節點的index=2日志,在(d)中由于S5節點當選為 leader ,則被強制覆寫,導致index=2的資料無了

 

在 (a) 中, S1 是領導者,部分的復制了索引位置 2 的日志條目,在 (b) 中,S1 崩潰了,然后 S5 在任期 3 里 通過 S3、S4 和自己的選票贏得選舉,然后從客戶端接收了一條不一樣的日志條目放在了索引 2 處,然后到 (c),S5 又崩潰了;S1 重新啟動,選舉成功,開始復制日志,在這時,來自任期 2 的 那條日志已經被復制到了集群中的大多數機器上,但是還沒有被提交,如果 S1 在 (d) 中又崩潰 了,S5 可以重新被選舉成功(通過來自 S2,S3 和 S4 的選票),然后覆寫了他們在索引 2 處的日志,

  • Leader 宕機:新 leader 是否提交之前任期內的日志條目

領匯入知道一條當前任期內的日志記錄是可以被提交的,只要它被存盤到了大多數的服務器上,如果一個領匯入在提交日志條目之前崩潰了,未來后續的領匯入會繼續嘗試復制這條日志記錄,然而,一個領匯入不能斷定一個之前任期里的日志條目被保存到大多數服務器上的時候就一定已經提交了, 這里說的情況就是上面所說的情況,有可能已經在大多數節點中提交的資料被新 leader 給覆寫了,

在論文里這一段我看了很久,確實比較難以理解這里想表達的意思,Raft 永遠不會通過計算副本數目的方式去提交一個之前任期內的日志條目,只有領匯入當前任期里的日志條目通過計算副本數目可以被提交,一旦當前任期的日志條目以這種 方式被提交,那么由于日志匹配特性,之前的日志條目也都會被間接的提交

如果上面所說的這一段規則,那么必然會出現新leader被選擇出來后立馬就把舊 term 的資料給覆寫提交的情況,如下圖

在 (c) 中,當前的 leader 為 s1,此時的 term=4,此時s1宕機了,然后 s5 當選為最新的 leader ,term=5,此時 s5 順利的把當前的 index=2 term=3 的日志復制給了全部集群,主要看這個日志條目是虛線框,意味著沒有提交的,此時如果再請求添加一個 term=5 index=3 的日志條目,這個時候吧這個日志條目復制發送給其他節點后,藍色的日志部分才會從虛線變成實作,變成提交狀態,

這以規則的目的是保證,新選舉出來的 leader 不會在當前 term 內的第一條日志條目請求提交前宕機,也就保證了資料肯定是最新的最可靠的,因為宕機的 leader 它們的資料都不可信,也就是 term=2 和 term=4 任期中提交的資料,雖然復制給了大多數,但是并沒有在此任期提交 term=4 的日志資料,所以被認為是臟資料,

  • Follower 和 Candidate 宕機處理

這里的崩潰宕機比leader宕機要簡單,因為宕機后發送給他們的 requestVote 和 appendEntries 請求都會失敗,raft 通過無線重試的方法來處理這種失敗,如果崩潰的機器重啟了,那么這些rpc就會成功的完成,如果一個服務器接收了一個rpc,但是還沒有回應的時候宕機了,那么重啟之后會再次收到相同的請求,這里重復的請求是 leader 快取了這個 follower 節點相關的資訊,大多數是 stateRPC 中的引數,這里插個題外話,如果 follower 節點過多的話,會不會導致 leader 的負擔非常大,因為每個節點都要發送心跳,然后還要記住每個節點的狀態資訊?

  • 時間和可用性限制

raft 只要滿足以下的時間要求,整個系統就能選舉出并維持一個穩定的 leader,

  廣播時間(broadcastTime) << 選舉超時時間(electionTimeout) << 平均故障間隔時間 (MTBF) 

廣播時間指的是從一個服務器并行的發送 RPCs 給集群中的其他服務器并接收回應的平均時間,選舉超時時間就是在 candidate 的選舉的超時時間限制,然后平均故障間隔時間就是對于 一臺服務器而言,兩次故障之間的平均時間, 

 

六、集群成員變更

在集群成員變更,或者需要改變集群配置的時候(比如增刪節點、替換宕機的機器或者改變復制的程度),raft可以進行配置變更自動化,因為這個時候其實是最容易出現錯誤的,比如宕機出現,可能會造成集群腦裂的問題,raft 使用的是類似于兩階段提交的方法,來保證轉換程序中不會出現同一任期的兩個 leader,不會出現集群變成兩個獨立的大多數的問題,

比如論文中這里,從三臺節點增加到五臺節點程序中,S4S5是新加入節點,配置變更的時候會出現 two dishoint majorities ,也就是集群可能會出現兩個 leader ,

如下圖就是發生上面問題的程序:

 

 

階段a. 集群存在 S1 ~ S3 三個節點,我們將該成員配置表示為 C-old,綠色表示該節點當前視圖(成員配置)為 C-old,其中紅邊的 S3 為 leader,

階段b. 集群新增了 S4、S5 兩個節點,該變更從 leader 例如,我們將 S1 ~ S5 的五節點新成員配置表示為 C-new,藍色表示該節點當前視圖為 C-new,

階段c. 假設 S3 短暫宕機觸發了 S1 與 S5 的超時選主,

階段d. S1 向 S2、S3 拉票,S5 向其它全部四個節點拉票,由于 S2 的日志并沒有比 S1 更新,因此 S2 可能會將選票投給 S1,S1 兩票當選(因為 S1 認為集群只有三個節點),而 S5 肯定會得到 S3、S4 的選票,因為 S1 感知不到 S4,沒有向它發送 RequestVote RPC,并且 S1 的日志落后于 S3,S3 也一定不會投給 S1,結果 S5 三票當選,最終集群出現了多個主節點的致命錯誤,也就是所謂的腦裂,

 

在 raft 中為了避免出現這樣的問題,所以用了兩階段的方法,集群在發起變更的時候會切換到一個過渡的配置,也就是(b)中 leader 為 s3 時,收到集群成員新增的命令,此時會變成聯合一致的狀態(joint consensus)

  1.  第一階段,leader 發起 C(old-new) 讓集群進入聯合一致狀態,這時候所有 rpc 都要在新舊兩個配置中都達到大多數才算成功
  2.  第二階段,leader 發起 C(new) 讓集群進入新配置狀態,這時候 rpc 只要在新配置集群下能達到大多數就算成功,

在聯合一致(joint consensus)中,論文說明此階段 raft 需要遵循一下幾點

  • 日志條目被復制給集群中新、老配置的所有服務器,
  • 新、舊配置的服務器都可以成為領匯入,
  • 達成一致(針對選舉和提交)需要分別在兩種配置上獲得大多數的支持,特別是這一條,非常重要

來看看在變更階段的配置切換示意圖

 

虛線表示已經被創建但是還沒有被提交的配置日志條目,實線表 示最后被提交的配置日志條目,領匯入首先創建了 C(old-new) 的配置條目在自己的日志中,并提 交到 C(old-new) 中(C-old 的大多數和 C-new 的大多數),然后他創建 C-new 條目并提交到 C- new 中的大多數,這樣就不存在 C-new 和 C-old 可以同時做出決定的時間點,

估計大多人看到這里還是會比較懵逼,下面我們分別討論下如果 leader 在上圖不同時段宕機,集群會發生什么變化,就知道 raft 是怎么避免腦裂問題的發生了,

  1. leader 在 C(old-new) 聯合一致未提交的時候宕機 

 

S1S2S3是舊集群,S4S5是新加入集群,當s3領導者開始提交 C(old-new) 發起聯合一致時,注意此時還沒提交 C(old-new) ,這個時候 S3 宕機,S1S2選舉超時開始下一輪term,然后S1S2會產生一個老配置的 leader,因為可以投票給自己并且獲取到對方一票,所以 S1S2 都有可能變成舊集群的 leader,而不需要宕機的 S3,

然后 S3S4S5 集群中的任何一個想要成為 leader 的話,需要在老配置集群 S1S2S3 ,和新集群 S1S2S3S4S5 中都拿到超過半數選票才能當選,S4 和 S5 是不可能成為新 leader 的,因為在舊配置 S1S2 中根本不知道有新集群的節點 S4S5,所以舊集群肯定是不能拿到選票的,也就不可能成為舊集群的 leader,唯一有機會成為 leader 的S3,如果在 S1S2 之中成為 leader 后,也是不可能成為舊集群的 leader 的,所以集群就回退到聯合一致的狀態之前了,也就是集群變更失敗,但是不會出現兩個 leader,

如果在 S1S2 超時之前,S3就從宕機恢復,并且成為舊集群的leader,并且在新集群也硬的了大多數,也就是 S4S5 的選票,那么 S3 從宕機中恢復,繼續開始集群成員變更,

在S3中將 C(oid-new) 配置都復制到了新舊集群中的大多數的時候,比如下面

 

舊集群:S2S3,新集群:S2S3S4,這時候就可以提交 C(old-new) 了

  2. leader 如果在 C(old-new) 已提交但 C-new 未發起的時候宕機

這個時候選舉限制安全性規則決定了選出的新 leader 肯定是具有 C(old-new) 配置的,所以也就不存在腦裂的可能,C(old-new) 提交后,leader 就會發起 C-new,這時候 leader 只需要滿足新配置的條件就可以提交日志,

  3. leader 在 C-new 已發起復制時候宕機

對于這種情況,已經復制了 C-new 的節點會只按新配置選舉,沒有復制 C-new 的節點會按照新老配置選擇,然后新 leader 會再次再次提交 C-new,所以宕機也無所謂了,

 

如果此時 leader S3 宕機了,C-new 會不會覆寫呢?不會的,因為處于聯合一致狀態的節點,也就是說只復制 C(old-new) 但是沒有復制 C-new 的節點,必須要在兩個新舊集群中獲得大多數選票才能選舉成功,而 S2S3 不會投票給 S1S4S5 中的一個,因為它日志是領先的,所以只有 S2 才能當選,已提交的 C-new 是不會覆寫的,

集群成員變更還有三個補充規則需要說明一下:

  1.  新增節點時,需要新增的節點一定會先完成日志同步,然后再開始集群成員的變更,這個時候新增的節點不對外提供服務,就只是日志復制追上 leader
  2.  縮減節點時,leader 本身可能就是要縮減的節點,這時它會在完成 C-new 提交后自動退位
  3. 為了避免下線的節點超時選舉影響集群運行,服務器會在它確信集群中有 leader 存在時拒絕 requestVoteRPC,因為 C-new 的新 leader 不會再發送心跳給要退出的節點,如果這些節點沒有及時下線,那么它們超時后會發起選舉,導致集群進入選舉階段,影響集群正常運行,所以一個節點如果在最小超時時間之內,收到了 requestVoteRPC 請求,那么它會拒絕此 RPC,

 

七、日志壓縮

raft 的日志在正常操作中不斷的增長,但是在實際的系統中,日志不能無限制的增長,隨著日志不斷增長,他會占用越來越多的空間,花費越來越多的時間來重置,如果沒有一定的機制去清除日志里積累的陳舊的資訊,那么會帶來可用性問題,
快照是最簡單的壓縮方法,在快照系統中,整個系統的狀態都以快照的形式寫入到穩定的持久化存盤中,然后到那個時間點之前的日志全部丟棄,快照技術被使用在 Chubby 和 ZooKeeper 中,接下來的會介紹 raft 中的快照技術,

 

圖中展示了 raft 中快照的基礎思想,每個服務器獨立的創建快照,只包括已經被提交的日志,主要的作業包括將狀態機的狀態寫入到快照中,raft 也包含一些少量的元資料到快照中: 最后被包含索引指的是被快照取代的最后的條目在日志中的索引值(狀態機最后應用的日志),最后被包含的任期指的是該條目的任期號,保留這些資料是為了支持快照后緊接著的第一個條目的附加日志請求時的一致性檢查, 因為這個條目需要前一日志條目的索引值和任期號,為了支持集群成員更新,快照中也將最后的一次配置作為最后一個條目存下來,一旦服務器完成一次快照,他就可以洗掉最后索引位置之前的所有日志和快照了,

轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/541456.html

標籤:架構設計

上一篇:sysAK(青囊)系統運維工具集:如何實作高效自動化運維?

下一篇:Raft一致性共識演算法論文學習

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C#(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 面試突擊第一季,第二季,第三季

    第一季必考 https://www.bilibili.com/video/BV1FE411y79Y?from=search&seid=15921726601957489746 第二季分布式 https://www.bilibili.com/video/BV13f4y127ee/?spm_id_fro ......

    uj5u.com 2020-09-10 05:35:24 more
  • 第三單元作業總結

    1.前言 這應該是本學期最后一次寫作業總結了吧。總體來說,對作業的節奏也差不多掌握了,作業做起來的效率也更高了。雖然和之前的作業一樣,作業中都要用到新的知識,但是相比之前,更加懂得了如何利用工具以及資料。雖然之間卡過殼,但總體而言,這幾次作業還算完成的比較好。 2.作業程序總結 相比前兩個單元,此單 ......

    uj5u.com 2020-09-10 05:35:41 more
  • 北航OO(2020)第四單元博客作業暨課程總結博客

    北航OO(2020)第四單元博客作業暨課程總結博客 本單元作業的架構設計 在本單元中,由于UML圖具有比較清晰的樹形結構,因此我對其中需要進行查詢操作的元素進行了包裝,在樹的父節點中存盤所有孩子的參考。考慮到性能問題,我采用了快取機制,一次查詢后盡可能快取已經遍歷過的資訊,以減少遍歷次數。 本單元我 ......

    uj5u.com 2020-09-10 05:35:48 more
  • BUAA_OO_第四單元

    一、UML決議器設計 ? 先看下題目:第四單元實作一個基于JDK 8帶有效性檢查的UML(Unified Modeling Language)類圖,順序圖,狀態圖分析器 MyUmlInteraction,實際上我們要建立一個有向圖模型,UML中的物件(元素)可能與同級元素連接,也可與低級元素相連形成 ......

    uj5u.com 2020-09-10 05:35:54 more
  • 6.1邏輯運算子

    邏輯運算子 1. && 短路與 運算式1 && 運算式2 01.運算式1為true并且運算式2也為true 整體回傳為true 02.運算式1為false,將不會執行運算式2 整體回傳為false 03.只要有一個運算式為false 整體回傳為false 2. || 短路或 運算式1 || 運算式2 ......

    uj5u.com 2020-09-10 05:35:56 more
  • BUAAOO 第四單元 & 課程總結

    1. 第四單元:StarUml檔案決議 本單元采用了圖模型決議UML。 UML檔案可以抽象為圖、子圖、邊的邏輯結構。 在實作中,圖的節點包括類、介面、屬性,子圖包括狀態圖、順序圖等。 采用了三次遍歷UML元素的方法建圖,第一遍遍歷建點,第二、三次遍歷設定屬性、連邊,實作圖物件的初始化。這里借鑒了一些 ......

    uj5u.com 2020-09-10 05:36:06 more
  • 談談我對C# 多型的理解

    面向物件三要素:封裝、繼承、多型。 封裝和繼承,這兩個比較好理解,但要理解多型的話,可就稍微有點難度了。今天,我們就來講講多型的理解。 我們應該經常會看到面試題目:請談談對多型的理解。 其實呢,多型非常簡單,就一句話:呼叫同一種方法產生了不同的結果。 具體實作方式有三種。 一、多載 多載很簡單。 p ......

    uj5u.com 2020-09-10 05:36:09 more
  • Python 資料驅動工具:DDT

    背景 python 的unittest 沒有自帶資料驅動功能。 所以如果使用unittest,同時又想使用資料驅動,那么就可以使用DDT來完成。 DDT是 “Data-Driven Tests”的縮寫。 資料:http://ddt.readthedocs.io/en/latest/ 使用方法 dd. ......

    uj5u.com 2020-09-10 05:36:13 more
  • Python里面的xlrd模塊詳解

    那我就一下面積個問題對xlrd模塊進行學習一下: 1.什么是xlrd模塊? 2.為什么使用xlrd模塊? 3.怎樣使用xlrd模塊? 1.什么是xlrd模塊? ?python操作excel主要用到xlrd和xlwt這兩個庫,即xlrd是讀excel,xlwt是寫excel的庫。 今天就先來說一下xl ......

    uj5u.com 2020-09-10 05:36:28 more
  • 當我們創建HashMap時,底層到底做了什么?

    jdk1.7中的底層實作程序(底層基于陣列+鏈表) 在我們new HashMap()時,底層創建了默認長度為16的一維陣列Entry[ ] table。當我們呼叫map.put(key1,value1)方法向HashMap里添加資料的時候: 首先,呼叫key1所在類的hashCode()計算key1 ......

    uj5u.com 2020-09-10 05:36:38 more
最新发布
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式,它可以用來減少類之間的直接依賴關系,
    * 將物件之間的通信封裝到一個中介者物件中,從而使得各個物件之間的關系更加松散。
    * 在中介者模式中,物件之間不再直接相互互動,而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:20:47 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點,專案投資大概1億,包括了礦山的各方面的內容,顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃,有很多煤礦行業專家的加持,他們的描述是非常完美,但是去年底應該上線的平臺,現在還沒有看到影子。他們確實有很多場景需求,但是被... ......

    uj5u.com 2023-04-20 08:20:25 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序,開始編碼、測驗、除錯之前進行需求分析和架構設計,才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:20:17 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師,不僅僅要緊跟行業技術趨勢,還要結合研發團隊現狀及痛點,探索新的交付方案。在日常中,你是否遇到如下問題 “ 業務需求排期長研發是瓶頸;非研發角色感受不到研發技改提效的變化;引入ISV 團隊又擔心質量和安全,培訓周期長“等等,基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:20:10 more
  • 【中介者設計模式詳解】C/Java/JS/Go/Python/TS不同語言實作

    * 中介者模式是一種行為型設計模式,它可以用來減少類之間的直接依賴關系,
    * 將物件之間的通信封裝到一個中介者物件中,從而使得各個物件之間的關系更加松散。
    * 在中介者模式中,物件之間不再直接相互互動,而是通過中介者來中轉訊息。 ......

    uj5u.com 2023-04-20 08:19:44 more
  • 露天煤礦現場調研和交流案例分享

    他們集團的資訊化公司及研究院在一個礦區正在做智能礦山的統一平臺的 試點,專案投資大概1億,包括了礦山的各方面的內容,顯示得我們這次交流有點多余。他們2年前開始做智能礦山的規劃,有很多煤礦行業專家的加持,他們的描述是非常完美,但是去年底應該上線的平臺,現在還沒有看到影子。他們確實有很多場景需求,但是被... ......

    uj5u.com 2023-04-20 08:19:07 more
  • 《社區人員管理》實戰案例設計&個人案例分享

    設計是一個讓人夢想成真程序,開始編碼、測驗、除錯之前進行需求分析和架構設計,才能保證關鍵方面都做正確 ......

    uj5u.com 2023-04-20 08:18:57 more
  • 軟體架構生態化-多角色交付的探索實踐

    作為一個技術架構師,不僅僅要緊跟行業技術趨勢,還要結合研發團隊現狀及痛點,探索新的交付方案。在日常中,你是否遇到如下問題 “ 業務需求排期長研發是瓶頸;非研發角色感受不到研發技改提效的變化;引入ISV 團隊又擔心質量和安全,培訓周期長“等等,基于此我們探索了一種新的技術體系及交付方案來解決如上問題。 ......

    uj5u.com 2023-04-20 08:18:49 more
  • 05單件模式

    #經典的單件模式 public class Singleton { private static Singleton uniqueInstance; //一個靜態變數持有Singleton類的唯一實體。 // 其他有用的實體變數寫在這里 //構造器宣告為私有,只有Singleton可以實體化這個類! ......

    uj5u.com 2023-04-19 08:42:51 more
  • 【架構與設計】常見微服務分層架構的區別和落地實踐

    軟體工程的方方面面都遵循一個最基本的道理:沒有銀彈,架構分層模型更是如此,每一種都有各自優缺點,所以請根據不同的業務場景,并遵循簡單、可演進這兩個重要的架構原則選擇合適的架構分層模型即可。 ......

    uj5u.com 2023-04-19 08:42:41 more