如何在C++异步gRPC客户端中获取gRPC状态

核心思路：区分CompletionQueue状态与服务端gRPC状态 #

AsyncNext返回的NextStatus仅表示CompletionQueue自身的操作状态（如操作完成、队列空、超时等），服务端返回的gRPC状态需要从RPC的具体操作对象或拦截器中获取，以下是两种可靠方案：

方案1：通过RPC操作的Finish方法直接获取 #

在异步RPC完成（即AsyncNext返回GRPC_OP_COMPLETE）后，调用对应RPC调用对象的Finish方法，即可拿到服务端返回的grpc::Status。以异步Unary调用为例：

// 假设已经发起异步Unary调用，绑定了tag到CompletionQueue
void HandleRpcCompletion(bool ok) {
    if (!ok) {
        // 处理队列层面的错误，比如RPC被取消
        return;
    }
    grpc::Status status;
    YourResponseType response;
    // 调用Finish获取服务端返回的状态和响应
    async_call_->Finish(&response, &status, nullptr);
    if (!status.ok()) {
        // 这里拿到服务端返回的grpc-status，做错误处理
        std::cout << "RPC failed with code: " << status.error_code() 
                  << ", message: " << status.error_message() << std::endl;
    } else {
        // 处理正常响应
    }
}

// 主循环中等待CompletionQueue事件
void RunCompletionLoop() {
    void* tag;
    bool ok;
    while (cq_->AsyncNext(&tag, &ok, gpr_inf_future(GPR_CLOCK_REALTIME))) {
        static_cast<RpcTag*>(tag)->OnCompleted(ok);
    }
}

关键说明：不同类型的异步RPC（如Unary、Streaming）对应的获取状态方式略有差异，但核心都是在操作完成后调用对应Finish或类似方法提取grpc::Status。

方案2：通过Interceptor的POST_RECV_STATUS钩子捕获状态 #

你提到的POST_RECV_STATUS钩子确实可以用来拦截服务端返回的状态，但需要正确实现Interceptor接口并注册到Channel：

1. 实现自定义Interceptor：

class StatusInterceptor : public grpc::experimental::Interceptor {
public:
    void Intercept(grpc::experimental::InterceptorBatchMethods* methods) override {
        if (methods->QueryInterceptionHookPoint(grpc::experimental::POST_RECV_STATUS)) {
            grpc::Status* status = methods->GetRecvStatus();
            if (status != nullptr && !status->ok()) {
                // 捕获到服务端返回的错误状态，做处理
                std::cout << "Interceptor caught status: " << status->error_code() 
                          << ", " << status->error_message() << std::endl;
            }
        }
        // 继续执行后续拦截逻辑或完成调用
        methods->Proceed();
    }
};

2. 注册Interceptor到Channel：

grpc::experimental::InterceptorRegistry::Builder builder;
builder.RegisterInterceptorFactory(
    []() -> grpc::experimental::Interceptor* {
        return new StatusInterceptor();
    });
auto channel = grpc::CreateCustomChannel(
    "server_address:port",
    grpc::InsecureChannelCredentials(),
    builder.BuildChannelArgs());

注意事项：

• 确保使用的gRPC版本支持Interceptor API（gRPC 1.14+开始提供实验性支持，后续版本逐渐稳定）
• 钩子点POST_RECV_STATUS仅在服务端状态被接收后触发，需确保Interceptor正确注册且Proceed()被调用以保证流程正常执行

常见误区澄清 #

你之前尝试Interceptor未触发钩子，可能是以下原因：

• Interceptor未正确注册到Channel（需通过CreateCustomChannel传入带Interceptor的ChannelArgs）
• 钩子点判断逻辑错误（需用QueryInterceptionHookPoint确认当前钩子类型）
• RPC类型不匹配（比如某些Streaming RPC的钩子触发时机略有不同）

内容的提问来源于stack exchange，提问作者Fabiano Zaruch Chinasso