• 安裝package
• 使用
• 參考

etcd是分散式強一致KV儲存系統。

關於etcd的介紹和使用，可以查閱上篇文章etcd入門。

本文主要介紹在golang中是如何使用etcd的。

安裝package

etcd 官方提供了golang語言的client package go.etcd.io/etcd/clientv3。這裡介紹的v3版本的使用。

下載已經發布版本的source code。
例如，v3.4.13 ,下載地址v3.4.13。

下載後，解壓到$GOPATH目錄下:

tar zvxf etcd-3.4.13.tar.gz -C /home/lanyang/workspace/go_projects/src/go.etcd.io/

cd /home/lanyang/workspace/go_projects/src/go.etcd.io/
mv etcd-3.4.13/ etcd
 

如果直接使用go get go.etcd.io/etcd/clientv3，會直接下載最新的程式碼，可能沒有經過嚴格測試，出現類似
cannot use &errPicker literal (type *errPicker) as type Picker in return argument 這樣的錯誤。

使用

下面程式碼中，先初始化連線配置，接著put一個值，最後get檢視結果。

package main

import (
	"context"
	"log"
	"time"

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

func main() {
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"localhost:2379", "localhost:2479", "localhost:2579"},
		DialTimeout: 5 * time.Second,
	})

	if err != nil {
		log.Println("connect to etcd failed, err:", err)
		return
	}
	defer cli.Close()

	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
	putResp, err := cli.Put(ctx, "fruit", "orange")
	cancel()

	if err != nil {
		log.Println("put to ectcd failed:", err)
		return
	}
	log.Println("putResp:", putResp)

	ctx, cancel = context.WithTimeout(context.Background(), 1*time.Second)
	getResp, err := cli.Get(ctx, "fruit")
	cancel()
	if err != nil {
		log.Printf("get from etcd failed, err:%v\n", err)
		return
	}

	log.Println("getResp:", getResp)

	for _, ev := range getResp.Kvs {
		log.Printf("%s:%s\n", ev.Key, ev.Value)
	}
}

 

啟動etcd服務(具體安裝可見etcd 入門)，接著執行上面的程式碼。

輸出結果：

2020-10-18 12:45:28.370946 I | putResp: &{cluster_id:3868734316268835716 member_id:2759271418354571410 revision:7 raft_term:31  <nil>}
2020-10-18 12:45:28.373794 I | getResp: &{cluster_id:3868734316268835716 member_id:2759271418354571410 revision:7 raft_term:31  [key:"fruit" create_revision:7 mod_revision:7 version:1 value:"orange" ] false 1}
2020-10-18 12:45:28.373810 I | fruit:orange

 

PUT GET返回錯誤型別主要由兩種，一種是context error，cancel的和context deadline。
另一種是，gRPC error。

可以定義一個handler專門處理錯誤：

func errHandler(err error) {
	switch err {
	case context.Canceled:
		log.Fatalf("ctx is canceled by another routine: %v", err)
	case context.DeadlineExceeded:
		log.Fatalf("ctx is attached with a deadline is exceeded: %v", err)
	case rpctypes.ErrEmptyKey:
		log.Fatalf("client-side error: %v", err)
	default:
		log.Fatalf("bad cluster endpoints, which are not etcd servers: %v", err)
	}
}

參考

etcd/clientv3

go操作etcd

從零開始入門 K8s | 手把手帶你理解 etcd

阿里 雲原生技術公開課