golang etcdclientv3使用說明

clientv3.New() 創建連接

config = ec.Config{
　　Endpoints:   []string{"10.0.0.5:2379"},  //連接的etcd集群地址，這里為單機的故一個地址
　　DialTimeout: 30 * time.Second,   //超時時長
}

 

返回值為clientv3.Client結構體

KV是經常使用的類型，主要用來操作key value值

client.Put() 實際上就是KV接口實現的一個方法

 

KV.Put 向etcd中插入一個Key，如存在則替換新的值。

if putRes, err = kv.Put(context.TODO(), "/cron/jobs/job3", "test111111 hel3123lo",ec.WithPrevKV()); err != nil {
	fmt.Println(err)
} else {
	fmt.Println("revision: ", putRes.Header.Revision)
	if putRes.PrevKv != nil{
		fmt.Println(string(putRes.PrevKv.Value))
	}
}

 

WithPrevKV()獲取Put事件操作之前的鍵值對

package main

import (
	"context"
	"fmt"
	"time"

	ec "go.etcd.io/etcd/clientv3"
)

func main() {
	var (
		config ec.Config
		client *ec.Client
		err    error
		kv     ec.KV
		putRes *ec.PutResponse
	)

	config = ec.Config{
		Endpoints:   []string{"10.0.0.5:2379"},
		DialTimeout: 30 * time.Second,
	}

	if client, err = ec.New(config); err != nil {
		fmt.Println(err)
		return
	}

	kv = ec.NewKV(client)

	if putRes, err = kv.Put(context.TODO(), "/cron/jobs/job3", "test111111 hel3123lo",ec.WithPrevKV()); err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("revision: ", putRes.Header.Revision)
		if putRes.PrevKv != nil{
			fmt.Println(string(putRes.PrevKv.Value))
		}
	}

	op:= ec.OpGet("/cron/jobs/job3")
	fmt.Println(string(op.KeyBytes()))
}

 

 如果Key不存在，則沒有事件操作之前的信息

[root@node01 ~]# ETCDCTL_API=3 etcdctl get /cron/jobs/ --prefix
/cron/jobs/job1
test hello
/cron/jobs/job2
test111111 hel3123lo
/cron/jobs/job3
test22222 hello2222
/cron/jobs/job4
test22222 hello2222

獲取key的值

package main

import (
	"context"
	"fmt"
	ec "go.etcd.io/etcd/clientv3"
	"time"
)

var(
	conf ec.Config
	cli *ec.Client
	err error
	kv ec.KV
	getResp *ec.GetResponse
)

func main(){
	conf = ec.Config{
		Endpoints:[]string{"10.0.0.5:2379"},
		DialTimeout:time.Second*30,
	}

	if cli,err = ec.New(conf); err != nil{
		fmt.Println(err)
	}
	kv = ec.NewKV(cli)

	getResp,err = kv.Get(context.TODO(),"/cron/jobs/job3")

	fmt.Println(getResp.Kvs)
}

 

運行結果

[key:"/cron/jobs/job3" create_revision:11 mod_revision:14 version:4 value:"test22222 hello2222" ]

Process finished with exit code 0

create_revision: 為創建時的版本

mod_revision：修改版本

version：自從創建以來修改的次數。 值會不斷的遞增。

 

 

刪除key

delResp, err = kv.Delete(context.TODO(), "/cron/jobs/job4", ec.WithPrevKV());

if len(delResp.PrevKvs) != 0 {
　　fmt.Println(delResp)
}

 

刪除前的多個key

　　

一次性刪除多個key

kv.Delete(context.TODO(), "/cron/jobs/", ec.WithPrefix())

 
WithPrefix()：以這個key為前綴的key都刪除掉