.NET Core 5中如何实现通用GRpc客户端，统一调用各服务Ping方法？

完全可以实现这样的通用客户端基类，不需要修改现有服务或Protobuf文件，核心思路是通过包装自动生成的GRpc客户端，结合类型转换与反射/表达式树调用，统一适配IClient接口。以下是具体实现方案：

1. 明确通用IClient接口 #

先确保你的通用接口定义清晰（假设所有服务的Ping方法请求/响应结构逻辑一致）：

public interface IClient
{
    Task<PingResponse> PingAsync(PingRequest request, CancellationToken cancellationToken = default);
}

// 通用请求/响应模型（与各服务Protobuf中的Ping结构对齐）
public class PingRequest
{
    public string Message { get; set; }
}

public class PingResponse
{
    public bool Success { get; set; }
    public string Reply { get; set; }
}

2. 创建泛型GRpc客户端基类 #

这个基类负责包装自动生成的GRpc客户端，通过反射/表达式树调用原生Ping方法，并处理通用模型与Protobuf模型的转换：

public abstract class GenericGrpcClient<TGrpcClient> : IClient
    where TGrpcClient : ClientBase<TGrpcClient>
{
    protected readonly TGrpcClient _innerClient;
    private readonly Func<object, CancellationToken, Task<object>> _pingFunc;

    protected GenericGrpcClient(TGrpcClient innerClient)
    {
        _innerClient = innerClient;
        // 用表达式树预编译PingAsync调用，避免反射性能损耗
        var requestParam = Expression.Parameter(typeof(object), "request");
        var ctParam = Expression.Parameter(typeof(CancellationToken), "cancellationToken");
        var pingMethod = typeof(TGrpcClient).GetMethod(
            nameof(PingAsync),
            new[] { GetGrpcRequestType(), typeof(CancellationToken) }) 
            ?? throw new InvalidOperationException($"类型 {typeof(TGrpcClient)} 未找到匹配的PingAsync方法");

        var methodCall = Expression.Call(
            Expression.Constant(innerClient),
            pingMethod,
            Expression.Convert(requestParam, GetGrpcRequestType()),
            ctParam);

        _pingFunc = Expression.Lambda<Func<object, CancellationToken, Task<object>>>(
            Expression.Convert(methodCall, typeof(Task<object>)),
            requestParam,
            ctParam).Compile();
    }

    public async Task<PingResponse> PingAsync(PingRequest request, CancellationToken cancellationToken = default)
    {
        var grpcRequest = ConvertToGrpcRequest(request);
        var grpcResponse = await _pingFunc(grpcRequest, cancellationToken);
        return ConvertFromGrpcResponse(grpcResponse);
    }

    // 抽象方法：由具体子类实现通用请求到Protobuf请求的转换
    protected abstract object ConvertToGrpcRequest(PingRequest request);
    // 抽象方法：由具体子类实现Protobuf响应到通用响应的转换
    protected abstract PingResponse ConvertFromGrpcResponse(object grpcResponse);
    // 抽象方法：获取当前GRpc客户端对应的Ping请求类型
    protected abstract Type GetGrpcRequestType();
}

3. 实现具体服务的客户端包装类 #

针对每个自动生成的GRpc客户端，创建对应的包装子类，仅需要实现类型转换逻辑：

// 示例：ServiceA的客户端包装
public class ServiceAClientWrapper : GenericGrpcClient<ServiceAClient>
{
    public ServiceAClientWrapper(ServiceAClient innerClient) : base(innerClient)
    {
    }

    protected override object ConvertToGrpcRequest(PingRequest request)
    {
        // 将通用PingRequest转换为ServiceA的Protobuf请求类型
        return new ServiceA.Protos.PingRequest
        {
            Message = request.Message
        };
    }

    protected override PingResponse ConvertFromGrpcResponse(object grpcResponse)
    {
        var serviceAResponse = (ServiceA.Protos.PingResponse)grpcResponse;
        return new PingResponse
        {
            Success = serviceAResponse.Success,
            Reply = serviceAResponse.Reply
        };
    }

    protected override Type GetGrpcRequestType()
    {
        return typeof(ServiceA.Protos.PingRequest);
    }
}

4. 主服务中动态创建与使用IClient #

通过工厂类封装客户端创建逻辑，仅需传入服务URL即可获取IClient实例：

public class GrpcClientFactory
{
    public IClient CreateClient<TGrpcClient, TWrapper>(string serviceUrl)
        where TGrpcClient : ClientBase<TGrpcClient>
        where TWrapper : IClient
    {
        var channel = GrpcChannel.ForAddress(serviceUrl);
        var innerClient = Activator.CreateInstance(typeof(TGrpcClient), channel) as TGrpcClient;
        return Activator.CreateInstance(typeof(TWrapper), innerClient) as IClient;
    }
}

// 主服务中使用示例
var clientFactory = new GrpcClientFactory();
IClient serviceAClient = clientFactory.CreateClient<ServiceAClient, ServiceAClientWrapper>("http://servicea:5001");
var pingResult = await serviceAClient.PingAsync(new PingRequest { Message = "主服务心跳检测" });

关键注意事项 #

• 确保所有服务的Protobuf文件中，Ping方法的参数、返回值结构逻辑一致，否则需要调整转换逻辑适配差异。
• 表达式树预编译相比反射性能更优，适合高频调用场景；如果对性能要求不高，也可以直接用反射简化代码。
• 所有包装类仅需实现类型转换，完全不影响现有服务的Protobuf定义与业务逻辑。

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