当前位置：首页 > article >正文

etcd快速入门

article 2024/11/27 4:51:46

ETCD（全称“etc daemon”）是一个分布式键值存储，常用于配置管理、服务发现和领导者选举，特别在云原生应用中使用广泛。它使用Raft一致性算法确保分布式系统的一致性。ETCD通过提供API存储、检索和监视键值对的变化，广泛应用于Kubernetes等容器化平台，具有高可靠性、可扩展性和容错性。

1. 键值存储：

client, err := clientv3.New(clientv3.Config{
    Endpoints: []string{"localhost:2379"},
})
if err != nil {
    log.Fatal(err)
}
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()

// 设置键值对
_, err = client.Put(ctx, "foo", "bar")
if err != nil {
    log.Fatal(err)
}

// 获取键值对
resp, err := client.Get(ctx, "foo")
if err != nil {
    log.Fatal(err)
}
fmt.Println(resp.Kvs)

2. 事务支持：

txn := client.Txn(ctx)
resp := txn.If(
    clientv3.Compare(clientv3.Version("foo"), "=", 0),
).Then(
    clientv3.OpPut("foo", "bar"),
).Else(
    clientv3.OpGet("foo"),
)
txnResp, err := resp.Commit()
if err != nil {
    log.Fatal(err)
}
fmt.Println(txnResp)

3. 监控与通知：

watchChan := client.Watch(context.Background(), "foo")
for wresp := range watchChan {
    for _, ev := range wresp.Events {
        fmt.Printf("Type: %s Key: %s Value: %s\n", ev.Type, ev.Kv.Key, ev.Kv.Value)
    }
}

4. 分布式锁：

leaseResp, err := client.Grant(context.Background(), 10) // 10 seconds lease
if err != nil {
    log.Fatal(err)
}

lock := clientv3.NewMutex(client, "lock-key")
if err := lock.Lock(context.Background()); err != nil {
    log.Fatal(err)
}
fmt.Println("Lock acquired")

// Do work
time.Sleep(5 * time.Second)

if err := lock.Unlock(context.Background()); err != nil {
    log.Fatal(err)
}
fmt.Println("Lock released")

完整demo:

package main

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

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

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

	// 将一个键值对存储到 etcd 中
	_, err = client.Put(context.Background(), "foo", "bar")
	if err != nil {
		log.Fatal(err)
	}

	// 从 etcd 中获取值
	resp, err := client.Get(context.Background(), "foo")
	if err != nil {
		log.Fatal(err)
	}

	// 输出键值对
	for _, kv := range resp.Kvs {
		fmt.Printf("%s : %s\n", kv.Key, kv.Value)
	}
}