ETCD

简介

Etcd 是一个开源的分布式键值存储系统，用于可靠地存储和检索数据。它由 CoreOS 开发并开源，现在由云原生计算基金会（CNCF）维护。Etcd 是一个高可用、一致性、分布式的系统，被广泛用于构建分布式系统、服务发现、配置管理和分布式协调等场景。

Etcd 提供了一个简单的键值存储接口，类似于一个分布式的字典或配置文件。它支持基本的 CRUD 操作（创建、读取、更新和删除），并支持事务操作。每个键值对都由一个唯一的键来标识，并且可以使用目录结构来组织和管理键值对。

特点

Etcd 的主要特点和功能如下：

分布式一致性：Etcd 使用 Raft 一致性算法来确保在集群中的不同节点之间的数据强一致性。Raft 算法提供了强一致性保证，并且可以在节点故障或网络分区的情况下保持数据一致性。
高可用性：Etcd 架构设计为具有高可用性。通过将数据复制到多个节点，并选择具有最新数据的节点进行读取和写入操作，即使在节点故障的情况下，Etcd 仍然可以继续提供服务。
分布式事务支持：Etcd 支持事务操作，可以将多个读取和写入操作组合成一个原子的、不可分割的操作。这确保了在一个事务中的所有操作要么全部成功，要么全部失败。
监视和通知机制：Etcd 提供了监视和通知机制，允许应用程序订阅指定键的更改事件。当键的值发生变化时，Etcd 可以通知订阅了相关事件的应用程序，使得应用程序可以实时感知和响应数据的变化。
安全性：Etcd 支持基于 TLS 的加密通信，并提供身份验证和访问控制机制，确保数据在传输和存储过程中的安全性。

Etcd 被广泛应用于云原生领域，特别是在容器编排系统（如 Kubernetes）中用于服务发现、配置管理和集群协调等关键功能。它提供了一个可靠的基础设施，用于构建分布式系统，并保证数据的一致性和高可用性

数据结构

键值对（Key-Value）：Etcd 的最基本的数据结构是键值对。每个键都是一个字符串，可以使用目录结构来组织和管理键。对应于每个键，可以存储一个关联的值，值可以是任意字符串。
目录（Directory）：Etcd 允许创建目录结构来组织键值对。目录是一种特殊的键，它本身没有关联的值，而是包含了一组子键。通过目录结构，可以以层次结构方式组织和管理键值对，提供更灵活的数据组织方式。
序列（Sequence）：Etcd 提供了序列机制，用于生成自增的整数序列。可以通过创建一个序列键，并使用 Get 操作获取序列的当前值。每次获取序列值后，序列的值会自动递增。
租约（Lease）：Etcd 支持租约机制，用于为键值对设置过期时间。租约是一种时间期限，可以与键值对关联。当租约过期时，对应的键值对将自动被删除。通过租约，可以实现基于时间的数据过期和自动清理。
监视（Watch）：Etcd 提供了监视机制，可以订阅指定键的变化事件。当指定的键发生变化时，Etcd 将发送通知给订阅者。监视机制可用于实时感知和响应数据的变化，用于构建事件驱动的应用程序。

这些数据结构提供了丰富的功能和灵活性，可以根据需求来组织和管理数据。通过键值对、目录、序列和租约，可以构建各种类型的分布式系统，实现服务发现、配置管理、分布式锁等功能。监视机制则提供了实时的数据变化通知，用于构建响应式的应用程序。

主要操作

增删改查

Put：将一个键值对写入到 Etcd 中。通过指定键和相应的值来创建或更新一个键值对。如果键已经存在，则会更新对应的值。
Get：根据给定的键从 Etcd 中检索相应的值。可以使用精确匹配的键获取单个键值对，也可以使用前缀匹配的键获取一组键值对。
Delete：根据给定的键从 Etcd 中删除相应的键值对。可以使用精确匹配的键删除单个键值对，也可以使用前缀匹配的键删除一组键值对。
Watch：监视给定键的变化，并在变化发生时接收通知。可以订阅特定键的变更事件，例如创建、更新或删除操作。当指定的键发生变化时，Etcd 将发送通知给订阅者。
Lease：Etcd 提供了租约机制，用于为键值对设置过期时间。可以创建一个租约并将其与键值对关联，当租约过期时，键值对将自动被删除。
Transaction：Etcd 支持事务操作，可以将多个读取和写入操作组合成一个原子的、不可分割的操作。事务操作可以保证在一个事务中的所有操作要么全部成功，要么全部失败。
Compact：Etcd 支持紧凑操作，用于清理过期的键值对并释放底层存储空间。紧凑操作可以减小存储空间的使用，并提高 Etcd 的性能。

demo

当使用 Etcd 时，可以使用 Etcd 的客户端库或 Etcd 提供的命令行工具来执行操作。下面是一些示例操作的代码片段，使用的是 Etcd 的 Go 客户端库（go-etcd）：

安装 go-etcd 客户端库：

go get github.com/coreos/go-etcd/etcd

导入所需的包：

import (
    "github.com/coreos/go-etcd/etcd"
    "fmt"
)

连接到 Etcd 服务器：

client := etcd.NewClient([]string{"http://localhost:2379"})

这里假设 Etcd 服务器运行在本地，监听在默认端口 2379。

写入键值对：

client.Set("/mykey", "myvalue", 0)

将键 /mykey 的值设置为 myvalue。

读取键值对：

response, err := client.Get("/mykey", false, false)
if err != nil {
    fmt.Println(err)
} else {
    if len(response.Node.Nodes) == 0 {
        fmt.Println("Key not found")
    } else {
        fmt.Println(response.Node.Nodes[0].Value)
    }
}

获取键 /mykey 的值，并打印输出。

监视键的变化：

watcher := client.Watch("/mykey", 0, false)
for {
    select {
    case response := <-watcher.Event:
        fmt.Println(response.Node.Value)
    }
}

监听键 /mykey 的变化，并在变化发生时打印输出。

删除键值对：

_, err := client.Delete("/mykey", false)
if err != nil {
    fmt.Println(err)
} else {
    fmt.Println("Key deleted")
}

删除键 /mykey。

xiaxichen's blog