clientv3-master.zip

**etcd clientv3 使用详解** `etcd` 是一个分布式的、一致性的键值存储系统，常用于服务发现、配置共享以及分布式锁等场景。它基于 Google 的 Chubby 实现，采用开源的 Go 语言编写，具有高性能、高可用性、简单易用的特点。在 Go 语言中，`clientv3` 是官方提供的最新版本客户端，提供了丰富的功能和高效的操作接口。 ### 1. 安装与引入 你需要在你的项目中引入 `etcd/clientv3` 包。可以通过 `go get` 命令来安装： ```bash go get -u go.etcd.io/etcd/clientv3 ``` 然后，在你的代码中导入： ```go import "go.etcd.io/etcd/clientv3" ``` ### 2. 连接 etcd 要连接到 etcd 集群，你需要创建一个 `clientv3.Config` 结构体实例，并设置端点（endpoints）等配置。例如： ```go config := clientv3.Config{ Endpoints: []string{"http://localhost:2379", "http://localhost:22379", "http://localhost:32379"}, DialTimeout: 5 * time.Second, } // 创建客户端实例 client, err := clientv3.New(config) if err != nil { panic(err) } defer client.Close() ``` ### 3. CRUD 操作 #### 创建（Create） 使用 `clientv3.Put` 函数可以创建或更新键值对： ```go resp, err := client.Put(context.Background(), "key", "value") if err != nil { panic(err) } fmt.Println("Put response:", resp) ``` #### 读取（Get） 使用 `clientv3.Get` 函数可以获取键的值： ```go resp, err := client.Get(context.Background(), "key") if err != nil { panic(err) } for _, ev := range resp.Kvs { fmt.Printf("%s : %s\n", ev.Key, ev.Value) } ``` #### 更新（Update） 使用 `clientv3.CompareAndSwap` 或 `clientv3.Put` 可以更新键值： ```go _, err = client.Put(context.Background(), "key", "new_value") if err != nil { panic(err) } ``` #### 删除（Delete） 使用 `clientv3.Delete` 函数可以删除键： ```go resp, err := client.Delete(context.Background(), "key") if err != nil { panic(err) } fmt.Println("Delete response:", resp) ``` ### 4. 事件监听与监视 `clientv3.Watch` 提供了实时监听 etcd 中键值变化的功能： ```go ch := client.Watch(context.Background(), "key") for resp := range ch { for _, ev := range resp.Events { switch ev.Type { case mvccpb.PUT: fmt.Printf("Put event: %s : %s\n", ev.Kv.Key, ev.Kv.Value) case mvccpb.DELETE: fmt.Println("Key deleted:", ev.Kv.Key) } } } ``` ### 5. 分布式锁 `clientv3.Lock` 和 `clientv3.Unlock` 可以实现跨进程的互斥锁： ```go lock := clientv3.NewLock(client, "my-lock") err = lock.Lock(context.Background()) if err != nil { panic(err) } // 执行临界区代码 lock.Unlock(context.Background()) ``` ### 6. 事务操作（Transactions） `clientv3.Txn` 支持条件操作，如只有满足条件时才执行操作： ```go compare := clientv3.Compare( clientv3.Version("key"), "=", 1, ) successOps := []clientv3.Op{clientv3.Put("key", "success")} failureOps := []clientv3.Op{clientv3.Put("key", "failure")} resp, err := client.Txn(context.Background()). If(compare). Then(successOps...). Else(failureOps...). Commit() if err != nil { panic(err) } fmt.Println("Txn response:", resp) ``` 以上是关于 `etcd clientv3` 的基本使用方法，实际开发中还可以根据需求利用它的其他高级特性，如 lease（租约）、watch 的递归、多路复用等，以实现更复杂的应用场景。`clientv3` 提供了强大且灵活的接口，让开发者能够轻松地在 Go 语言中构建与 etcd 集群交互的应用。