保证数据的一致性有两种情况,一种是
重新选取出新leader后的数据同步
,还有一种是
leader处理完事务请求后与follow保持数据一致
。
首先是重新选取出新leader后的数据同步,
通过FastLeaderElection选举算法选出leader,选出leader之后,leader需要与其他节点进行同步,当超过一半的follow与leader进行同步完成后,leader才能成为真正的leader,然后follow会带上自己最大的ZXID尝试与leader连接,来确定数据是否同步。
其次是leader处理完事务请求后与follow保持数据一致。
事务请求全部是由leader处理的,当leader收到请求后,会将事务请求转化为事务Proposal,由于leader会为每一个follow创建一个队列,所以leader会将事务放入响应队列中,按顺序处理事务请求,来保证事务的顺序性。之后会在队列中顺序向其他节点广播该提案。follow收到后会将其以事务的形式写入到本地日志中,并向leader发送反馈ack,leader会等待其他follow的回复,当收到一半以上的follow响应时,leader会向其他节点发送commit消息,同时leader提交该提案。当follow将数据同步完成之后,leader会将该follow加入到真正可用的follow列表中。
版权声明:本文为m0_51697147原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。