Go中实现客户端负载均衡的Round Robin策略需维护服务实例列表并原子递增索引取模选择节点，配合sync.RWMutex保护动态更新、健康检查与故障剔除机制。
在 Go 语言中实现客户端负载均衡（Client-side Load Balancing）并使用 Round Robin 策略，核心是：自己维护一个服务实例列表，在每次请求前按轮询顺序选择一个节点，无需依赖外部 LB（如 Nginx、Consul Fabio），适合微服务直连或 gRPC 场景。
准备服务实例列表
你需要先获取后端服务的多个地址（例如从配置文件、DNS、服务发现中心如 etcd/Consul 获取）。最简形式是一个 []string，比如：
[]string{"10.0.1.10:8080", "10.0.1.11:8080", "10.0.1.12:8080"}
建议封装成结构体，支持动态更新（如监听服务发现变化）：
立即学习“go语言免费学习笔记（深入）”；
- 用
sync.RWMutex保护实例列表读写 - 提供
Add(addr)/Remove(addr)方法 - 避免热更新时出现空列表，可设默认兜底地址
实现线程安全的 Round Robin 选择器
关键点是“原子递增索引 + 取模”，避免并发下选到相同节点或越界。推荐用 atomic.Int64：
type RoundRobinBalancer struct {
addrs []string
mu sync.RWMutex
index atomic.Int64
}
func (r *RoundRobinBalancer) Next() string {
r.mu.RLock()
defer r.mu.RUnlock()
if len(r.addrs) == 0 {
return ""
}
n := int(r.index.Add(1) % int64(len(r.addrs)))
return r.addrs[n]
}
注意：Add(1) 返回的是新值，所以首次调用会是 1 → 取模后为 1%3=1，第二次为 2，第三次为 0（因为 3%3=0），自然形成循环。
集成到 HTTP 或 gRPC 客户端
HTTP 场景：替换 http.Client.Transport.RoundTrip，或更简单——在每次发请求前调用 balancer.Next() 拼接 URL：
- 用
http.NewRequest("GET", "http://"+addr+"/health", nil) - 配合
context.WithTimeout防止单点卡死 - 失败时可 fallback 到下一个节点（需重试逻辑）
gRPC 场景：实现 grpc.Balancer 接口较重，推荐轻量方案——用 grpc.WithContextDialer 自定义拨号器：
- 拨号前调用
balancer.Next()获取目标地址 - 返回
net.Conn时复用标准net.Dial - 避免每次 RPC 都新建连接，可搭配
grpc.WithBlock()+ 连接池
增强可用性：健康检查与故障剔除
纯 Round Robin 不感知节点状态，生产环境必须加探测机制：
- 启动后台 goroutine，定期对每个 addr 发送
HEAD /health或 TCP 连通性检测 - 连续失败 N 次后调用
balancer.Remove(addr) - 恢复后自动重新加入（需记录 lastFailAt 时间戳+指数退避）
- 可选：给每个 addr 绑定权重或失败计数，升级为 Weighted Round Robin
基本上就这些。不复杂但容易忽略线程安全和健康反馈，上线前务必压测节点切换与故障恢复行为。
