17370845950

Go服务自动注册与发现需选对注册中心、理清生命周期，并将Register/Deregister与进程退出强绑定；用Consul时须设TTL并定期续期，用唯一Service.ID，且必须监听SIGTERM等信号执行优雅注销。

Go 服务要实现自动注册与发现，核心不在于写多少代码，而在于选对注册中心、理清生命周期边界、并让 Register 和 Deregister 与进程退出强绑定。硬编码服务地址或轮询文件列表不是“发现”，只是临时 workaround。

用 Consul 做注册中心时，必须处理好健康检查和 TTL 续期

Consul 默认依赖客户端主动上报健康状态。如果只调一次 agent/service/register 就不管了，服务挂掉后注册信息仍会残留（默认 24 小时才过期）。

实操建议：

• 注册时务必设置 TTL（如 "ttl": "30s"），并启动 goroutine 定期调用 /v1/agent/check/pass/ 续期
• 避免用 http.Check 类型的健康检查——它由 Consul 主动探活，网络抖动易误判；TTL 模式更可控
• 注册 payload 中的 Service.ID 必须全局唯一，建议拼接主机名+端口+启动时间戳，否则多实例重启可能覆盖彼此

curl -X PUT http://localhost:8500/v1/agent/service/register \
  -d '{
    "ID": "api-server-192.168.1.10-8080-1717023456",
    "Name": "api-server",
    "Address": "192.168.1.10",
    "Port": 8080,
    "Check": {
      "TTL": "30s"
    }
  }'

服务注销必须 hook 到 os.Interrupt / syscall.SIGTERM

很多 Go 服务在 main() 里直接 http.ListenAndServe，没做信号捕获。K8s 发送 SIGTERM 或 Ctrl+C 退出时，注册信息不会自动清除，导致发现系统持续返回已死节点。

实操建议：

• 用 signal.Notify 监听 os.Interrupt 和 syscall.SIGTERM
• 在 shutdown 流程中，先

  

  停 HTTP server（srv.Shutdown()），再发 DELETE /v1/agent/service/deregister/
• 加超时控制（如 5 秒），避免注销失败阻塞进程退出

sigChan := make(chan os.Signal, 1)
signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
<-- 省略启动逻辑 -->
go func() {
  <-- 启动服务注册 -->
}()
<-- 启动 HTTP server -->
<-- 阻塞等待信号 -->
<-sigChan
log.Println("shutting down...")
srv.Shutdown(context.Background())
// 调用 Consul 注销接口
http.Delete("http://localhost:8500/v1/agent/service/deregister/api-server-192.168.1.10-8080-1717023456", nil)

客户端做服务发现时，别直接缓存第一次查到的 IP 列表

常见错误是启动时调一次 /v1/health/service/，把结果存*局变量，后续所有请求都打固定几个后端——这根本不是“发现”，而是静态负载均衡。

实操建议：

• 每次发起 RPC 前，应重新查询（或使用带 TTL 的本地缓存，比如 groupcache 或 singleflight 配合短时 cache）
• 查询时加 Passing 参数（?passing），只取通过健康检查的实例
• 若用 gRPC，可实现自定义 Resolver，监听 watch /v1/health/service/ 的变更事件，动态更新 Address 列表

// 查询健康实例（curl 示例）
curl "http://localhost:8500/v1/health/service/api-server?passing"

在 Kubernetes 中，优先用 Headless Service + DNS，而非自己连 Consul

如果你的服务已部署在 K8s，硬上 Consul 做服务发现反而增加运维负担和故障点。K8s 原生的 headless service + StatefulSet 已提供稳定的 DNS A 记录发现能力（如 api-server.default.svc.cluster.local 解析为全部 Pod IP）。

实操建议：

• 无状态服务直接用 ClusterIP，需要直连 Pod 才用 headless
• DNS 解析结果有缓存（Linux nscd 或 Go net.Resolver 默认 TTL），需在代码里手动刷新或设短超时
• 若仍需跨集群发现，再考虑 Istio 或 Consul Connect，而不是在每个 Go 服务里重复实现注册逻辑

真正难的不是怎么调 API，而是注册时机是否覆盖所有异常退出路径、注销是否真正原子、以及客户端是否感知到服务列表的秒级变化。这些细节漏掉一个，整个“自动发现”就退化|成人|工维护配置的幻觉。