每日一库：ETCD in go

ETCD简介

ETCD 是一个开源的、高可用的键值存储系统，它被广泛用于配置管理和服务发现。ETCD 使用 Raft 算法来保证数据的强一致性和高可用性。它是 Kubernetes 集群的核心组件之一，用于存储集群配置和状态信息。

ETCD 的主要特点包括：

1.分布式存储：ETCD 支持将数据分布在多个节点上，以实现高可用性和扩展性。2.强一致性：ETCD 使用 Raft 算法来确保数据的一致性，即使在节点故障的情况下也能保持数据的正确性。3.键值存储：ETCD 将数据以键值对的形式存储，可以存储任意类型的数据。4.Watch 机制：ETCD 提供了 Watch 机制，允许应用程序监听数据的变化，从而实现实时通知。5.HTTP gRPC 接口：ETCD 提供了 HTTP 和 gRPC 接口，方便各种编程语言与 ETCD 进行交互。6.事务支持：ETCD 支持基于事务的操作，保证数据的一致性和完整性。

Golang 使用 ETCD 示例

以下是一个使用 Golang 访问 ETCD 的简单示例。在此示例中，我们将展示如何连接到 ETCD，设置键值对，获取键值对，以及使用 Watch 机制实时监测数据变化。

代码语言：javascript复制

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "go.etcd.io/etcd/client/v3"
)

func main() {
    // 创建 ETCD 客户端连接
    cfg := client.Config{
        Endpoints:   []string{"http://localhost:2379"}, // ETCD 地址
        DialTimeout: 5 * time.Second,
    }
    client, err := client.New(cfg)
    if err != nil {
        log.Fatal(err)
    }
    defer client.Close()

    // 创建 KV 客户端
    kv := clientv3.NewKV(client)

    // 设置键值对
    key := "example_key"
    value := "example_value"
    _, err = kv.Put(context.Background(), key, value)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Key '%s' set to '%s'n", key, value)

    // 获取键值对
    getResp, err := kv.Get(context.Background(), key)
    if err != nil {
        log.Fatal(err)
    }
    if len(getResp.Kvs) > 0 {
        fmt.Printf("Value for key '%s': %sn", key, getResp.Kvs[0].Value)
    } else {
        fmt.Printf("Key '%s' not foundn", key)
    }

    // 使用 Watch 机制实时监测数据变化
    watcher := clientv3.NewWatcher(client)
    watchChan := watcher.Watch(context.Background(), key)
    fmt.Println("Waiting for changes...")
    for resp := range watchChan {
        for _, event := range resp.Events {
            fmt.Printf("Event type: %s, Key: %s, Value: %sn", event.Type, event.Kv.Key, event.Kv.Value)
        }
    }
}

在这个示例中，我们使用 go.etcd.io/etcd/client/v3 包连接到 ETCD，并进行了一些基本的操作，包括设置键值对、获取键值对以及使用 Watch 机制监听数据变化。请确保将 http://localhost:2379 替换为你实际的 ETCD 地址。

声明：本作品采用署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)[1]进行许可，使用时请注明出处。 Author: mengbin[2] blog: mengbin[3] Github: mengbin92[4] cnblogs: 恋水无意[5]

References

[1] 署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0): https://creativecommons.org/licenses/by-nc-sa/4.0/deed.zh [2] mengbin: mengbin1992@outlook.com [3] mengbin: https://mengbin.top [4] mengbin92: https://mengbin92.github.io/ [5] 恋水无意: https://www.cnblogs.com/lianshuiwuyi/

存储 etcd 连接数据算法

1 人点赞