etcd快速入门

        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)
}
}

原文地址：https://blog.csdn.net/A_Tevens/article/details/143955599

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！