Etcd
Last updated
Last updated
etcd 实际上是一个分布式 kv 存储。搭配一些开源库可以用于服务注册与发现，如 k8s 就使用了 etcd 作为存储并基于它实现了服务注册与发现
用于与客户端交互和底层 raft 模块通信的 etcd-server
用于与集群中其他 etcd 节点通信的 etcd-raft
用于存储日志的 etcd-WAL
用于持久化用户数据的 etcd-storage
用于与客户端交互的 etcd-client
用于模块通信之间的 网络协议
一个请求与一个 etcd 集群的交互主要流程分为两大部分：
写数据到某个 etcd server 中。
该 etcd server 与集群中的其他 etcd 节点进行交互， 当确保数据已经被存储之后应答客户端
请求流程划分为了以下几个子步骤：
1.1：etcd server 收到客户端请求。
1.2：etcd server 将请求发送给本模块的 raft.go，这里负责与 etcd raft 模块进行通信。
1.3：raft.go 将数据封装成 raft 日志的形式提交给 raft 模块。
1.4：raft 模块会首先保存到 raftLog 的 unstable 存储部分。
1.5：raft 模块通过 raft 协议与集群中其他 etcd 节点进行交互。
写入数据的 etcd 是 leader 节点，因为在 raft 协议中，如果提交数据到非leader节点的话需要路由到 etcd leader 节点去。
应答步骤如下：
2.1 ：集群中其他节点向 leader 节点应答接收这条数据库。
2.2：当 leader 节点收到超过半数以上应答接收这条日志数据的节点时，etcd raft 通过 Ready 结构体通知 etcd server 中的 raft 该日志数据已经 commit。
2.3：raft.go 收到 Ready 数据时，首先将这条日志写到 WAL 模块中。
2.4：通知最上层的 etcd server 该日志已经 commit。
2.5：etcd server 调用 applierV3 模块将日志写入持久化存储中。
2.6：etcd server 应答客户端该数据写入成功。
2.7：最后 etcd server 调用 etcd raft，修改其 raftLog 模块的数据，将这条日志写入 raftLog storage 中
etcd：简单易用，不需要集成 sdk，有 watch 机制；需配合第三方工具实现服务发现
zk：功能强大，有 watch 机制，需要在服务中集成 sdk；JAVA 编写
consul：使用 gossip 协议，支持多数据中心；watch 机制是通过定期健康检查机制实现的，并且数据变更后需要客户端自己再拉一遍数据，不够实时
