ETCD in go

ETCD简介
Golang 使用 ETCD 示例

ETCD简介

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

ETCD 的主要特点包括：

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

Golang 使用 ETCD 示例

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

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': %s\n", key, getResp.Kvs[0].Value)
	} else {
		fmt.Printf("Key '%s' not found\n", 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: %s\n", 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)进行许可，使用时请注明出处。
Author: mengbin
blog: mengbin
Github: mengbin92
cnblogs: 恋水无意