raft算法學習(一):角色概念以及選舉過程

Raft算法是強領導模型,集群中只能有一個領導。
下面是raft的視頻講解:
raft

raft的三種角色及其概念

服務器節點狀態一共有三種:領導者(Leader)、跟隨著(Follower)、候選人(Candidate)
跟隨者:接受和處理來自領導者的消息,當等待領導者心跳信息超時時,推薦自己當候選人
候選人:向其他節點發送請求投票的RPC消息,通知其他節點來投票,如果贏得了大多數選票,就晉升當領導者
領導者:處理寫請求、管理日志復制、不斷發送心跳信息,表示自己還活著,不要發起新的選舉

選舉領導者的過程

初始狀態:所有節點都是跟隨者
Raft算法特性時隨機超時時間,每個節點等待領導者節點心跳信息的超時時間間隔是隨機的。
集群中沒有領導者時,等待超時時間最小的節點會因為沒有等到領導者心跳信息,發生超時。
超時自薦
此時該節點就會增加自己的任期編號,并推舉自己為候選人,先給自己投一張選票,然后向其他節點發送請求投票RPC消息,請它們選舉自己為領導者。
選舉投票
其他節點接受到候選人的RPC消息時,并且在編號為1的任期內,沒有投過票,那么就把選票投給該候選人,然后增加自己的任期編號。

圖1 初始狀態
圖2 超時自薦
圖3 選舉投票

新領導產生
候選人在選舉超時時間內贏得了大多數的選票,那么它就會成為本屆任期內新的領導者。

新領導威懾維權
領導者將周期性地發送心跳消息,通知其他服務器我是領導者,阻止跟隨者發起新的選舉,篡權。

圖1 初始狀態
圖2 超時自薦

選舉細節

1、節點間通訊方式

Raft里,服務器節點間溝通聯絡采用的是遠程過程調用(RPC),在領導選舉中,需要用到兩類RPC:
1、請求投票(RequestVote)RPC,由候選人在選舉期間發起,通知各個節點進行投票
2、日志復制(AppendEntries)RPC,由領導者發起,用來復制日志和提供心跳信息

2、關于任期的rules

Raft算法中的領導者是有任期的,每個任期由單調遞增的數字(任期編號)標識。任期編號會隨著選舉的進行而變化。
Raft 算法中的任期不只是時間段,而且任期編號的大小,會影響領導者選舉和請求的處理
1、跟隨者在等待領導者心跳信息超時后,推舉自己為候選人,會增加自己的任期號。(在推舉自己的時候就會++了)
2、一個服務器節點若檢測到自己任期編號比其他節點小,更新自己的編號到較大的編號值
3、若一個候選人或者領導者檢測到自己任期編號比其他節點小,會將自己恢復成跟隨著狀態。所以,raft 不兼容作惡節點。 只要有一個作惡節點發送“任期編號更大“的心跳消息,立馬就能讓這個集群變成無 leader 的,進而無法工作
4、如果一個節點接收到一個包含較小的任期編號值的請求,那么它會直接拒絕這個請求。

3、關于選舉的rules

1、領導者周期性向所有跟隨者發送心跳信息(不包含日志復制RPC消息)
2、如果在指定時間內,跟隨者沒有結收到領導者的消息,那么就自薦,發起領導者選舉
3、在一次選舉中,贏得大多數選票的候選人,將晉升為領導者
4、一個任期內,領導者會一直是領導者,直到它自身出現宕機等問題。當然如果出現網絡延遲,也會出現重新選舉的情況‘
5、在一次選舉中,每一個服務器節點最多會對一個任期編號投出一張選票,并且按照“先來先服務”的原則進行投票。
如下圖:
在這里插入圖片描述
6、日志完整性高的跟隨者拒絕投票給日志完整性低的候選人,即如果日志不完整的請求當主節點,如果當前的節點日志比他完整,那么就會拒絕給他投票
在這里插入圖片描述

4、隨即超時解決選票瓜分現象

? 跟隨者等待領導者心跳信息超時的時間間隔,是隨機的
? 當沒有候選人贏得過半票數,選舉無效了,這時需要等待一個隨機時間間隔,也就是說,等待選舉超時的時間間隔,是隨機的

關于raft的領導者選舉限制和局限

1.讀寫請求和數據轉發壓力落在領導者節點,導致領導者壓力。
2.大規模跟隨者的集群,領導者需要承擔大量元數據維護和心跳通知的成本。
3.領導者單點問題,故障后直到新領導者選舉出來期間集群不可用。
4.隨著候選人規模增長,收集半數以上投票的成本更大。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/376849.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/376849.shtml
英文地址,請注明出處:http://en.pswp.cn/news/376849.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

解決 FLex 4.0 Module里面Alert.show();出錯問題

TypeError: Error #1009: 無法訪問空對象引用的屬性或方法。 at mx.managers::PopUpManagerImpl/http://www.adobe.com/2006/flex/mx/internal::createModalWindow()[E:\dev\hero_private\frameworks\projects\framework\src\mx\managers\PopUpManagerImpl.as:701] at mx.manag…

datetime2 數據類型

.net的Entity Framework構建網站數據層,給一個實體的DATETIME類型的屬性賦值時 突然莫名奇妙顯示有一個類型不匹配的異常如下: System.Data.SqlClient.SqlException: 從 datetime2 數據類型到 datetime 數據類型的轉換產生一個超出范圍的值。 解決方法&a…

Yslow的A評級指南

這里測的是V2引擎,V1想拿A幾乎不可能,一個CDN測試的F就可以輕松廢了你的網站。 A評級 現在一個一個分析。 User fewer HTTP Requests:減少HTTP請求 圖片、CSS、JS、flash等這些都需要增加http請求數,減少這些元素的數量能減少響應…

jquery下 選擇器整理

jQuery 的選擇器可謂之強大無比,這里簡單地總結一下常用的元素查找方法 $("#myELement") 選擇id值等于myElement的元素,id值不能重復在文檔中只能有一個id值是myElement所以得到的是唯一的元素 $("div") 選擇所有的di…

git日常使用教程

目錄git日常使用git 基礎用法(本地)git branchgit checkoutgit mergegit rebaseHEAD ,在提交樹上移動相對引用強制修改分支位置撤銷變更整理提交記錄提交技巧Git TagsGit Describegit 基礎用法(遠程)git fetchgit pullgit push偏離的提交歷史,十分重要!&…

android一鍵分享功能不使用任何第三方sdk

在android中有自帶的一鍵分享功能,不過它會把所有帶分享的應用都找出來,如果我們只需要一些常見的分享應用,該如何做呢? 下面看我的效果圖(橫屏和豎屏自動適配): 接下來看我的調用(支…

包含EditText組件的界面中,禁止自動彈出軟鍵盤

解決方法: 1)在Manifest.xml文件中相應的activity下添加一下代碼:android:windowSoftInputMode"stateHidden"2)讓EditText失去焦點,使用EditText的clearFocus方法 例如:EditText edit(EditText)f…

gcc 編譯器使用指南

目錄安裝準備test.cpp編譯g 編譯參數-g :編譯帶調試信息的可執行文件-O[n] :開啟優化-l 和 -L :指定庫文件 | 指定庫文件路徑-I :指定頭文件搜索目錄-Wall 和 -w:打印警告信息 | 關閉警告信息-stdc11 :設置…

bug found:定義對象時

看下面代碼 class Test{ }; class Test2{public:Test2(Test *t){}};int main(){Test test();//把定義一個對象 “Test test;” 寫成 “Test test();”函數聲明了!Test2 test2(&test);//return 0;}Dev-cpp的提示信息: no matching function for c…

CMake學習使用(基于vscode)

目錄語法一些重要指令CMake常用變量CMake編譯工程編譯流程兩種構建方式實例展示參考: 基于VSCode和CMake實現C/C開發 | Linux篇 語法 基本語法格式:指令(arg1 arg2 …) 參數使用括弧括起來參數之間使用空格或者分號分開 指令是大小寫無關的&#xff0…

idhttp.post方式 調用datasnap rest 遠程方法

idhttp.get方式調用,這種比較簡單,大家都會。post方式網上卻沒有任何成功的代碼,本人也是摸索了一個上午才搞定。 分享給大家。 (1)post方式調用的遠程方法,方法名必須加“update”前綴,不加行不…

[轉]連接excel數據源時,首行包含列名稱選項在連接字符串中的設置。

關于Excel導入的HDRYES; IMEX1詳解 ProviderMicrosoft.Jet.OLEDB.4.0;Data Source111.xls;Extended Properties"Excel 8.0;HDRNO"; 其中HDRNO或YES即首行包含列名稱選項 (參數HDR的值:HDRYes,這代表第一行是標題,不做為數據使用&am…

C++多線程快速入門(一):基本常用操作

目錄case1:創建線程1 join、detachcase2:創建線程2 線程傳參 傳值或者傳引用case3:創建線程 線程傳參 functional object作為參數case4:觀察多線程程序加速計算case5:future get 獲取并發結果case6:互斥鎖…

android:configChanges屬性總結

原文地址:http://blog.csdn.net/zhaokaiqiang1992/article/details/19921703 android中的組件Activity在manifest.xml文件中可以指定參數android:ConfigChanges,用于捕獲手機狀態的改變。 在Activity中添加了android:configChanges屬性&#…

eclipse 中修改 M2_REPO的值

從eclipse中增加了maven2的插件之后,maven默認的本地庫的路徑是${user}/.m2/repository/下,一般windows用戶的操作系統都安裝在C盤,所以這個目錄 下的jar包比較危險。我嘗試從myeclipse->preferences->java->build path->classpa…

C++多線程快速入門(二)共享數據同步以及數據競爭

目錄std::unique_lock類模板僅調用一次線程局部存儲原子變量往期內容回顧std::unique_lock類模板 互斥鎖保證了線程間的同步,卻將并行操作變成了串行操作,對性能有較大影響,所以我們要盡可能減小鎖的區間粒度。 lock_guard只能保證在析構的時…

DNS安全淺議、域名A記錄(ANAME),MX記錄,CNAME記錄

相關學習資料 http://baike.baidu.com/link?url77B3BYIuVsB3MpK1nOQXI-JbS-AP5MvREzSnnedU7F9_G8l_Kvbkt_O2gKqFw7vm http://www.rfc-editor.org/rfc/rfc1035.txt http://www.rfc-editor.org/rfc/rfc3596.txt http://www.rfc-editor.org/rfc/rfc2782.txt http://www.rfc-edito…

ThinkInJava4讀書筆記之第一章對象入門

那句話怎么說來著,原句記不住了好像是出來混的遲早要還的。話說當初學校剛開Java課程,自己沒有好好學啊,后來直接做了jsp和servlet,然后學了SSH框架和Extjs、jQuery,接著是mybatis(ibatis)、fre…

C++多線程快速入門(三):生產者消費者模型與條件變量使用

互斥鎖完成 #include <iostream> #include <deque> #include <thread> #include <mutex>std::deque<int> q; std::mutex mtx;static void produce(int val) {while(val--) {std::unique_lock<std::mutex> guard(mtx);q.push_front(val);m…

【blade利刃出鞘】一起進入移動端webapp開發吧

前言 在移動浪潮襲來的時候&#xff0c;小釵有幸進入框架組做webapp框架開發&#xff0c;過程中遇到了移動端的各種坑&#xff0c;也產生了各種激情&#xff0c;就我們公司的發展歷程來說 第一階段&#xff1a;使用傳統方式開發移動站點&#xff0c;少量引入HTML5元素 第二階段…