第etcd通信接口之客戶端API核心方法實戰(zhàn)目錄前言etcdclientv3客戶端etcd客戶端初始化client定義

前言

我們在前面介紹了etcd的整體架構(gòu)。學習客戶端與etcd服務(wù)端的通信以及etcd集群節(jié)點的內(nèi)部通信接口對于我們更好地使用和掌握etcd組件很有幫助，也是所必需了解的內(nèi)容。我們將會介紹etcd的gRPC通信接口以及客戶端的實踐。

etcdclientv3客戶端

etcd客戶端clientv3接入的示例將會以Go客戶端為主，讀者需要準備好基本的開發(fā)環(huán)境。

首先是etcdclientv3的初始化，我們根據(jù)指定的etcd節(jié)點，建立客戶端與etcd集群的連接。

cli,err:=clientv3.New(clientv3.Config{

Endpoints:[]string{"localhost:2379"},

DialTimeout:5*time.Second,

如上的代碼實例化了一個client，這里需要傳入的兩個參數(shù)：

Endpoints：etcd的多個節(jié)點服務(wù)地址，因為我是單點本機測試，所以只傳1個。DialTimeout：創(chuàng)建client的首次連接超時，這里傳了5秒，如果5秒都沒有連接成功就會返回err；值得注意的是，一旦client創(chuàng)建成功，我們就不用再關(guān)心后續(xù)底層連接的狀態(tài)了，client內(nèi)部會重連。

etcd客戶端初始化

解決完包依賴之后，我們初始化etcd客戶端。客戶端初始化代碼如下所示：

//client_init_test.go

packageclient

import(

"context"

"fmt"

"go.etcd.io/etcd/clientv3"

"testing"

"time"

//測試客戶端連接

funcTestEtcdClientInit(t*testing.T){

var(

configclientv3.Config

client*clientv3.Client

errerror

//客戶端配置

config=clientv3.Config{

//節(jié)點配置

Endpoints:[]string{"localhost:2379"},

DialTimeout:5*time.Second,

//建立連接

ifclient,err=clientv3.New(config);err!=nil{

fmt.Println(err)

}else{

//輸出集群信息

fmt.Println(client.Cluster.MemberList(context.TODO()))

client.Close()

如上的代碼，預(yù)期的執(zhí)行結(jié)果如下：

===RUNTestEtcdClientInit

{cluster_id:14841639068965178418member_id:10276657743932975437raft_term:3[ID:10276657743932975437name:defaultpeerURLs:http://localhost:2380clientURLs::2379]{}[]0}nil

---PASS:TestEtcdClientInit(0.08s)

PASS

可以看到clientv3與etcdServer的節(jié)點localhost:2379成功建立了連接，并且輸出了集群的信息，下面我們就可以對etcd進行操作了。

client定義

接著我們來看一下client的定義：

typeClientstruct{

Cluster

Lease

Watcher

Auth

Maintenance

//Usernameisausernameforauthentication.

Usernamestring

//Passwordisapasswordforauthentication.

Passwordstring

注意，這里顯示的都是可導(dǎo)出的模塊結(jié)構(gòu)字段，代表了客戶端能夠使用的幾大核心模塊，其具體功能介紹如下：

Cluster：向集群里增加etcd服務(wù)端節(jié)點之類，屬于管理員操作。KV：我們主要使用的功能，即操作K-V。Lease：租約相關(guān)操作，比如申請一個TTL=10秒的租約。Watcher：觀察訂閱，從而監(jiān)聽最新的數(shù)據(jù)變化。Auth：管理etcd的用戶和權(quán)限，屬于管理員操作。Mainte