Golang如何实现微服务架构与服务注册_Golang微服务服务注册与发现实践

import ( "context" "log" "time"

"go.etcd.io/etcd/clientv3"

)

func registerService(client *clientv3.Client, serviceName, addr string, ttl int64) { // 创建租约 leaseResp, err := client.Grant(context.TODO(), ttl) if err != nil { log.Fatal("无法创建租约:", err) }

// 注册服务路径
key := "/services/" + serviceName + "/" + addr
_, err = client.Put(context.TODO(), key, "active", clientv3.WithLease(leaseResp.ID))
if err != nil {
    log.Fatal("注册失败:", err)
}

// 定期续租
ticker := time.NewTicker(time.Duration(ttl/2) * time.Second)
go func() {
    for range ticker.C {
        _, err := client.KeepAliveOnce(context.TODO(), leaseResp.ID)
        if err != nil {
            log.Println("心跳失败:", err)
            return
        }
    }
}()

}

var addrs []string
for _, kv := range resp.Kvs {
    addr := string(kv.Key)[len("/services/"+serviceName+"/"):]
    addrs = append(addrs, addr)
}
return addrs

}

// 监听服务变化 func watchServices(client *clientv3.Client, serviceName string, updateCh chan []string) { rch := client.Watch(context.Background(), "/services/"+serviceName, clientv3.WithPrefix()) for wresp := range rch { var addrs []string for _, ev := range wresp.Events { addr := string(ev.Kv.Key)[len("/services/"+serviceName+"/"):] if ev.Type == clientv3.EventTypePut { addrs = append(addrs, addr) } } updateCh

消费者获取到实例列表后，可结合轮询、随机等策略实现简单的客户端负载均衡。

集成 HTTP 服务示例

将注册逻辑嵌入一个 Gin 编写的 HTTP 服务：

// 注册本服务
registerService(cli, "user-service", "127.0.0.1:8080", 10)

// 启动 HTTP 服务
r := gin.Default()
r.GET("/users", func(c *gin.Context) {
    c.JSON(200, map[string]string{"status": "ok"})
})

r.Run(":8080")

其他服务可通过监听 /services/user-service 路径获取可用节点，并发起请求。

基本上就这些。Golang 配合 etcd 可高效实现服务注册与发现，无需引入复杂框架。关键在于租约控制、健康上报和变更监听。实际生产中可封装为公共库，供多个服务复用。不复杂但容易忽略细节，比如网络分区时的行为、重试机制等，需结合场景完善。