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.mzph.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元素 第二阶段…