etcd raft模块解析(一)

分布式一致性

选主算法是保证在2n+1数量的集群中可以保证最多n个节点宕机时依然可以保证服务可用,并且在宕机的服务器启动后可以加入集群继续使用

第一个被共识的算法是Paxos算法,zookeeper就是使用这种算法。但是Paxos算法过于复杂,于是有了raft算法。

raft算法的实现

下面是节点状态的切换图。


状态切换.png
任期Term

初始个节点任期都是一样,并且选出learder后节点们都会统一他们的任期。每个节点也会存储他们同步的日志index

选举使用一个每个节点设置随机的超时时间(Timeout)完成的。首先每个节点与leader进行心跳通信,并且每次通信后都会重置Timeout为值,重新倒计时。
如果Timeout倒计时到0时,则此节点认为leader已下线,开始选举。会把自己的任期号加一 。随机的Timeout应设置为大于心跳间隔一个数量级,已防止因为网络延迟迟到的心跳包让节点认为leader已下线。

开始选举,此节点会先投票给自己,然后给所有其他节点发送请求让他们来选举自己,会带上自己的任期号和最后一条日志index。如果其他节点之前没给任何人投票,并且任期号<=接收请求的任期号,并且日志index>=接到到index,那么他将获得这一票。如果他获得了半数以上的投票则他成为leader。如果没有任何一个节点获得半数投票则开启下一任期选举。

所以这个选举的原理就是看那个节点先感知leader下线,抢在其他节点前发送投票请求取得半数投票。而谁先感知则由每个节点设置的随机Timeout来决定。

因为是靠随机来做的算法,所以在极端情况下会重新几个节点同时发送投票请求,导致活锁的情况,不过连续多次极端情况的几率非常低

这个演示更加明了
http://thesecretlivesofdata.com/raft/
以上只是理论上的算法,实际还有一些特殊的点

下面看一个问题

在选举时是通过任期号和索引index来判断 谁的日志更新 , 谁的任期号大谁的新,同样任期号下谁的索引大谁新 这样会出现一个问题

如表格 t代表时间 一共有a,b,c,d,e五个节点 ,(x,y)代表(任期,数据)


选举流程.png

初始状态t1 a为learder 用其他颜色表示,在t2时接受客户端写入了新的数据,并在同步过程中宕机 只同步了两个节点

  • t3 时e竞选成了learder 因为大多数节点的任期和索引都和他一样新 之后接受了消息但是在写入自己后宕机
  • t4 时a苏醒成了learder 因为他的任期和索引都比大多数新 然后他继续了之前数据的复制 并且复制到了大多数上 这个数据(1,7)应该是有效的
  • t5 e苏醒并成为了learder 因为它最新一条数据的任期是2 然后它复制原来的消息(1,7)就丢失了 。

按理说这个a苏醒后应该是任期3 这样e就不会成为learder 。
这里的根本原因是获取任期要从日志里面最新的一条,因为a苏醒时没收到客户端请求没有新的日志所以其他节点存储的最新任期还是1其实应该是第3任期了。
比如节点d ,已经换了好次的leader了 但是因为这些leader没能写入数据 ,所以他记录的任期却还是1。
为了解决这个问题etcd有了一个限制:

每个节点竞选成learder后,要先同步一条空日志,这样一来大多数节点都能感知任期变动。

PreVote

这是为避免发生无意义选举的一个机制,当learder没挂掉时,因为发生网络分区导致少数服务在一个分区内,他们因为连不上learder会不断的发起选举,任期号不断增加。导致网络分区恢复时他的任期号大于learder,从而发送选举,扰乱集群。

prevote 要求节点在开始选举前,必须先和所有其他节点进行一次通讯,如果超过了半数以上响应才能开始选举。
节点会先进入PreCandidate状态此时不会增加自己的任期号,当他可以和集群半数以上的节点通信时,才能进入Candidate状态开始正式选举
这样网络分区情况下,少数节点的分区不会不断发起选举也不会增加自己的任期号。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,802评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,109评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,683评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,458评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,452评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,505评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,901评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,550评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,763评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,556评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,629评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,330评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,898评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,897评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,140评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,807评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,339评论 2 342

推荐阅读更多精彩内容

  • 寻找一种易于理解的一致性算法(扩展版) 摘要 Raft 是一种为了管理复制日志的一致性算法。它提供了和 Paxos...
    枝叶君阅读 2,625评论 0 15
  • 寻找一种易于理解的一致性算法(扩展版) 摘要 Raft 是一种为了管理复制日志的一致性算法。它提供了和 Paxos...
    yflau阅读 940评论 0 1
  • Raft 是一种为了管理复制日志的一致性算法,该算法强依赖 Leader 节点的可用性来确保集群数据的一致性,即如...
    沧行阅读 1,755评论 3 2
  • 在现实的分布式系统中,不能可能保证集群中的每一台机器都是100%可用可靠的,集群中的任何机器都可能发生宕机、网络连...
    菜刚RyuGou阅读 883评论 0 5
  • 有时候看酷酷的女主电影也是一件很爽的事情,今天小妹要给你们推荐的就是劳模姐的新作《茉莉牌局》。 杰西卡·查斯坦20...
    麻婆电影阅读 256评论 0 0