当前位置: 首页 > article >正文

【ETCD】ETCD 的一致性读(Linearizable Read)流程解析

ETCD中一致性读的主要流程如下所示
在这里插入图片描述

ETCD 的一致性读(Linearizable Read)流程分为以下几个步骤:

目录

      • 1. 客户端发送请求
      • 2. 请求追踪和阻塞等待 Raft 响应
      • **3. 请求 ReadIndex**
      • **4. Leader 确认自己状态**
      • **5. Leader 返回 ReadIndex**
      • **6. Follower 响应 ReadIndex**
      • **7. 等待 ReadIndex 应用到 MVCC**
      • **8. 向 MVCC 发送查询请求**
      • **9. MVCC 计算并返回结果**
      • **10. 返回响应给客户端**
      • **总结:关键点**

1. 客户端发送请求

  • 步骤 1:客户端向 ETCD 服务器(etcd gRPC server)发送一个范围查询(Range Request)。

2. 请求追踪和阻塞等待 Raft 响应

  • 步骤 2:ETCD 服务器创建一个唯一的 Request ID 用于跟踪当前请求,并阻塞请求直到 Raft 模块给出响应。

3. 请求 ReadIndex

  • 步骤 3:Follower 节点向 Leader 节点请求最新的 ReadIndex(Leader 的已提交索引)。

4. Leader 确认自己状态

  • 步骤 4:Leader 节点通过发送 心跳(Heartbeat) 向 Follower 确认自己的领导身份并维持集群共识(quorum)。Follower 会向 Leader 返回心跳响应,确认 Leader 身份有效。

5. Leader 返回 ReadIndex

  • 步骤 5:Leader 节点将自己的最新 已提交索引(committedIndex) 作为 ReadIndex 发送给请求的 Follower 节点。

6. Follower 响应 ReadIndex

  • 步骤 6:Follower 节点接收到 Leader 返回的 ReadIndex 后,将其与本地已提交的条目进行比较,并返回一个阻塞的通道,直到本地节点的已提交条目与 Leader 的 ReadIndex 保持一致。

7. 等待 ReadIndex 应用到 MVCC

  • 步骤 7:ETCD 服务器等待所有已提交的日志条目都被应用到本地的 MVCC(多版本并发控制存储层)。

8. 向 MVCC 发送查询请求

  • 步骤 8:ETCD 服务器向 MVCC 存储层请求与客户端范围查询对应的键值数据。

9. MVCC 计算并返回结果

  • 步骤 9:MVCC 模块根据最新的 ReadIndex 数据计算出结果(确保数据是最新的),然后将查询结果返回给 ETCD 服务器。

10. 返回响应给客户端

  • 步骤 10:ETCD 服务器将结果通过 gRPC 接口返回给客户端,完成一致性读请求。

总结:关键点

  1. ReadIndex 机制:通过 Leader 返回的 ReadIndex 确保数据读取的一致性,Follower 必须等待自己的状态与 Leader 的状态同步。
  2. Raft 共识:Leader 和 Follower 通过心跳确认领导身份并维持集群一致性。
  3. MVCC 存储:最终的数据查询和读取由 MVCC 处理,确保返回的是最新的、正确的键值数据。
  4. 阻塞机制:ETCD 服务器会阻塞客户端请求,直到本地节点的已提交状态与 Leader 保持一致。

这种机制保证了 ETCD 在分布式环境下提供 线性一致性(Linearizable) 的读取操作。


http://www.kler.cn/a/442692.html

相关文章:

  • Open FPV VTX开源之betaflight配置
  • 计算机的错误计算(二百一十一)
  • 基于python的网页表格数据下载--转excel
  • Python爬虫-汽车之家各车系周销量榜数据
  • 对比学习 (Contrastive Learning) 算法详解与PyTorch实现
  • python 寻找数据拐点
  • nexus5x安卓root
  • 队列的原理及应用
  • Git安装详解(写吐了,看完不后悔)
  • 9_less教程 --[CSS预处理]
  • 代码生成器
  • 架构实践04-高扩展架构模式
  • node.js的简单示例
  • 0101多级nginx代理websocket配置-nginx-web服务器
  • ElasticSearch系列:利用runtime field实现日期字符串实现日期范围查询
  • 使用Idea自带的git功能进行分支合并
  • 爬虫数据能用于商业吗?
  • linux下的单例安全的线程池实现
  • Android 之永乐大典
  • redis 缓存使用
  • uniapp打包apk允许横屏竖屏内容翻转
  • 【计算机网络2】计算机网络的性能能指标
  • 深入解析 `DataFrame.groupby` 和 `agg` 的用法及使用场景
  • VScode MAC按任意键关闭终端 想要访问桌面文件
  • Unity3D Shader变体自定义组合压缩方案详解
  • Next.js搜索引擎优化:如何利用React和Next.js解决SEO问题