etcd 与 Consul 的一致性读对比

电梯物联网专家 2024-01-11 09:41:40  51109 赞同 0 反对 0

分类：资源

etcd 和 Consul 是现在比较流行的分布式一致性 KV 存储，本文就来分享和对比一下这两个存储的一致性读的实现。

Consul 一致性读的实现

Consul 有三种读模式：

default
consistent
stale

其中 stale 是非一致性的读模式，而 default 和 consistent 是一致性的。

consistent 和 default 的区别在于 consistent 在读之前还会向各个节点确认自己是否还是 Leader，以防止在读之前的一瞬间变为 Follower，导致读取到旧值。

接下来我们看看具体实现的代码：

在 Get 方法的一开始 Consul 就调用了 ForwardRPC 方法来转发 RPC 请求，如果转发请求成功就直接返回。

如果转发请求没完成，就会取调用 blockingQuery 来查询本地的存储返回结果。

我们再来看一下 ForwardRPC 内部的实现。

可以看到 ForwardRPC 方法内部主要做了三件事情：

如果需要，转发请求给其他 DC
判断当前节点是否能处理这个读请求
如果不能处理，转发请求给 Leader

我们再来看看第 2 步 Consul 是如何判断的。

其中 info.IsRead 用来判断是不是一个读请求，info.AllowStaleRead 判断 HTTP 请求参数中的 AllowStale，为 false 时即为一致性的读请求，而最后判断是否已经跟 Leader 交互过。

所以当一个请求是一致性读请求时就会走到第 3 步将请求转发到 Leader 上。

而在转发 Leader 时会判断自身是不是 Leader，如果不是才会转发。

小结

从这几段逻辑可以看出，Consul 的一致性读是通过转发读请求给 Leader 来实现的。

etcd 一致性读的实现

etcd 的读分为串行读（Serialize）和线性读（Linearizable）两种模式。其中线性读是一致性的读模式。

同样的我们来看下一致性读的实现：

可以看到串行读和线性读的区别只是在串行读之前调用了 linearizableReadNotify 方法。

而 linearizableReadNotify 中也只是简单的给 s.readwaitc 发信号然后等待结果。

这个信号将会在 linearizableReadLoop 方法中处理。

可以看到 linearizableReadLoop 方法中通过 requestCurrentIndex 方法获得了一个叫做 confirmedIndex 的 index。

requestCurrentIndex 会向 Leader 节点发送 MsgReadIndex 消息，以获取 Leader 节点当前提交的最新的 index。然后再用本地的 appliedIndex 和 confirmedIndex 进行对比，如果本地已应用的 index 小于 confirmedIndex 则进行等待，直到追上 confirmedIndex 才会调用 nr.notify 发送通知信号解除 linearizableReadNotify 的等待进行后续的串行读操作。

也就是说 etcd 在做一致性读时，会先从 Leader 节点获取 Leader 节点当前最新的 commited index，然后和本地的 applied index 进行对比，等到本地应用的日志追上 Leader 时，才进行后续的串行读操作。

总结

从实现上来说 Consul 的一致性读的实现更加简单直接，但是可能会对 Leader 节点的性能造成一些影响。

而相对来说 etcd 的实现更加复杂但是讨巧，也充分利用到了每个节点的资源。

更多技术文章，请访问：https://opensource.actionsky.com/

关于 SQLE

SQLE 是一款全方位的 SQL 质量管理平台，覆盖开发至生产环境的 SQL 审核和管理。支持主流的开源、商业、国产数据库，为开发和运维提供流程自动化能力，提升上线效率，提高数据质量。

SQLE 获取

类型	地址
版本库	https://github.com/actiontech/sqle
文档	https://actiontech.github.io/sqle-docs/
发布信息	https://github.com/actiontech/sqle/releases
数据审核插件开发文档	https://actiontech.github.io/sqle-docs/docs/dev-manual/plugins/howtouse

如果您发现该资源为电子书等存在侵权的资源或对该资源描述不正确等，可点击“私信”按钮向作者进行反馈；如作者无回复可进行平台仲裁，我们会在第一时间进行处理！

评价 0 条

相关资源

如何在Python中进行数据可靠性存储和迁移，以及数据一致性的保证和校验 2024-01-07 51497 浏览
引言：数据的安全性和一致性对于任何应用程序都至关重要。在Python中，我们可以使用一些技术和库来确保数据的可靠性存储和迁移，以及数据一致性的保证和校验。本文将介绍几种常用的方法，并提供代码示例。
MySQL Mysqldump 一致性备份与大数据库备份与 PG MYSQL 到底谁是NO.1 2024-01-09 52924 浏览
作为一个技术人员，不是对自己的技术有要求，而是成天的讨论 PG 第一还是 MYSQL 第一，我不觉得是光彩的事情，这只能说明一件事情，你无能，提出这个问题的人，很可能在技术上是 physically challenged individual. 你在问这个问题的时候，其实你在告诉别人，这两个数据库你必然有一个你不会，不管是PG 或是 MYSQL 。为什么不能提高自己，两个都会呢？我想那时的你，不会在提出这样问题，因为你有自信，告诉任何人，”Who cares about which one is NO.1? I can operate both of them.” That’s all.
一致性哈希：数据分片与负载均衡的黄金法则 2024-01-06 51791 浏览
在分布式系统中，一致性哈希（Consistent Hashing）是一项关键算法，为解决数据分片和负载均衡难题提供了强大的支持。本文将深入研究一致性哈希的核心原理，解析其如何超越传统哈希算法，同时详细探讨一个关键问题：当节点发生问题时，数据是如何被处理的。
一致性（Consistency） 2023-12-28 49609 浏览
要理解一致性，这里有个例子，假设我们在构建一个分布式存储系统，并且这是一个KV服务。这个KV服务只支持两种操作，其中一个是put操作会将一个value存入一个key；另一个是get操作会取出key对应的value。
一致性就是用来定义操作行为的概念。 2023-12-28 50536 浏览
之所以一致性是分布式系统中一个有趣的话题，是因为，从性能和容错的角度来说，我们通常会有多个副本。在一个非分布式系统中，你通常只有一个服务器，一个表单。
Java多线程——CPU缓存原理和缓存一致性问题 2023-12-30 51709 浏览
说起Java中的多线程，就不得不说volatile关键词 volatile关键词执行修饰变量和实例变量，不能修饰方法参数，局部变量和实例常量。
探索如何实现MySQL与Redis间的一致性（如何实现数据库和redis一致） 2024-01-10 49691 浏览
MySQL与Redis在现今的Web应用中非常的常用，很多时候，当数据发生更改的时候，常常需要同步到这两种数据库中，以确保数据的一致性。但是，怎样才能实现MySQL与Redis间的一致性呢？
分布式事务及其一致性协议 2023-12-30 52171 浏览
一：什么是事务。事务是由一系列对系统中的数据进行访问和更新的操作所组成的一个程序执行逻辑单元。狭义上的事务指的就是数据库的事务。
Linux & Windows双系统时间不一致解决方案 2024-01-08 50193 浏览
Windows操作系统直接把CMOS时间认定为当前显示时间，不根据时区转换。这样每调整一次系统时区，系统会根据调整的时区来计算当前时间，确定后，也就同时修改了CMOS内的时间（即每调整一次时区，设置保存后，CMOS时间也将被操作系统改变一次，注意不同操作系统调整时间后，也会同时改变CMOS时间，这一点是共通的） LINUX的时间和时区 Linux和苹果操作系统以当前主板CMOS内时间做为格林威治标准时间，再根据系统设置的时区来最终确定当前系统时间（如时区设置为GMT+08:00北京时间时以及当前CMOS时间为03:00，那么系统会将两个时间相加得出显示在桌面的当前系统时间为11:00）。
统信操作系统V20系统时间与实际时间不一致 2024-03-06 51155 浏览
统信操作系统V20系统时间与实际时间不一致