调用grpc::CompletionQueue的AsyncNext/Next返回ok=false时如何获取gRPC状态码？

当grpc::CompletionQueue的AsyncNext或Next返回ok=false时，这个返回值仅说明队列本身的状态（比如队列被关闭、无待处理事件），不会携带具体的RPC调用错误状态。要拿到对应的gRPC状态码，得通过对应的异步调用对象（比如ClientAsyncReader）的Finish方法，但关键是要找对调用时机。

正确操作流程 #

别等CompletionQueue返回ok=false再去调Finish，正确的做法是在发起异步RPC时，就把Finish操作注册到队列里，和Read/Write这类操作一起等待事件触发：

1. 初始化RPC调用，调用ClientAsyncReader::StartCall并绑定到目标CompletionQueue。
2. 调用ClientAsyncReader::Read读取响应，把操作注册到队列。
3. 准备一个grpc::Status对象，调用ClientAsyncReader::Finish(&status, tag)，将Finish操作也注册到队列。
4. 当CompletionQueue::AsyncNext拿到Finish对应的tag时，直接检查status对象，就能获取到具体的状态码（比如GRPC_STATUS_UNAVAILABLE、GRPC_STATUS_DEADLINE_EXCEEDED）。

为什么之前调用Finish返回成功？ #

如果等CompletionQueue已经返回ok=false（队列已关闭）再调用Finish，此时RPC调用的状态可能已经被内部清理，Finish操作无法正确捕获实际的错误状态，自然会返回默认的成功状态。

根据状态码处理重试/退出 #

拿到grpc::Status后，通过status.error_code()获取具体状态码，再做判断：

• 可重试场景：遇到GRPC_STATUS_UNAVAILABLE（服务不可用）、GRPC_STATUS_DEADLINE_EXCEEDED（调用超时）、GRPC_STATUS_RESOURCE_EXHAUSTED（资源耗尽）这类状态时，可以重新发起RPC调用。
• 直接退出场景：如果是GRPC_STATUS_INVALID_ARGUMENT（参数错误）、GRPC_STATUS_PERMISSION_DENIED（权限不足）这类状态，说明调用本身存在问题，没必要重试，直接终止流程即可。

注意事项 #

• 每个异步RPC调用都必须执行一次Finish操作，不管调用成功还是失败，否则会造成资源泄漏。
• 同一个异步调用对象（比如同一个ClientAsyncReader实例）只能调用一次Finish，重复调用会导致未定义行为。

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