17370845950

Go微服务中不能直接用http.Client做负载均衡，因其不维护实例列表、不感知健康状态与权重变化，无法自动轮询或多节点重试；需借助go-kit/sd等组件实现服务发现与动态负载均衡。

Go 微服务中为什么不能直接用 http.Client 做负载均衡

因为 http.Client 本身不维护服务实例列表，也不感知健康状态或权重变化。你调用 client.Do(req) 时，目标地址是写死的或靠上层拼接，无法自动在多个 10.0.1.10:8080、10.0.1.11:8080 之间轮询或重试失败节点。

真正需要的是一个能动态管理后端节点、支持健康检查、可插拔策略的客户端抽象层。常见错误是把负载均衡逻辑硬编码进业务 HTTP 调用里，导致无法复用、难测试、升级策略要改一堆地方。

• 节点发现必须解耦：从 DNS、Consul、Nacos 或静态配置获取地址列表，不应和请求发送耦合
• 健康检查不能靠“第一次请求失败再换”：这会放大错误，应主动探活（如定期发 HEAD /health）
• 策略切换需零重启：比如从 RoundRobin 切到 LeastConnections，不能重建整个 client 实例

用 go-kit/transport/http + sd 实现标准服务发现与负载均衡

这是 Go 生态中较成熟、符合微服务分层思想的做法：sd（service discovery）负责拉取/监听节点，transport/http 将其转化为可调用的 endpoint.Endpoint，中间由 lb 包提供策略。

关键不是自己写轮询算法，而是正确组装这些组件。下面是最小可行示例：

package main

import (
	"context"
	"time"
	"github.com/go-kit/kit/sd"
	"github.com/go-kit/kit/sd/lb"
	httptransport "github.com/go-kit/kit/transport/http"
)

func main() {
	// 1. 构建实例列表（这里用静态，实际可替换为 consul.Instancer）
	instancer := sd.NewStaticInstancer([]string{
		"http://10.0.1.10:8080",
		"http://10.0.1.11:8080",
		"http://10.0.1.12:8080",
	}, nil)

	// 2. 创建负载均衡器（默认 RoundRobin）
	balancer := lb.NewRoundRobin(instancer)

	// 3. 构造 endpoint（实际业务接口封装）
	var endpoint httptransport.Endpoint
	endpoint = httptransport.NewClient(
		"POST",
		lb.NewOpportunist(balancer), // 注意：这里传的是 balancer 的 opportunistic wrapper
		encodeRequest,
		decodeResponse,
	).Endpoint()

	// 后续用 endpoint(context.Background(), req) 发起带负载均衡的调用
}

注意 lb.NewOpportunist(balancer) —— 它不是每次调用都选新节点，而是在首次失败时才 fallback 到下一个实例，适合配合重试使用。若要严格轮询，应结合 lb.Retry 中间件。

grpc-go 场景下如何让 ClientConn 自动负载均衡

gRPC 官方不内置服务发现，但提供了 balancer 接口和 resolver 机制。你不能只写 grpc.Dial("10.0.1.10:9000")，而要注册自定义 resolver，让 gRPC 运行时能感知一组地址并交由 balancer 调度。

• resolver 负责“找谁”：监听 Consul 变更，返回 resolver.State{Addresses: []resolver.Address{...}}
• balancer 负责“怎么连”：实现 Picker 接口，决定每次 Invoke() 用哪个 SubConn
• 务必启用 WithDefaultServiceConfig(`{"loadBalancingPolicy":"round_robin"}`)，否则默认用 p2c（仅限部分版本），且不生效

最简实践是直接使用社区封装好的包，例如 github.com/sercand/kuberesolver（适配 Kubernetes Service）或 github.com/grpc-ecosystem/go-grpc-middleware/resolver/dns（DNS SRV）。避免从零实现 Picker，除非你明确需要自定义权重或熔断逻辑。

自研简易轮询器时最容易漏掉的三个细节

如果项目轻量、依赖少，或只是临时验证，可以手写一个 RoundRobinBalancer。但以下三点不处理，上线后大概率出问题：

• 并发安全：index 字段必须用 atomic.AddUint64(&b.index, 1)，而非 b.index++ —— 否则高并发下会跳过节点或重复选中
• 节点变更不感知：新增节点后，旧的 index % len(oldList) 会越界 panic；需加锁同步更新列表和重置 index
• 无健康隔离：某个节点连续超时 3 次，应临时剔除（加入 blacklist map），并在后台异步探测恢复，而不是等下次轮到它再失败一次

真正麻烦的从来不是“怎么选”，而是“什么时候不该选”和“选错了怎么兜底”。生产环境建议优先用 go-kit/sd 或 grpc-go 官方推荐链路，它们已覆盖连接复用、空闲驱逐、延迟统计等隐性需求。