gRPC客户端负载均衡通过自定义Resolver和round_robin策略实现，结合服务发现（如etcd/Consul）动态获取后端地址，示例中注册demo方案返回多个地址并轮询分发请求，客户端连接时指定loadBalancingPolicy为round_robin，调用时均匀访问不同端口的服务实例，生产环境需配合健康检查与动态服务发现确保高可用。
在使用 Golang 和 gRPC 构建分布式系统时，客户端负载均衡是一个关键优化点。它可以让 gRPC 客户端将请求均匀地分发到多个服务实例上，避免单点压力过大，提高系统的可用性和性能。
理解 gRPC 负载均衡机制
gRPC 默认支持客户端负载均衡，但需要配合服务发现机制（如 DNS、etcd、Consul 等）来动态获取后端服务地址列表。gRPC Go 版本内置了 round_robin（轮询）负载均衡策略，可直接使用。
核心流程包括：
- 通过解析器（Resolver）获取服务的多个后端地址
- 使用负载均衡策略（如 round_robin）选择目标地址发起调用
- 连接管理与健康检查（可选）
实现自定义服务发现 + 轮询负载均衡
下面是一个基于手动注册后端节点并使用内置 round_robin 的示例。
立即学习“go语言免费学习笔记（深入）”；
注意：这里使用一个简单的静态节点列表模拟服务发现，生产环境可替换为 etcd 或 Consul。
1. 定义 Resolver Scheme
首先注册一个自定义的解析器方案，用于返回多个后端地址：
package main
import (
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
"google.golang.org/grpc/resolver"
"log"
"context"
pb "your_project/proto" // 替换为你的 proto 编译路径
)
const scheme = "demo"
type DemoResolverBuilder struct{}
func (b *DemoResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error) {
r := &DemoResolver{
cc: cc,
addresses: []resolver.Address{
{Addr: "localhost:50051"},
{Addr: "localhost:50052"},
{Addr: "localhost:50053"},
},
}
cc.UpdateState(resolver.State{Addresses: r.addresses})
return r, nil
}
func (b *DemoResolverBuilder) Scheme() string {
return scheme
}
type DemoResolver struct {
cc resolver.ClientConn
addresses []resolver.Address
}
func (r *DemoResolver) ResolveNow(o resolver.ResolveNowOptions) {}
func (r *DemoResolver) Close() {}2. 注册解析器并创建 gRPC 连接
```go func main() { // 注册自定义 resolver resolver.Register(&DemoResolverBuilder{})// 连接使用自定义 scheme
conn, err := grpc.Dial(
scheme+":///service",
grpc.WithDefaultServiceConfig(`{"loadBalancingPolicy":"round_robin"}`),
grpc.WithTransportCredentials(insecure.NewCredentials()),
)
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
client := pb.NewYourServiceClient(conn)
// 发起多次调用观察负载均衡效果
for i := 0; i < 10; i++ {
resp, err := client.YourMethod(context.Background(), &pb.YourRequest{Data: "test"})
if err != nil {
log.Printf("call failed: %v", err)
continue
}
log.Printf("response: %s", resp.GetMessage())
}}
服务端配合（验证负载）
每个后端服务启动时监听不同端口，并返回自身标识：
```go // 简化服务端逻辑 func startServer(port string) { lis, _ := net.Listen("tcp", ":"+port) s := grpc.NewServer() pb.RegisterYourServiceServer(s, &server{Port: port}) log.Printf("server listening on %s", port) s.Serve(lis) } type server struct{ Port string } func (s *server) YourMethod(ctx context.Context, req *pb.YourRequest) (*pb.YourResponse, error) { return &pb.YourResponse{Message: "Hello from " + s.Port}, nil }
分别启动三个服务实例（50051, 50052, 50053），客户端调用时会看到输出来自不同端口，说明轮询生效。
生产建议
- 使用 etcd 或 Consul 实现动态服务发现，Resolver 可监听节点变化并更新 Address 列表
- 开启健康检查（gRPC Health Checking Protocol）自动剔除不可用节点
- 考虑使用 gRPC-Go 的 xds 扩展支持更复杂的负载策略（如最少连接）
- 合理设置连接超时和重试策略提升容错能力
基本上就这些。Golang 的 gRPC 生态对负载均衡支持良好，关键是实现正确的 Resolver 并启用合适的负载策略。不复杂但容易忽略的是服务发现的实时性和健康检测机制。
