gRPC 实现客户端流传输

gRPC 客户端流传输允许客户端向服务器发送一组消息，但文档表明服务器通常在收到所有客户端请求后才发送响应。然而，在 C++ 中，开发者需要一种方法来在流中间捕获服务器响应以停止发送更多数据。本文探讨了两种解决方案：一是等待写入失败并调用 finish 接收服务器响应，二是切换到双向流。

客户端流式传输的官方 gRPC 文档指出：

服务器通常但不一定在收到所有客户端请求后发回单个响应......

我想做的是在流中间捕获服务器响应以停止发送更多数据。

在 Go 中，我可以使用 RecvMsg 启动一个新的 goroutine 来侦听来自服务器的消息，但我找不到在 C++ 中执行相同操作的方法。看来 ClientWriter 不提供这种功能。

一种解决方案是使用双向流，但想知道是否有其他方法可以在 C++ 中实现此目的。

解决方案

一旦服务器发送响应和状态并在客户端（即客户端 gRPC 堆栈）接收回来，后续的 Write() 尝试将开始失败。第一个失败的 Write() 是向客户端发出的信号，表明它应该停止写入并完成 RPC。

所以这里的两个选项是： 1. 等待写入失败，然后调用 finish 接收服务器的响应和状态。 2. 如果客户端确实想在调用 Finish 之前读取服务器的响应，请切换到双向流。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。