凯发真人娱乐

解读raft(二 选举和日志复制) -凯发真人娱乐

2023-08-17,,

leader election

raft采用心跳机制来触发leader。leader周期性的发送心跳(如果有正常的rpc的请求情况下可以不发心跳)包保持自己leader的角色(避免集群中其他节点认为没有leader而开始选举)。

follower在收到leader或者candidate的rpc请求的情况下一直保持follower状态。而当一段时间内(election timeout)没有收到请求则认为没有leader节点而出发选举流程。

选举流程如下:

    follower递增自己的任期并设置为candidate角色
    投票给自己并且并发的给所有节点发送投票请求
    保持candidate状态直到:
    同一个任期内获得大多数选票,成为leader(一个节点在一个任期内只能给一个candidate投票,任期相同则选票先到先得)并给其他节点发送心跳来保持自己的角色
    收到其他节点的rpc请求,如果请求中的任期大于等于candidate当前的任期,认为其他节点成为了leader,自身转换为follower;如果其他节点的任期小于自身的任期,拒绝rpc请求并保持candidate角色
    一段时间后仍旧没有leader(可能是出现了平票的情况),则在选举超时后重新发起一轮选举(递增任期、发送投票请求)

为了避免平票的问题,同时在出现平票的情况后能快速解决,raft的选举超时时间是在一个区间内随机选择的(150~300ms)。这样尽量把服务器选举时间分散到不同的时间,保证大多数情况下只有一个节点会发起选举。在平票的情况下,每个节点也会在一个随机时间后开始新一轮选举,避免可能出现的一直处于平票的情况。

log replication

一旦leader被选举出来后,leader就开始为集群服务:处理所有的客户端请求并将数据到所有节点。

一旦日志被“安全”的复制,那么leader将这个日志应用到自己的状态机并响应客户端。

如果有节点异常或网络异常,leader会一直重试直到所有日志都会正确复制到所有节点(日志不允许有空洞,所以每个节点上的日志都是连续的,不能有因为失败引起的空洞)。

日志组织形式如上图,每个日志条目中包含可执行的指令、和日志被创建时的任期号,日志条目也包含了自己在日志中的位置,即index。一旦一个日志条目存在于大多数节点,那么该日志条目是committed的。

raft算法保证所有committed的日志都是持久化的(日志需要在大多数节点上持久化之后再响应给客户端,这意味着每个follower节点收到appendentry请求后需要持久化到日志之后再响应给leader),且最终会被所有的状态机执行。

raft算法保证了以下特性:

如果两个日志条目有相同的index和term,那么他们存储了相同的指令(即index和term相同,那么可定是同一条指令,就是同一个日志条目)
如果不同的日志中有两个日志条目,他们的index和term相同,那么这个条目之前的所有日志都相同

两条规则合并起来的含义:两个日志loga、logb,如果loga[i].index=log[i]b.index且loga[i].term=log[i].term,那么loga[i]=log[i]b,且对于任何n < i的日志条目,loga[n]=logb[n]都成立。(这个结论显而易见的可以从日志复制规则中推导出来)

一个新leader被选举出来时,follower可能是上图中的任何一种情况。

(a)(b)可能还没复制到日志
(c)(d)可能曾经是leader,所有包含了多余的日志(这些日志可能被提交了,也可能没提交)
(e)可能是成为leader之后增加了一些日志,但是在commit之前又编程了follower角色,且还没有更新日志条目
(f)可能是在任期2称为了leader并追加了日志但是还没提交就crash了,恢复之后在任期3又成了leader并且又追加了日志

在raft中,通过使用leader的日志覆盖follower的日志的方式来解决出现像上图的情况(强leader)。leader会找到follower和自己想通的最后一个日志条目,将该条目之后的日志全部删除并复制leader上的日志。详细过程如下:

leader维护了每个follower节点下一次要接收的日志的索引,即nextindex
leader选举成功后将所有follower的nextindex设置为自己的最后一个日志条目 1
leader将数据推送给follower,如果follower验证失败(nextindex不匹配),则在下一次推送日志时缩小nextindex,直到nextindex验证通过

上面的方式显然可以通过一些方法进行优化来减少重试的次数,但是在raft论文中对是否有必要进行优化提出了质疑,因为这种异常的情况很少出现。

解读raft(二 选举和日志复制)的相关教程结束。

网站地图