在 Go 框架中实现高可用分布式部署

// 定义服务 struct，用于在 Consul 中注册服务
type Service struct {
    ID   string
    Name string
    Port int
}

// RegisterConsul 注册服务到 Consul
func RegisterConsul(service Service) error {
    // 创建 Consul 客户机
    client, err := consul.NewClient(config.DefaultConfig())
    if err != nil {
        return err
    }

    // 注册服务
    reg := &consul.AgentServiceRegistration{
        ID:      service.ID,
        Name:    service.Name,
        Port:    service.Port,
        Address: "127.0.0.1", // 实际部署时替换为机器 IP 地址
    }
    return client.Agent().ServiceRegister(reg)
}

// ResolveConsul 解决 Consul 中的服务
func ResolveConsul(name string) (*consul.ServiceEntry, error) {
    // 创建 Consul 客户机
    client, err := consul.NewClient(config.DefaultConfig())
    if err != nil {
        return nil, err
    }

    // 解决服务
    services, err := client.Agent().ServicesWithFilter(fmt.Sprintf("Service == \"%s\"", name))
    if err != nil {
        return nil, err
    }

    // 返回第一个可用服务
    for _, service := range services {
        return service, nil
    }
    return nil, errors.New("service not found")
}

// ConnectService 使用 gRPC Connect 方法连接到服务
func ConnectService(addr string) (*grpc.ClientConn, error) {
    // 建立 gRPC 连接
    conn, err := grpc.Dial(addr, grpc.WithInsecure())
    if err != nil {
        return nil, err
    }
    return conn, nil
}