浅入深出ETCD之【集群部署与golang客户端使用】
前言
之前说了etcd的简介，命令行使用，一些基本原理。这次来说说现实一点的集群部署和golang版本的客户端使用。因为在实际使用过程中，etcd的节点肯定是需要2N+1个进行部署的，所以有必要说明一下集群的部署。
集群部署
网上有很多集群部署的教程，有的很复杂，其实对于我们实际使用来说，其实配置并不复杂，下面举例一种最简单的集群配置。（简单到你想不到~）
下载
https://github.com/etcd-io/etcd/releases
还是在github上面找到需要下载的版本
我使用的是etcd-v3.3.13-linux-amd64.tar.gz
使用wget下载到linux你喜欢的目录，或者本地下载完成之后上传均可。
部署
首先我找了三台机器，对应ip为
192.168.4.224
192.168.4.225
192.168.4.226
PS：提醒一下记得开发对应防火墙的端口
然后将下载的文件解压，之后进入解压后的目录，分别使用下面的命令启动。(注意下面的命令对应的是三台不同的机器，你需要修改对应为你自己的ip)
$ ./etcd --name infra0 --initial-advertise-peer-urls http://192.168.4.224:2380 \
--listen-peer-urls http://192.168.4.224:2380 \
--listen-client-urls http://192.168.4.224:2379,http://127.0.0.1:2379 \
--advertise-client-urls http://192.168.4.224:2379 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://192.168.4.224:2380,infra1=http://192.168.4.225:2380,infra2=http://192.168.4.226:2380 \
--initial-cluster-state new
$ ./etcd --name infra1 --initial-advertise-peer-urls http://192.168.4.225:2380 \
--listen-peer-urls http://192.168.4.225:2380 \
--listen-client-urls http://192.168.4.225:2379,http://127.0.0.1:2379 \
--advertise-client-urls http://192.168.4.225:2379 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://192.168.4.224:2380,infra1=http://192.168.4.225:2380,infra2=http://192.168.4.226:2380 \
--initial-cluster-state new
$ ./etcd --name infra2 --initial-advertise-peer-urls http://192.168.4.226:2380 \
--listen-peer-urls http://192.168.4.226:2380 \
--listen-client-urls http://192.168.4.226:2379,http://127.0.0.1:2379 \
--advertise-client-urls http://192.168.4.226:2379 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://192.168.4.224:2380,infra1=http://192.168.4.225:2380,infra2=http://192.168.4.226:2380 \
--initial-cluster-state new
至此，三个节点的集群部署完成。😂😂😂没错就是这么easy，没有网上说的那么复杂。
配置文件
如果你嫌弃每次使用这么长的命令进行启动，你可以将它写为配置文件：
# 当前节点名称
name: infra1
# etcd数据保存目录
data-dir: /usr/local/etcd
# 供外部客户端使用的url
listen-client-urls: http://192.168.4.225:2379,http://127.0.0.1:2379
# 广播给外部客户端使用的url
advertise-client-urls: http://192.168.4.225:2379
# 集群内部通信使用的URL
listen-peer-urls: http://192.168.4.225:2380
# 广播给集群内其他成员访问的URL
initial-advertise-peer-urls: http://192.168.4.225:2380
# 集群的名称
initial-cluster-token: etcd-cluster-1
# 初始集群成员列表
initial-cluster: infra0=http://192.168.4.224:2380,infra1=http://192.168.4.225:2380,infra2=http://192.168.4.226:2380
#初始集群状态
initial-cluster-state: new
然后指定配置文件的路径进行启动就可以了
./etcd --config-file=conf.yml
其他部署策略
以上的部署一方面，我个人部署时使用的最简单方式，更简单的可能是使用yum进行etcd的下载。
当然上述方式也存在一些问题，现在的etcd相当于裸奔的情况：
- 没有鉴权就想到于任何人知道ip和端口就可以连接上你的etcd，所以当前可能只适用于内网使用，服务通过内网ip进行访问（这个可以通过添加权限和用户来完成）
- 当前通信是没有加密的
- 当前etcd是利用静态ip来进行配置的，我认为这也是实际中用到最普通的情况，但是etcd还提供发现机制来进行部署和配置，更加灵活
等等，这些部署策略更多针对于线上，因为官方写的非常详细了，我感觉再写也就班门弄斧了。
https://doczhcn.gitbook.io/etcd/index/index-1/clustering
Golang客户端使用
这里来实际用代码操作一下etcd，还是和之前使用命令行一样，get/put/del/watch/lease用一下这些操作，其他操作请查看doc
https://godoc.org/github.com/coreos/etcd/clientv3
客户端下载
这里不建议使用go get进行下载，真的太慢了，可以直接从github上面下载之后放到对应目录快一些。https://github.com/etcd-io/etcd
下载解压之后放到gopath下对应：go/src/go.etcd.io/etcd
代码
package main
import (
"context"
"fmt"
"go.etcd.io/etcd/clientv3"
"go.etcd.io/etcd/mvcc/mvccpb"
"time"
)
func main() {
// 配置客户端连接
client, err := clientv3.New(clientv3.Config{
// Endpoints: []string{"127.0.0.1:2379"},
Endpoints: []string{"192.168.4.224:2379", "192.168.4.225:2379", "192.168.4.226:2379"},
DialTimeout: 5 * time.Second,
})
if err != nil {
panic(err)
}
defer client.Close()
// 启动watch监听
watch := client.Watch(context.TODO(), "aaa")
go func() {
for {
watchResponse := <- watch
for _, ev := range watchResponse.Events {
switch ev.Type {
case mvccpb.DELETE:
fmt.Printf("监听到del：%s\n", ev.Kv.Key)
case mvccpb.PUT:
fmt.Printf("监听到put：%s, %s\n", ev.Kv.Key, ev.Kv.Value)
}
}
}
}()
// 新增
putResponse, err := client.Put(context.TODO(), "aaa", "xxx")
if err != nil {
fmt.Println(err)
return
}
fmt.Println(putResponse.Header.String())
// 查询
getResponse, err := client.Get(context.TODO(), "aaa")
if err != nil {
fmt.Println(err)
return
}
fmt.Println(getResponse.Kvs)
// 删除
deleteResponse, err := client.Delete(context.TODO(), "aaa")
if err != nil {
fmt.Println(err)
return
}
fmt.Println(deleteResponse.Header.String())
// 申请租约
grantResponse, err := client.Grant(context.TODO(), 10)
if err != nil {
fmt.Println(err)
return
}
// 使用租约
response, err := client.Put(context.TODO(), "aaa", "xxx", clientv3.WithLease(grantResponse.ID))
if err != nil {
fmt.Println(err)
return
}
fmt.Println(response.Header.String())
// 等待租约自动过期
time.Sleep(time.Second * 20)
}
大致能得到以下输出
监听到put：aaa, xxx
cluster_id:14841639068965178418 member_id:10276657743932975437 revision:53 raft_term:4
[key:"aaa" create_revision:53 mod_revision:53 version:1 value:"xxx" ]
监听到del：aaa
cluster_id:14841639068965178418 member_id:10276657743932975437 revision:54 raft_term:4
监听到put：aaa, xxx
cluster_id:14841639068965178418 member_id:10276657743932975437 revision:55 raft_term:4
监听到del：aaa
其实使用起来还是非常简单，我就不过多赘述了。
