如何使用Go gRPC客户端直接拨号多IP地址（无需服务发现）

你遇到的错误很明确——grpc.Dial并不支持直接用逗号分隔多个地址作为参数，它会把整个字符串当作单一的网络地址解析，自然会因为格式错误抛出"too many colons"的异常。要实现直接指定多个IP连接且不用服务发现，你需要借助gRPC的Resolver（地址解析器）和负载均衡策略来完成，下面是两种实用的实现方案：

方案一：自定义全局静态Resolver #

这种方法适合需要在多个地方复用同一地址列表的场景，我们可以注册一个自定义的Resolver，让它直接返回我们指定的所有服务器地址：

import (
    "google.golang.org/grpc"
    "google.golang.org/grpc/resolver"
)

// 自定义Resolver Builder，负责生成Resolver实例
type staticResolverBuilder struct {
    addresses []resolver.Address
}

func (b *staticResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error) {
    // 把我们的静态地址列表推送给客户端连接
    if err := cc.UpdateState(resolver.State{Addresses: b.addresses}); err != nil {
        return nil, err
    }
    return &staticResolver{}, nil
}

func (b *staticResolverBuilder) Scheme() string {
    return "static" // 自定义的Scheme标识
}

// 空实现Resolver接口的方法，因为我们不需要动态更新地址
type staticResolver struct{}
func (r *staticResolver) ResolveNow(resolver.ResolveNowOptions) {}
func (r *staticResolver) Close() {}

// 初始化静态Resolver，传入你的服务器地址列表
func initStaticResolver(serverAddrs []string) {
    var resolverAddrs []resolver.Address
    for _, addr := range serverAddrs {
        resolverAddrs = append(resolverAddrs, resolver.Address{Addr: addr})
    }
    resolver.Register(&staticResolverBuilder{addresses: resolverAddrs})
}

然后在连接时使用这个自定义的Scheme：

func main() {
    // 初始化Resolver，传入你的两个gRPC服务器地址
    initStaticResolver([]string{"192.168.1.12:8800", "192.168.1.13:8800"})

    // 连接时使用自定义的static scheme，目标名称可以随便填（比如"grpc-servers"）
    conn, err := grpc.Dial(
        "static:///grpc-servers",
        grpc.WithInsecure(), // 注意：生产环境请替换为TLS配置，不要用这个
        grpc.WithBalancerName(grpc.RoundRobin), // 启用轮询负载均衡
    )
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    // 这里就可以正常创建gRPC客户端Stub并调用接口了
}

方案二：使用手动Resolver（更简洁，适合单场景） #

如果你用的是grpc-go v1.41及以上版本，可以使用官方提供的manual Resolver，无需全局注册，更灵活：

import (
    "google.golang.org/grpc"
    "google.golang.org/grpc/resolver"
    "google.golang.org/grpc/resolver/manual"
)

func main() {
    // 创建一个手动Resolver Builder
    mr := manual.NewBuilder()

    // 连接时指定使用这个手动Resolver
    conn, err := grpc.Dial(
        mr.Scheme() + ":///test-target",
        grpc.WithInsecure(), // 生产环境替换为TLS配置
        grpc.WithResolvers(mr),
        grpc.WithBalancerName(grpc.RoundRobin), // 启用轮询负载均衡
    )
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    // 更新Resolver的地址列表，传入你的两个服务器地址
    mr.UpdateState(resolver.State{
        Addresses: []resolver.Address{
            {Addr: "192.168.1.12:8800"},
            {Addr: "192.168.1.13:8800"},
        },
    })

    // 接下来就可以正常使用gRPC客户端了
}

关键说明 #

• 两种方案的核心都是通过Resolver向gRPC客户端提供多个后端地址，配合RoundRobin负载均衡策略，客户端会自动在多个服务器之间轮询调用。
• 生产环境注意：绝对不要使用grpc.WithInsecure()，请配置合法的TLS证书来保证gRPC通信的安全性。

内容的提问来源于stack exchange，提问作者honglin xiao