本文使用的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
等服务发现和分布式锁写完了，我再更新
