本文使用的Centos8下部署Etcd。

首先来下载我们今天的主角

链接：etcd 提取码：mpbo
由于美国对我国的限制，最近这个时期GitHub下载东西？你心里mmp的在说，不靠谱下台，不靠谱下台，不靠谱下台。

下载好上面的etcd之后，放到自己的linux下。

tar xvf etcd-v3.4.5-linux-amd64.tar.gz #解压我们的程序
cd etcd-v3.4.5-linux-amd64 
sudo cp etcd etcdctl /usr/local/bin/

etcd --version
# if you see info
etcd Version: 3.4.5
Git SHA: e784ba73c
Go Version: go1.12.12
Go OS/Arch: linux/amd64

# mkdir etcd config file path
mkdir -p /var/lib/etcd/
mkdir /etc/etcd

groupadd --system etcd
useradd -s /sbin/nologin --system -g etcd etcd #这个账号不能用来登录
 
#接下来我们为etcd 创建 systemctl 脚本命令
vim /etc/systemd/system/etcd.service

[Unit]
Description=Etcd Server
After=network.target

[Service]
Type=simple
WorkingDirectory=/var/lib/etcd/   
EnvironmentFile=-/etc/etcd/etcd.conf #配置文件路径
ExecStart=/usr/local/bin/
Type=notify
[Install]
WantedBy=multi-user.target

#看不懂没有关系，cp加完了
systemctl daemon-reload
systemctl start etcd.service

# 看看情况
systemctl status etcd
#看看端口 
ss -tunelp | grep 2379

到了这里就好了，不过没有关系，我进去操作一下etcdctl客户端

image.png

集群篇

etcds实例名称	IP地址	Hostname
etcd 1	192.168.142.161	kubernetes-node1.example.com
etcd 2	192.168.142.162	kubernetes-node2.example.com
etcd 3	192.168.142.163	kubernetes-node3.example.com

编辑etcd1下的配置文件

vim /etc/etcd/etcd.conf
# [member]
ETCD_NAME=etcd1   #etcd实例名称
ETCD_DATA_DIR="/var/lib/etcd"  #etcd数据保存目录
ETCD_LISTEN_CLIENT_URLS="http://192.168.142.161:2379,http://127.0.0.1:2379"
#供外部客户端使用的url
ETCD_ADVERTISE_CLIENT_URLS="http://192.168.142.161:2379,http://127.0.0.1:2379"
#广播给外部客户端使用的url

#[cluster]
ETCD_LISTEN_PEER_URLS="http://192.168.142.161:2380"   #集群内部通信使用的URL
ETCD_INITIAL_ADVERTISE_PEER_URLS="http://192.168.142.161:2380"
#广播给集群内其他成员访问的URL
ETCD_INITIAL_CLUSTER="etcd1=http://192.168.142.161:2380,etcd2=http://192.168.142.162:2380,etcd3=http://192.168.142.163:2380"
#初始集群成员列表
ETCD_INITIAL_CLUSTER_STATE="new"
#初始集群状态，new为新建集群
ETCD_INITIAL_CLUSTER_TOKEN="k8s-etcd-cluster"  #集群的名称

etcd2和etcd3为加入k8s-etcd-cluster集群的实例，需要将其ETCD_INITIAL_CLUSTER_STATE设置为"exist"。etcd2的完整配置如下

# [member]
ETCD_NAME=etcd2
ETCD_DATA_DIR="/var/lib/etcd"
ETCD_LISTEN_CLIENT_URLS="http://192.168.142.162:2379,http://127.0.0.1:2379"
ETCD_ADVERTISE_CLIENT_URLS="http://192.168.142.162:2379,http://127.0.0.1:2379"

#[cluster]
ETCD_LISTEN_PEER_URLS="http://192.168.142.162:2380"
ETCD_INITIAL_ADVERTISE_PEER_URLS="http://192.168.142.162:2380"
ETCD_INITIAL_CLUSTER="etcd1=http://192.168.142.161:2380,etcd2=http://192.168.142.162:2380,etcd3=http://192.168.142.163:2380"
ETCD_INITIAL_CLUSTER_STATE="exist"
ETCD_INITIAL_CLUSTER_TOKEN="k8s-etcd-cluster"

来段官方版本的etcd

package main

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

func main() {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   []string{"127.0.0.1:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        fmt.Println("connect to etcd failed,err:", err)
        return
    }
    defer cli.Close()
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    _, err = cli.Put(ctx, "test", "google")
    cancel()
    if err != nil {
        fmt.Println("put failed err:", err)
        return
    }

    ctx, cancel = context.WithTimeout(context.Background(), time.Second)
    resp, err := cli.Get(ctx, "test")
    cancel()
    if err != nil {
        fmt.Println("get failed,err:", err)
        return
    }
    for _, ev := range resp.Kvs {
        fmt.Println(ev.Key, ev.Value)
    }

}

go mod 有很多坑，不过没有关系。

#我们在go mod 添加以下代码即可
replace (
    github.com/coreos/go-systemd => github.com/coreos/go-systemd/v22 v22.0.0
    google.golang.org/grpc => google.golang.org/grpc v1.26.0
)

看到这里已经完了

image.png

等服务发现和分布式锁写完了，我再更新