Raft共识算法图二解释

devtools/2024/10/18 14:25:23/

下面是有关Raft协议中不同术语和概念的翻译及解释:

术语和概念:

  • 任期号(term number):用来区分不同的leader。
  • 前一个日志槽位的信息(prelogIndex):这是前一个日志条目的索引(第几个)。
  • 前一个槽位的任期号(prelogTerm):这是前一个日志条目的任期号。
  • 下一个槽位的索引(nextIndex{follow}):应当给特定追随者(follow)发送的下一个日志条目的索引。
  • 快速恢复:特定机制用于解决日志不一致问题。
    • XTerm:在日志不一致时,追随者中与领导者冲突的日志条目对应的任期号。如果追随者在对应位置的任期号不匹配,它会拒绝领导者的AppendEntries消息,并将自己的任期号放在XTerm中。如果在对应位置没有日志,则XTerm为-1。
    • XIndex:在追随者中,对应任期号为XTerm的第一条日志条目的索引。
    • XLen:如果追随者在对应位置没有日志,那么XTerm返回-1,XLen表示空白的日志槽位数。

在这里插入图片描述

State:

  • 持久化数据:需要在服务器重启后依然保持的数据,包括:

    • 当某个服务器刚刚重启,在它加入到Raft集群之前,它必须要检查并确保这些数据有效的存储在它的磁盘上。服务器必须要有某种方式来发现,自己的
      确有一些持久化存储的状态,而不是一些无意义的数据。
    • Log:所有的日志条目。
    • currentTerm:当前任期号。
    • votedFor:当前任期内投票给的候选人。
  • 非持久化数据(适用于所有服务器):

    • commitIndex:已知已提交的最高日志条目的索引(初始化为0,单调增加)。
    • lastApplied:应用于状态机的最高日志条目的索引(初始化为0,单调增加)。
  • 非持久化数据(仅适用于领导者)(选举后重新初始化):

    • nextIndex[]:对于每个服务器,下一个需要发送的日志条目的索引(初始化为领导者的最后一个日志条目索引+1)。
    • matchIndex[]:对于每个服务器,已知在该服务器上复制的最高日志条目的索引(初始化为0,单调增加)。
      在这里插入图片描述

Rules for Servers:

  • All Servers:所有服务器的共通行为规则。

    • 如果 commitIndex > lastAppliedlastApplied 自增,应用 log[lastApplied] 到状态机(§5.3)
    • 如果 RPC 请求或响应包含任期 T 大于 currentTerm:设置 currentTerm = T,转变为追随者(§5.1)
  • Followers:追随者的特定行为规则。

    • 对来自候选人和领导者的 RPC 做出响应
    • 如果在没有收到当前领导者的 AppendEntries RPC 或未向候选人授予投票的情况下,选举超时过期:转变为候选人
  • Candidates:候选人的特定行为规则。

    • 转变为候选人时,开始选举:
      • 增加 currentTerm
      • 为自己投票
      • 重置选举计时器
      • 向所有其他服务器发送 RequestVote RPC
      • 如果从大多数服务器收到投票:成为领导者
      • 如果收到新领导者的 AppendEntries RPC:转变为追随者
      • 如果选举超时过期:开始新的选举
  • Leaders:领导者的特定行为规则。

    • 选举成功后:向每个服务器发送初始的空 AppendEntries RPC(心跳),在空闲期间重复以防止选举超时(§5.2)
    • 如果从客户端收到命令:将条目追加到本地日志,条目应用到状态机后回应(§5.3)
    • 如果最后的日志索引 ≥ 追随者的 nextIndex:从 nextIndex 开始发送 AppendEntries RPC
    • 如果成功:更新追随者的 nextIndex 和 matchIndex(§5.3)
    • 如果因日志不一致导致 AppendEntries 失败:减少 nextIndex 并重试(§5.3)
    • 如果存在一个 N,使得 N > commitIndex,大多数 matchIndex[i] ≥ N,且 log[N].term == currentTerm:设置 commitIndex = N(§5.3, §5.4)。

在这里插入图片描述

AppendEntries RPC

目的:由领导者调用以复制日志条目,同时也作为心跳信号,以维持权威并防止超时。

参数:
  • term(任期号):领导者的当前任期。
  • leaderId(领导者ID):领导者的标识符,使得追随者可以在必要时重定向客户端。
  • prevLogIndex(前一个日志索引):紧接在新条目之前的日志条目的索引。
  • prevLogTerm(前一个日志条目的任期):与 prevLogIndex 对应的日志条目的任期。
  • entries[](日志条目数组):要存储的日志条目(心跳时为空;为了效率可能发送多个)。
  • leaderCommit(领导者的提交索引):领导者的 commitIndex
结果:
  • term(当前任期):用于领导者更新自己的任期。
  • success(成功标志):如果追随者包含与 prevLogIndexprevLogTerm 匹配的条目,则为真。
接收者实现:
  1. 如果 term < currentTerm,回复假(§5.1)
  2. 如果日志中不存在在 prevLogIndex 位置且任期与 prevLogTerm 匹配的条目,回复假(§5.3)
  3. 如果现有条目与新条目发生冲突(索引相同但任期不同),删除现有条目及其后所有条目(§5.3)
  4. 将任何未在日志中的新条目追加到日志中
  5. 如果 leaderCommit > commitIndex,将 commitIndex 设置为 leaderCommit 与最后一个新条目的索引中的较小者
    在这里插入图片描述

RequestVote RPC

目的:由候选者调用,用于在选举中收集选票。

参数:
  • term(任期号):候选者的当前任期。
  • candidateId(候选者ID):请求投票的候选者的标识符。
  • lastLogIndex(最后日志条目的索引):候选者最后一个日志条目的索引(§5.4)。
  • lastLogTerm(最后日志条目的任期):候选者最后一个日志条目的任期(§5.4)。
结果:
  • term(当前任期):用于候选者更新自己的任期。
  • voteGranted(授予选票):如果候选者收到了选票,则为真。
接收者实现:
  1. 如果 term < currentTerm,回复假(§5.1)
  2. 如果 votedFor 为空或等于 candidateId,并且候选者的日志至少与接收者的日志一样新,授予选票(§5.2, §5.4)
要求:
  • 具体来说,您应该仅在以下情况下重新启动选举计时器:
    • a) 您AppendEntries当前领导者处获得 RPC(即,如果参数中的术语AppendEntries已过时,则不应重置计时器);
    • b) 您正在开始选举;
    • c) 您向另一个同行授予投票权。
  • 请按照图 2 的指示了解何时开始选举。特别要注意的是,如果您是候选人(即您当前正在进行选举),但选举计时器触发,您应该开始另一次选举。这对于避免由于 RPC 延迟或丢失而导致系统停顿非常重要。
  • 以下是我们一遍又一遍地看到的一些内容,您应该在实施中留意:
    • 如果某个步骤显示“回复错误”,则意味着您应该立即回复,而不是执行任何后续步骤。
    • 如果您收到一个AppendEntriesRPC,其 prevLogIndex指向日志末尾之外,您应该像确实有该条目但术语不匹配一样处理它(即回复 false)。
    • 即使领导者没有发送任何条目,也AppendEntries应该执行 RPC 处理程序的检查 2 。
    • min最后一步(#5)中的是AppendEntries必要,并且需要使用最后一个条目的索引来计算。仅仅拥有应用日志中的内容并在到达日志末尾时停止的函数是不够的。这是因为在领导者发送给您的条目(全部与您的日志中的条目匹配)之后,您的日志中可能有与领导者日志不同的条目。因为#3 规定只有在存在冲突条目时才截断日志,这些条目不会被删除,并且如果 超出领导发送给您的条目,您可能会应用不正确的条目。lastApplied``commitIndex``leaderCommit
    • 严格按照第 5.4 节中的描述实施“最新日志”检查非常重要。没有作弊,只是检查长度!

http://www.ppmy.cn/devtools/36369.html

相关文章

后端如何处理接口的重复调用

首先是&#xff0c;原理在请求接口之前&#xff0c;使用过滤器拦截数据&#xff0c;来进行判断两次数据是否一致。 1.自定义注解 2.创建一个Handler处理器 3.RepeatSubmitInterceptor的实现类 4.过滤器的配置

翻译《The Old New Thing》- Does Windows have a limit of 2000 threads per process?

Does Windows have a limit of 2000 threads per process? - The Old New Thing (microsoft.com)https://devblogs.microsoft.com/oldnewthing/20050729-14/?p34773 Raymond Chen 2005年07月29日 Windows 是否有一个每个进程2000线程的限制&#xff1f; 简要 文章解释了在 W…

LeetCode 226.翻转二叉树

题目描述 给你一棵二叉树的根节点 root &#xff0c;翻转这棵二叉树&#xff0c;并返回其根节点。 示例 1&#xff1a; 输入&#xff1a;root [4,2,7,1,3,6,9] 输出&#xff1a;[4,7,2,9,6,3,1]示例 2&#xff1a; 输入&#xff1a;root [2,1,3] 输出&#xff1a;[2,3,1]示例…

VBA快速删除Excel工作表

Excel处理数据时,经常需要删除部分工作表,像这样 工作中一个工作薄中十几张甚至几十张工作表是常有的事,手动一张张去删,费时费力,VBA代码可以帮你快速搞定,这就需要非常简单的代码 。 1、如果只留下一张名为“Sheet1”的工作表,其余的全删除,代码如下: For Each She…

fero - yolo - mamba:基于选择性状态空间的面部表情检测与分类

fero - yolo - mamba:基于选择性状态空间的面部表情检测与分类 摘要IntroductionRelated work FER-YOLO-Mamba: Facial Expression Detection and Classification Based on Selective State Space 摘要 面部表情识别&#xff08;FER&#xff09;在理解人类情绪线索方面起着关键…

免备案香港主机会影响网站收录?

免备案香港主机会影响网站收录?前几天遇到一个做电子商务的朋友说到这个使用免备案香港主机的完整会不会影响网站的收录问题&#xff0c;这个问题也是站长关注较多的问题之一。小编查阅了百度官方规则说明&#xff0c;应该属于比较全面的。下面小编给大家介绍一下使用免备案香…

每日OJ题_贪心算法三③_力扣45. 跳跃游戏 II(dp解法+贪心解法)

目录 力扣45. 跳跃游戏 II 解析代码1_动态规划 解析代码2_贪心 力扣45. 跳跃游戏 II 45. 跳跃游戏 II 难度 中等 给定一个长度为 n 的 0 索引整数数组 nums。初始位置为 nums[0]。 每个元素 nums[i] 表示从索引 i 向前跳转的最大长度。换句话说&#xff0c;如果你在 num…

Autodesk AutoCAD 2025 for Mac:强大的二维三维绘图工具

Autodesk AutoCAD 2025 for Mac是一款专为Mac用户打造的计算机辅助设计软件&#xff0c;它在继承了AutoCAD系列软件的优秀传统的基础上&#xff0c;针对Mac系统进行了全面优化&#xff0c;为用户提供了更出色的绘图和设计体验。 这款软件不仅支持用户创建和编辑复杂的二维几何图…