etcd-3-go操作etcd基础

一 golang对etcd的增删改查

package main

import (
	"context"
	"fmt"
	"github.com/etcd-io/etcd/clientv3"
	"time"
)

func connect() (client *clientv3.Client, err error){

	client, err = clientv3.New(clientv3.Config{
		 // etcd的集群数组，我们这里只有1个
		Endpoints:   []string{"127.0.0.1:2379", "127.0.0.1:22379", "127.0.0.1:32379"},
		DialTimeout: 5 * time.Second,
	})

	if err != nil {
		fmt.Println("connect err:", err)
		return nil, err
	}

	return client, err
}

func main() {

	// 连接
	cli, err := connect()
	defer cli.Close()
	if err != nil {
		return
	}

	// 获取etcd读写对象
	kv := clientv3.NewKV(cli)

	// 添加键值对
	r1, err := kv.Put(context.TODO(), "/lesson/math", "100")		// 添加数学课程为100分
	if err != nil {
		fmt.Println("put key1 err:", err)
		return
	}

	// 继续添加键值对
	r2, err := kv.Put(context.TODO(), "/lesson/music", "50")		// 添加音乐课程为50分
	if err != nil {
		fmt.Println("put key2 err:", err)
		return
	}

	fmt.Println("添加结果r1: ", r1)			// &{cluster_id:14841639068965178418 member_id:10276657743932975437 revision:9 raft_term:2  <nil>}
	fmt.Println("添加结果r2: ", r2)			// &{cluster_id:14841639068965178418 member_id:10276657743932975437 revision:10 raft_term:2  <nil>}

	// 获取整个 /lesson目录下的数据
	getAll, err := kv.Get(context.TODO(), "/lesson/", clientv3.WithPrefix())
	if err != nil {
		fmt.Println("select all err: ", err)
		return
	}
	// [key:"/lesson/math" create_revision:9 mod_revision:25 version:8 value:"100"  key:"/lesson/music" create_revision:26 mod_revision:26 version:1 value:"50" ]
	fmt.Println("查询所有：", getAll.Kvs)

	// 删除键值对,如果添加参数:clientv3.WithPrevKV()，则delResult结果中包含删除前的结果：PrevKvs
	delResult, err := kv.Delete(context.TODO(), "/lesson/music")
	if err != nil {
		fmt.Println("del key2 err:", err)
		return
	}
	fmt.Println("删除r2结果:", delResult)

	// 修改键值对，修改仍然是Put
	updRerulst, err := kv.Put(context.TODO(), "/lesson/math", "30")
	if err != nil {
		fmt.Println("upd key2 err:", err)
		return
	}
	fmt.Println("修改r1结果:", updRerulst)

	// 查询当前r1的值 该函数支持重载，第三个参数都是 clientv3.With***，用来限制返回结果
	getR1, err := kv.Get(context.TODO(), "/lesson/math")
	if err != nil {
		fmt.Println("select r1 err: ", err)
		return
	}
	//  [key:"/lesson/math" create_revision:9 mod_revision:13 version:3 value:"100" ]
	fmt.Println("查询r1结果：", getR1.Kvs)	

	// 查询被删除的r2的值
	getR2, err := kv.Get(context.TODO(), "/lesson/music")
	if err != nil {
		fmt.Println("select r2 err: ", err)
		return
	}
	//  []
	fmt.Println("查询r2结果：", getR2.Kvs)	

}

二 批量操作

• 批量删除：kv.Delete(context.TODO(), "/lesson/", clientv3.WithPrevfix())
• 批量按顺序删除，并删除2个：kv.Delete(context.TODO(), "/lesson/lesson1", clientv3.WithFromKey(),clientv3.WithLimit(2))

三 使用OP操作代替原有的增删改查

	// 创建Op
	putOp := clientv3.OpPut("/cron/jobs/job8", "888")
	// 执行Op
	opR, err := kv.Do(context.TODO(), putOp)
	if err != nil {
		fmt.Println("putOp err:", err)
		return
	}
	fmt.Println("写入Revision：", opR.Put().Header.Revision)

	// 创建Op
	getOp := clientv3.OpGet("/cron/jobs/job8")
	// 执行Op
	opR2, err := kv.Do(context.TODO(), getOp)
	if err != nil {
		fmt.Println("getOp err:", err)
		return
	}
	fmt.Println("获取Revisoon：", opR2.Get().Kvs[0].ModRevision)
	fmt.Println("获取Value：", opR2.Get().Kvs[0].Value)