Go与gRPC：能否在应用运行时动态创建Protobuf类并调用方法？

要实现运行时基于用户提供的.proto文件、JSON配置和请求数据调用gRPC方法，核心是利用Protobuf动态解析API和gRPC动态调用能力，不需要提前编译.proto文件。以下是具体实现步骤：

1. 动态解析Protobuf文件，提取核心描述符 #

首先加载用户上传的.proto文件，解析出服务、方法、请求/响应消息的描述信息（Descriptor），这是后续所有操作的基础。

以Python为例：

from google.protobuf import descriptor_pool, descriptor_pb2

# 读取用户上传的.proto文件内容
with open("protobuf.proto", "r") as f:
    proto_content = f.read()

# 将.proto内容解析为可识别的描述符格式
file_descriptor_proto = descriptor_pb2.FileDescriptorProto()
descriptor_pool.Default().AddSerializedFile(file_descriptor_proto.SerializeToString())

# 根据用户配置获取对应描述符
service_desc = descriptor_pool.Default().FindServiceByName("Unary")
method_desc = service_desc.FindMethodByName("GetServerResponse")
request_msg_desc = descriptor_pool.Default().FindMessageTypeByName("protobuf_all_modes.MessageRequest")
response_msg_desc = descriptor_pool.Default().FindMessageTypeByName("protobuf_all_modes.MessageResponse")

2. 将JSON请求数据序列化为Protobuf消息 #

利用动态生成的消息类型，把用户提供的JSON请求数据转换成Protobuf二进制格式。

Python示例：

from google.protobuf.json_format import Parse
from google.protobuf.message import Message

# 基于请求消息描述符创建动态消息类
RequestMessage = type("RequestMessage", (Message,), {"DESCRIPTOR": request_msg_desc})()

# 读取用户上传的JSON请求文件
with open("grpc_request_data.json", "r") as f:
    request_json = f.read()

# 把JSON解析为Protobuf消息
Parse(request_json, RequestMessage)

3. 建立gRPC连接并动态调用指定方法 #

通过gRPC的通用调用接口，传入之前获取的方法描述符、序列化/反序列化逻辑，完成方法调用。

import grpc

# 建立gRPC通道（服务器地址需根据实际场景获取，比如从用户配置补充）
channel = grpc.insecure_channel("localhost:50051")

# 调用Unary类型方法
response = channel.unary_unary(
    method_desc.full_name,
    request_serializer=RequestMessage.SerializeToString,
    response_deserializer=lambda data: response_msg_desc._concrete_class().FromString(data)
)(RequestMessage)

# 将响应转回JSON（可选，用于返回给用户）
from google.protobuf.json_format import MessageToJson
print(MessageToJson(response))

4. 关键边界处理 #

• 合法性校验：提前检查.proto文件语法是否正确，用户指定的服务、方法、消息名称是否存在于解析后的描述符中
• 数据校验：确保JSON请求数据与消息类型的字段匹配（比如字段名、数据类型），避免序列化失败
• 异常捕获：处理gRPC连接超时、服务端错误、序列化/反序列化失败等异常情况

如果使用Java、Go等其他语言，核心思路一致：用对应语言的Protobuf动态解析API（如Java的Descriptors类、Go的protoreflect包）获取描述符，再结合gRPC的通用调用工具完成方法调用。

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