码迷,mamicode.com
首页 > 编程语言 > 详细

Raft算法之选举篇

时间:2020-10-19 22:19:08      阅读:28      评论:0      收藏:0      [点我收藏+]

标签:索引   变更   引号   有一个   lastlog   str   ima   app   内存   

前面我们介绍了Raft算法,接下来会分篇讲述每一个部分,今天讲述选举的细节。

 

在讲述选举之前,先介绍下Raft算法基础。

 

一、Raft基础

1、节点角色

在Raft中,在任意时刻,服务器节点只能是以下3个角色之一:

 

Follower(跟随者):系统启动时默认的角色,一般来说不参与客户端读、写请求,接受Leader发送过来的心跳追加日志,在Leader挂了之后转变为Candidate;

 

Candidate(候选人):如果当前没有Leader,Follower就转变为这个角色,这个角色会向其它节点发起投票请求,如果多数节点同意投票,则晋升为Leader;

 

Leader(领导人):接受客户端的读、写请求,协调整个日志的持久化和推进;

 

下面讲节点角色时统一用英文描述。

 

2、节点角色状态迁移图

技术图片

 

 

系统启动时,大家都是Follower,然后启动定时器,如果在指定时间没有收到Leader的心跳,则将自己变成Candidate,然后向其它成员发起投票请求,如果收到过半以上成员的投票则Candidate晋升为Leader;

 

Leader发送心跳给其它成员时如果收到的响应中term比自己的大,则退化成Follower;

 

3、逻辑时钟(term)

选举过程有个term参数,这个参数就是逻辑时钟,这是一个整数,全局递增;Raft 把时间分割成任意长度的任期,用term来标识每一届leader的任期,这样可以保证在一个任期内只有一个Leader。

 

逻辑时钟规则如下:

Candidate发起选举时就将自己的term加1,然后发起投票请求;

收到投票请求的节点比较请求的term和自己的term,如果请求的term比自己的大,则更新自己的term;

这样在即使每个节点的时间不一样的情况下也可以推进逻辑时钟;

 

 

4、状态

状态所有服务器上持久存在的
currentTerm 服务器最后一次知道的任期号(初始化为 0,持续递增)
votedFor 在当前获得选票的候选人的 Id
log[] 日志条目集;每一个条目包含一个用户状态机执行的指令,和收到时的任期号

上面的状态是所有节点都要保存的,并且要持久化的,即每次变更马上要写入磁盘。

 

 

状态所有服务器上经常变的
commitIndex 已知的最大的已经被提交的日志条目的索引值
lastApplied 最后被应用到状态机的日志条目索引值(初始化为 0,持续递增)

上面的状态是保存在内在中,每次重启后都0开始,即不需要持久化到磁盘上。

 

状态在领导人里经常改变的 (选举后重新初始化)
nextIndex[] 对于每一个服务器,需要发送给他的下一个日志条目的索引值(初始化为领导人最后索引值加一)
matchIndex[] 对于每一个服务器,已经复制给他的日志的最高索引值

上述只有在Leader节点才会需要保存,并且是也是保存在内存中,不需要持久化,重启后从0开始。

 

二、领导人选举

领导人选举发生的条件为Follower没收到Leader的心跳,具体场景一般如下:

1、系统启动时

2、Leader挂了或网络分区了

 

具体细节如下:

1、请求投票 RPC

由候选人发起

 

参数解释
term 候选人的任期号
candidateId 请求选票的候选人的 Id
lastLogIndex 候选人的最后日志条目的索引值
lastLogTerm 候选人最后日志条目的任期号

 

返回值

返回值解释
term 当前任期号,以便于候选人去更新自己的任期号
voteGranted 候选人赢得了此张选票时为真

 

接收请求投票的节点响应规则如下:

  1. 如果term < currentTerm返回 false;
  2. 如果 votedFor 为空或者为 candidateId,并且候选人的日志至少和自己一样新,那么就投票给他;

第1条规则好理解,第2条规则前面部分是为了保证在一个任期内每个节点只投1票,前面也说过这个信息是要持久化的;

 

候选人的日志至少和自己一样新:这里说的就比较笼统了,这里的意思是要看下各自最后1条日志,即两者的索引号和term都对的上,我们看一个实际的例子:

 

技术图片

 

 

 

上面的例子从上往下假设分别为A、B、C、D、E节点,A当前为Leader,各节点日志索引如下:

A:8

B:5

C:8

D:2

E:7

 

如果这时候A挂了,如果D最先升级为Candidate,B、C、E收到请求后都不会为D投票,拿B来说,B发现D的最后一条日志索引为2,而自己的日志索引为8,因此拒绝B的请求。

 

 

关于选举还有其它一些规则:

1、针对Follower

如果在超过选举超时时间的情况之前都没有收到Leader的心跳,或者是Candidate请求投票的,就自己变成Candidate;

2、针对Candidate

开始选举后的动作如下:自增当前的任期号(currentTerm); 给自己投票; 重置选举超时计时器;发送请求投票的 RPC 给其他所有服务器; 
收到响应后的规则:如果接收到大多数服务器的选票,那么就变成Leader;如果接收到来自新的领导人的心跳信息,则转变成Leader;如果选举过程超时,再次发起一轮选举; 

3、针对Leader

一旦成为领导人:发送空的附加日志 RPC(心跳)给其他所有的服务器;在一定的空余时间之后不停的重复发送,以阻止跟随者超时。

技术图片

 

Raft算法之选举篇

标签:索引   变更   引号   有一个   lastlog   str   ima   app   内存   

原文地址:https://www.cnblogs.com/szprg/p/13837961.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!