当前位置：首页 > 文章列表 > Golang > Go教程 > Golang搭建etcd集群教程详解

Golang搭建etcd集群教程详解

2026-01-14 16:17:53 0浏览收藏

一分耕耘，一分收获！既然都打开这篇《Golang etcd集群搭建教程》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

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

Golang服务注册中心 etcd集群搭建

搭建基于 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()
    }
}