gRPC C++ 异步一元调用如何确保请求已成功发送至服务端

问题根因 #

• gRPC 异步 API 本身就是非阻塞提交设计：你调用Finish仅会将请求和完成事件注册到 gRPC 内部任务队列，不会同步等待请求序列化、网络发送完成。所有 IO 操作、状态变更的调度全依赖CompletionQueue的轮询逻辑，也就是你代码中调用CompletionQueue::Next()/AsyncNext()的部分。你在Finish之后直接断点停住了执行线程，轮询逻辑被中断，gRPC 内部的 IO 任务自然不会被调度执行。
• 首次请求存在额外的连接初始化开销：gRPC Channel 默认是懒加载连接，第一次发请求时才会启动 DNS 解析、TCP 握手、TLS 协商（若启用）、HTTP/2 协议交互的流程，这些操作也全部是异步挂载到CompletionQueue上等待轮询调度的，所以首次请求的延迟现象会特别明显。后续请求可以复用已经建立完成的连接，请求提交后 IO 处理速度快，就会出现Finish调用后很快就完成发送的现象，和你观测到的结果完全吻合。

解决方案 #

• 如果需要确认请求已经发出，可以在调用Finish后先轮询一段时间CompletionQueue再断点，就能观测到即使停住断点，请求也已经发送到服务端。
• 如果要避免首次请求的延迟，可以提前初始化连接：调用channel->GetState(true)主动触发连接建立，轮询等待通道进入GRPC_CHANNEL_READY状态后再发起请求即可。

内容的提问来源于stack exchange，提问作者bumbling-tadpole