分布式部署 Go 框架的故障处理和容错机制

import (
    "context"
    "errors"

    "github.com/hashicorp/consul/api"
    "google.golang.org/grpc"
)

// 创建一个 gRPC 客户端连接，并包含重试和超时机制
func CreateClientConn(ctx context.Context, service string) (*grpc.ClientConn, error) {
    consulClient, err := api.NewClient(consul.DefaultConfig())
    if err != nil {
        return nil, err
    }

    serviceEntry, _, err := consulClient.Catalog().Service(service, "", nil)
    if err != nil {
        return nil, err
    }

    if len(serviceEntry) == 0 {
        return nil, errors.New("no service instances found")
    }

    addr := serviceEntry[0].ServiceAddress + ":" + strconv.Itoa(serviceEntry[0].ServicePort)

    // 使用指数退避重试
    retryPolicy := backoff.NewExponentialBackOff()
    retryPolicy.MaxInterval = 30 * time.Second

    opts := []grpc.DialOption{
        grpc.WithBackoffConfig(backoff.Config{
            MaxDelay: retryPolicy.MaxInterval,
            Backoff:  retryPolicy.Backoff,
        }),
        grpc.WithTimeout(10 * time.Second),
    }

    return grpc.Dial(addr, opts...)
}