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 机制实时监测数据变化。

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: 恋水无意