Golang搭建etcd集群教程详解

珍惜时间，勤奋学习！今天给大家带来《Golang etcd集群搭建教程》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

首先部署三节点etcd集群，配置各节点名称、IP及集群信息，通过systemd管理服务；然后使用Go的etcd客户端实现服务注册与发现，注册时创建租约并定期续租，发现时从etcd前缀路径获取服务列表，结合KeepAlive和Watch机制实现高可用服务管理。

搭建基于 etcd 的 Golang 服务注册中心，核心是部署高可用的 etcd 集群，并通过 Go 程序实现服务的注册与发现。下面分步骤说明如何完成整个流程。

etcd 集群部署（三节点示例）

etcd 是一个高可用的分布式键值存储系统，常用于服务发现、配置共享和分布式协调。建议至少使用三个节点来保证容错能力。

环境准备：
假设三台机器 IP 分别为：

• 192.168.1.10（node1）
• 192.168.1.11（node2）
• 192.168.1.12（node3）

在每台机器上执行以下操作：

1. 下载并安装 etcd

以 Linux 为例：

wget https://github.com/etcd-io/etcd/releases/download/v3.5.12/etcd-v3.5.12-linux-amd64.tar.gz
tar xzvf etcd-v3.5.12-linux-amd64.tar.gz
cd etcd-v3.5.12-linux-amd64
sudo mv etcd etcdctl /usr/local/bin/

2. 创建 etcd 配置文件（systemd 方式）

创建配置文件 /etc/etcd/config.env：

# 节点唯一名称
ETCD_NAME=node1
# 本机 IP
ETCD_ADVERTISE_CLIENT_URLS=http://192.168.1.10:2379
ETCD_LISTEN_CLIENT_URLS=http://0.0.0.0:2379
ETCD_LISTEN_PEER_URLS=http://0.0.0.0:2380
ETCD_ADVERTISE_PEER_URLS=http://192.168.1.10:2380
# 集群配置
ETCD_INITIAL_ADVERTISE_PEER_URLS=http://192.168.1.10:2380
ETCD_INITIAL_CLUSTER_TOKEN=etcd-cluster-1
ETCD_INITIAL_CLUSTER=node1=http://192.168.1.10:2380,node2=http://192.168.1.11:2380,node3=http://192.168.1.12:2380
ETCD_INITIAL_CLUSTER_STATE=new

注意：每台机器的 ETCD_NAME 和 IP 地址要对应修改。

3. 创建 systemd 服务文件

/etc/systemd/system/etcd.service

[Unit]
Description=etcd
After=network.target
[Service]
Type=notify
EnvironmentFile=/etc/etcd/config.env
ExecStart=/usr/local/bin/etcd
Restart=on-failure
LimitNOFILE=65536
[Install]
WantedBy=multi-user.target

4. 启动服务

sudo systemctl daemon-reexec
sudo systemctl enable etcd
sudo systemctl start etcd

5. 验证集群状态

任选一个节点执行：

etcdctl --endpoints=http://192.168.1.10:2379,http://192.168.1.11:2379,http://192.168.1.12:2379 endpoint status --write-out=table

输出应显示三个成员，状态正常。

Go 服务注册与发现实现

使用 Go 客户端 go.etcd.io/etcd/clientv3 与 etcd 交互。

1. 安装依赖

go get go.etcd.io/etcd/clientv3

2. 服务注册逻辑

服务启动时向 etcd 写入自身信息，并周期性发送心跳（租约续期）。

package main

import (
    "context"
    "log"
    "time"

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

const serviceKey = "/services/user-service/192.168.1.10:8080"

func registerService(etcdEndpoints []string) {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   etcdEndpoints,
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        log.Fatal("连接 etcd 失败:", err)
    }
    defer cli.Close()

    // 创建一个 10 秒的租约
    resp, err := cli.Grant(context.TODO(), 10)
    if err != nil {
        log.Fatal("创建租约失败:", err)
    }

    // 注册服务
    _, err = cli.Put(context.TODO(), serviceKey, "http://192.168.1.10:8080", clientv3.WithLease(resp.ID))
    if err != nil {
        log.Fatal("服务注册失败:", err)
    }

    log.Println("服务注册成功，开始续租")

    // 定期续租（KeepAlive）
    keepAlive, err := cli.KeepAlive(context.TODO(), resp.ID)
    if err != nil {
        log.Fatal("续租失败:", err)
    }

    // 持续监听续租响应
    for range keepAlive {
        // 接收心跳响应，维持租约
    }
}

3. 服务发现逻辑

客户端从 etcd 获取当前可用的服务地址列表。

func getServiceList(cli *clientv3.Client) {
    resp, err := cli.Get(context.Background(), "/services/user-service/", clientv3.WithPrefix())
    if err != nil {
        log.Println("获取服务列表失败:", err)
        return
    }

    log.Println("当前可用服务:")
    for _, kv := range resp.Kvs {
        log.Printf("%s -> %s", kv.Key, kv.Value)
    }
}

4. 主函数调用示例

func main() {
    etcdEndpoints := []string{"http://192.168.1.10:2379", "http://192.168.1.11:2379", "http://192.168.1.12:2379"}

    // 启动注册（建议放到 goroutine）
    go registerService(etcdEndpoints)

    // 模拟服务运行
    ticker := time.NewTicker(30 * time.Second)
    for range ticker.C {
        cli, _ := clientv3.New(clientv3.Config{Endpoints: etcdEndpoints})
        getServiceList(cli)
        cli.Close()
    }
}

关键注意事项

• 租约（Lease）时间要合理设置，通常为 10~30 秒，心跳频率应小于租约时间。
• 服务关闭时应主动撤销租约或删除 key，避免残留。
• 生产环境建议启用 etcd 的 HTTPS 和用户认证。
• Go 客户端应复用 *clientv3.Client 实例，避免频繁创建连接。
• 监听服务变化可使用 Watch 机制实现动态更新。

基本上就这些。etcd 集群搭建完成后，配合 Go 的租约机制，就能实现一个轻量级、高可用的服务注册与发现中心。

今天关于《Golang搭建etcd集群教程详解》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！