当前位置：首页 > 文章列表 > Golang > Go教程 > Golang+Etcd实现服务注册与发现

Golang+Etcd实现服务注册与发现

2025-11-04 08:27:47 0浏览收藏

Golang不知道大家是否熟悉？今天我将给大家介绍《Golang用Etcd实现服务注册与发现》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

使用Golang结合Etcd实现服务注册与发现，通过租约机制维持心跳、Watch监听服务变化。服务启动时将信息写入Etcd并创建租约，定时续租保持活跃；客户端通过前缀查询实例并监听变更，实现动态服务发现。生产环境中需封装模块、添加重试、合理设置TTL，并结合健康检查提升稳定性。该方案已广泛应用于Kubernetes等系统，具备高可用与可扩展性。

Golang如何使用Etcd实现服务发现与注册_Golang Etcd服务发现注册实践详解

在微服务架构中，服务发现与注册是核心组件之一。Golang 作为高性能后端语言，常与 Etcd 配合实现服务的自动注册与发现。Etcd 是一个高可用、强一致性的分布式键值存储系统，由 CoreOS 开发，广泛用于 Kubernetes 等系统中。本文将详细介绍如何使用 Golang 结合 Etcd 实现服务注册与发现。

服务注册：将服务信息写入 Etcd

服务注册的本质是将服务的元信息（如 IP、端口、健康状态）写入 Etcd，并维持心跳以表明服务存活。

基本流程如下：

服务启动时，向 Etcd 写入自身信息，通常以 key-value 形式存储，例如：
/services/user-service/192.168.1.100:8080
value 可为 JSON 格式的结构体，包含服务名、地址、版本、权重等。
使用租约（Lease）机制自动过期，避免宕机服务残留。
通过定时续租（KeepAlive）维持服务活跃状态。

示例代码：

package main

import (
    "context"
    "encoding/json"
    "log"
    "time"

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

type ServiceInfo struct {
    Name    string `json:"name"`
    Host    string `json:"host"`
    Port    int    `json:"port"`
    Version string `json:"version"`
}

func registerService(cli *clientv3.Client, service ServiceInfo) (clientv3.LeaseID, context.CancelFunc) {
    data, _ := json.Marshal(service)
    key := "/services/" + service.Name + "/" + service.Host + ":" + fmt.Sprint(service.Port)

    // 创建租约，TTL 为 10 秒
    leaseResp, err := cli.Grant(context.TODO(), 10)
    if err != nil {
        log.Fatal(err)
    }

    // 注册服务
    _, err = cli.Put(context.TODO(), key, string(data), clientv3.WithLease(leaseResp.ID))
    if err != nil {
        log.Fatal(err)
    }

    // 启动保活
    ctx, cancel := context.WithCancel(context.Background())
    _, err = cli.KeepAlive(ctx, leaseResp.ID)
    if err != nil {
        log.Fatal(err)
    }

    return leaseResp.ID, cancel
}

上述代码中，通过 Grant 创建租约，并用 KeepAlive 持续发送心跳，确保服务不被清除。

服务发现：从 Etcd 获取可用服务列表

服务发现是指客户端从 Etcd 中查询某个服务的所有可用实例，并能监听变化。

实现方式包括：

通过前缀查询获取某服务的所有实例，例如：/services/user-service/
解析返回的 KV 列表，提取服务地址。
使用 Watch 监听服务列表变化，动态更新本地缓存。

示例代码：

func getServiceInstances(cli *clientv3.Client, serviceName string) []ServiceInfo {
    resp, err := cli.Get(context.TODO(), "/services/"+serviceName+"/", clientv3.WithPrefix())
    if err != nil {
        log.Printf("Failed to get services: %v", err)
        return nil
    }

    var instances []ServiceInfo
    for _, ev := range resp.Kvs {
        var info ServiceInfo
        json.Unmarshal(ev.Value, &info)
        instances = append(instances, info)
    }
    return instances
}

结合 Goroutine 和 Watch，可实现实时监听：

go func() {
    watchCh := cli.Watch(context.Background(), "/services/"+serviceName+"/", clientv3.WithPrefix())
    for resp := range watchCh {
        for _, ev := range resp.Events {
            if ev.Type == clientv3.EventTypePut {
                log.Printf("Service added: %s", ev.Kv.Key)
            } else if ev.Type == clientv3.EventTypeDelete {
                log.Printf("Service removed: %s", ev.Kv.Key)
            }
        }
    }
}()