我正在尝试构建一个异步gRPC C++客户端,它使用ClientAsyncReaderWriter实例向服务器发送流消息,或从服务器接收流消息。客户端和服务器在需要的时候相互发送消息。ClientAsyncReaderWriter实例有一个绑定的完成队列。我尝试通过调用Next()和AsyncNext()函数来检查完成队列,以查看是否有任何事件表明有来自服务器的消息。但是,即使有来自服务器的消息,完成队列也没有事件。Read the
我使用异步C++ client for gRPC,但是我不能为每个请求设置超时,当我使用同步客户端时,我可以通过ClientContext.set_deadline()来设置超时,但是这个方法在异步客户端不起作用;
我担心当gRPC服务器崩溃时,一些请求将永远在完成队列中,但是我希望当完成队列中的请求在指定的时间内没有收到响应时,它可以通知该请求超时。