如何在C# .NET中基于运行时加载Proto实现通用gRPC服务？

针对你需要托管数百个gRPC服务、统一处理请求转发的需求，无需从零实现gRPC底层支持，可通过以下基于官方生态的步骤完成：

1. 安装必要NuGet包 #

首先引入核心依赖：

Grpc.AspNetCore
Google.Protobuf
Grpc.Reflection
Google.Protobuf.Reflection

2. 动态加载Proto文件并生成服务描述符 #

你可以通过Google.Protobuf.Reflection.DescriptorPool编译目录中的.proto文件，生成对应的FileDescriptor集合，进而提取所有服务定义：

using Google.Protobuf.Reflection;
using System.IO;

// 初始化描述符池
var descriptorPool = new DescriptorPool();
var protoDir = "./Protos"; // 你的proto文件目录

foreach (var protoFile in Directory.GetFiles(protoDir, "*.proto"))
{
    var content = File.ReadAllText(protoFile);
    // 编译proto文件到描述符池
    var fileDescriptor = descriptorPool.AddFile(protoFile, content);
    // 若有跨文件引用，需确保依赖文件已优先加载
}

// 获取所有服务描述符
var allServices = descriptorPool.Files
    .SelectMany(file => file.Services)
    .ToList();

如果proto文件有复杂依赖或需兼容bufbuild规范，也可先用buf工具预生成FileDescriptorSet（.desc文件），再直接加载：

using Google.Protobuf.Reflection;

var descriptorSet = FileDescriptorSet.Parser.ParseFrom(File.ReadAllBytes("./proto-descriptors.desc"));
var descriptorPool = new DescriptorPool();
foreach (var fileProto in descriptorSet.File)
{
    descriptorPool.Add(fileProto);
}
var allServices = descriptorPool.Files.SelectMany(f => f.Services).ToList();

3. 注册通用gRPC请求处理器 #

基于ServerServiceDefinition动态创建每个服务的绑定，将所有服务方法指向同一个通用处理逻辑：

using Grpc.Core;
using Google.Protobuf;

// 通用请求处理函数
async Task<IMessage> GenericHandler(IMessage request, ServerCallContext context)
{
    // 1. 将gRPC请求转换为目标协议（根据需求实现）
    // 2. 转发请求到外部服务
    // 3. 将外部响应转换回gRPC消息并返回
    var responseType = context.Method.ResponseType;
    return responseType.DefaultInstance; // 示例返回默认实例，需替换为实际响应逻辑
}

// 构建所有服务的ServerServiceDefinition
var serviceDefinitions = new List<ServerServiceDefinition>();
foreach (var service in allServices)
{
    var serviceBuilder = ServerServiceDefinition.CreateBuilder(service.FullName);
    foreach (var method in service.Methods)
    {
        // 根据方法类型绑定通用处理器，这里以Unary为例
        if (method.IsUnary)
        {
            serviceBuilder.AddMethod(method, async (request, context) =>
            {
                return await GenericHandler(request, context);
            });
        }
        // 如需支持流式方法（ServerStreaming/ClientStreaming/Duplex），可添加对应分支处理
    }
    serviceDefinitions.Add(serviceBuilder.Build());
}

4. 启用gRPC反射服务 #

为让客户端通过gRPC反射发现动态加载的服务，需将生成的服务描述符注册到反射服务中：

using Grpc.Reflection;
using Grpc.Reflection.V1Alpha;

// 创建反射服务所需的描述符集合
var reflectionDescriptors = descriptorPool.Files.Select(f => f.FileDescriptorProto).ToList();
var reflectionService = ServerReflectionService.CreateService(reflectionDescriptors);

// 在ASP.NET Core中注册所有服务
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddGrpc();

var app = builder.Build();

// 注册动态生成的gRPC服务
foreach (var serviceDef in serviceDefinitions)
{
    app.MapGrpcService(serviceDef);
}
// 注册反射服务
app.MapGrpcService(reflectionService);

app.Run();

关键说明 #

• 流式请求处理：若服务包含流式方法，需在通用处理器中实现IAsyncStreamReader和IAsyncStreamWriter的对应逻辑。
• 性能优化：若proto文件数量极大，建议提前用buf或protoc的--descriptor_set_out参数预编译FileDescriptorSet，避免运行时重复编译。
• 错误处理：在通用处理器中添加异常捕获与转换，确保返回符合gRPC规范的错误信息。

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