非常游戏网
如何在Python中实现异步的gRPC通信_使用grpcio-reflection提供的异步支持

如何在Python中实现异步的gRPC通信_使用grpcio-reflection提供的异步支持

2026-05-29日常编程65427

grpcio-reflection 无异步支持因其 servicer 继承同步基类、无 AsyncServicer 实现且依赖同步 I/O;异步调用反射需用 grpc.aio.Channel + stub.ServerReflectionInfo 并 await,自研异步服务端须重写方法并缓存 FileDescriptorSet。

Python 的 grpcio 官方库从 1.39 版本起才正式支持异步客户端和服务端,而 grpcio-reflection 本身**不提供任何异步能力**——它只是为服务端添加 gRPC 反射协议(Reflection Protocol)的辅助包,所有反射逻辑仍运行在同步上下文中。想用异步方式调用反射接口(比如 ServerReflection.GetExtension 或动态发现服务),必须自己封装或绕过它。

为什么 grpcio-reflection 没有 async 支持

grpcio-reflection 的核心是实现 reflection_pb2_grpc.ServerReflectionServicer,它继承自同步基类,所有方法签名都是普通函数(非 async def)。即使你启用了 grpc.aio.Server,这个包也不会自动适配:它的 servicer 无法被异步 server 注册,强行注册会报 TypeError: expected Servicer, got AsyncServicer

  • 它依赖 reflection_pb2 和原始 grpc.server(),底层绑定的是 C extension 的同步 I/O
  • 没有提供 reflection_pb2_grpc.ServerReflectionAsyncServicer 或类似接口
  • 其用途仅限于让 grpcurlevans 等工具能查询服务定义,不是为程序内动态调用设计的

想在 async Python 中做 gRPC 反射调用,该怎么做

如果你的目标是「在异步代码里获取远程服务的 proto 描述」,不能靠 grpcio-reflection 提供服务端反射能力来反向调用,而应直接使用异步客户端发起反射请求。前提是目标服务端已启用反射(无论用同步还是异步 server 启的)。

  • 安装带异步支持的客户端:pip install grpcio>=1.39
  • grpc.aio.Channel 连接服务端,再创建 reflection_pb2_grpc.ServerReflectionStub(注意:stub 是同步/异步共用的,但底层 channel 决定行为)
  • 调用方法时需用 await,例如:await stub.ServerReflectionInfo(iter([request])),因为返回的是 grpc.aio.StreamStreamCall
  • 实际请求体需手动构造 reflection_pb2.ServerReflectionRequest,比如 file_by_filenamelist_services

示例片段:

Python 3.14.3

微软官方的 Python 扩展,是 VS Code 安装量最高的扩展(209M+)。集成 IntelliSense(通过 Pylance)、调试(通过 Python Debugger)、代码检查、格式化、重构和单元测试等功能。支持 Jupyter Notebook、虚拟环境管理和多 Python 版本切换。

import grpc.aio
import reflection_pb2, reflection_pb2_grpc

channel = grpc.aio.insecure_channel("localhost:50051")
stub = reflection_pb2_grpc.ServerReflectionStub(channel)

request = reflection_pb2.ServerReflectionRequest(
    list_services=""
)
async for response in stub.ServerReflectionInfo(iter([request])):
    print(response.list_services_response.service)

如果要自己实现异步反射服务端(替代 grpcio-reflection)

目前没有现成的异步版 grpcio-reflection 包。若必须在 grpc.aio.Server 上暴露反射接口,得手写一个 AsyncServerReflectionServicer,继承 reflection_pb2_grpc.ServerReflectionServicer 并重写全部方法为 async def,同时把内部 proto 解析逻辑(如读取 service_pb2.FileDescriptorSet)改为非阻塞方式。

  • 关键难点在于:gRPC Python 的异步 server 要求所有 servicer 方法返回 Awaitable,但原反射逻辑大量使用 descriptor_pool.Default() 和同步文件读取
  • 你可以提前将 FileDescriptorSet 序列化为 bytes 并缓存,避免每次请求都解析 .proto;否则 await 点卡在 CPU-bound 解析上,失去异步意义
  • 别试图 patch grpcio-reflection 的源码——它的模块结构和 import 链不兼容 grpc.aio 的 event loop 绑定机制

真正麻烦的地方不在代码怎么写,而在于反射本身是个低频、调试向功能,绝大多数生产服务根本不会开启它;一旦开了,又往往被当成“理所当然存在”的基础设施,结果在异步迁移时才发现它成了唯一没 async 化的环节。