社区微信群开通啦，扫一扫抢先加入社区官方微信群
社区微信群
整个demo是在上一篇springboot+GRPC传输简单数据的基础上添加的内容，如有什么不明白的地方可参考上一篇文档。
整个demo的实现步骤：
在demo-proto接口文件中新增流式数据消息格式，在流式返回数据中添加一个集合对象，实现返回数据中可有集合对象。以及添加传输流式数据的StreamServerHello方法
代码如下所示：
//流式响应消息
message StreamResponse{
int32 code=1;
string message=2;
int32 count=3;
repeated CommonResponse record=4;
}
service Simple{
rpc Hello(CommonRequest) returns(CommonResponse){}
rpc StreamServerHello(CommonRequest) returns(stream StreamResponse){}
}
把定义的传输消息的内容、方法添加完成后，使用build方法生成对应的程序代码，为服务端调用做好准备。
代码如下所示:
方法具体代码如下：
注：在这里没有把返回的数据使用JSON进行处理，只是简单的把返回的数据转成字符串作为返回对象。
代码如下：
分别启动客户端和服务端
服务端启动结果如图所示：
客户端启动结果如图所示：
demo最后运行结果如下所示：
本文整个demo的实现在上一篇文档的基础上完成的，如果有什么不明白的地方可参考上一篇文章gRPC----gRPC(springboot)传输简单数据
如果觉得我的文章对您有用，请随意打赏。你的支持将鼓励我继续创作！
