编码:隐匿在计算机软硬件背后的语言是讲述计算机工作原理的。不过,你千万不要因为“工作原理”之类的字眼就武断地认为,它是晦涩而难懂的。作者用丰富的想象和清晰的笔墨将看似繁杂的理论阐述得通俗易懂,你丝毫不会感到枯燥和生硬。更重要的是,你会因此而获得对计算机工作原理较深刻的理解。这种理解不是抽象层面上的,而是具有一定深度的,这种深度甚至不逊于“电气工程师”和“程序员”的理解。
文件：url80.ctfile.com/f/25127180-513751948-7417f9（访问密码：551685）
以下内容无关：
本文是《java版gRPC实战》系列的第四篇，前文掌握了服务端流，适合从服务端获取大量数据的场景，今天的目标是掌握客户端流类型的服务，包括服务提供方和使用方两侧的开发；
先来看看官方资料对客户端流式RPC的介绍：客户端写入一个消息序列并将其发送到服务器，同样也是使用流。一旦客户端完成写入消息，它等待服务器完成读取返回它的响应；
本文由以下几部分组成：
提前小结几个重要的知识点，稍后开发过程中要重点关注这几个地方；
在proto文件中定义客户端流类型的gRPC接口，再通过proto生成java代码；
开发服务端应用；
开发客户端应用；
验证；
提前小结
为了突出重点，这里将几个关键的知识点提前给出：
客户端流的特点，是请求方以流的形式提交数据到响应方；
一次RPC请求中，请求方可以通过流的方式源源不断的提交数据，直到调用了StreamObserver的onCompleted方法，才算提交数据完成；
平时咱们调用方法时，方法内部用到的数据是通过入参传进来的，但这里不一样，客户端要传给服务端的数据和gRPC方法的入参没有关系，而是和方法的返回对象有关（执行返回对象的onNext方法可以将数据传给服务端）；
客户端在A线程上传完数据后，服务端的响应是在另一个线程B执行的，因此，如果A线程拿到服务端响应，就要B线程的异步响应方法执行完毕，等待的方法有多种，我用的是CountDownLatch；
在服务端，开发者要编写的代码和以往web开发不同，不是将数据处理好返回，而是返回一个StreamObserver实例给上层框架，由框架负责处理的逻辑，开发者专注开发StreamObserver的实现即可，例如重写onNext方法，客户端通过流每上传一笔数据，onNext方法都会被外层框架执行一次；
如果您用的是IDEA，记得勾选下图红框中的选框，否则运行应用的时候可能遇到lombok相关的问题：
在这里插入图片描述
上面提到的这些，会在接下来的开发过程中充分体现出来；
源码下载
本篇实战中的完整源码可在GitHub下载到，地址和链接信息如下表所示(https://github.com/zq2599/blog_demos)：
名称 链接 备注
项目主页 https://github.com/zq2599/blog_demos 该项目在GitHub上的主页
git仓库地址(https) https://github.com/zq2599/blog_demos.git 该项目源码的仓库地址，https协议
git仓库地址(ssh) git@github.com:zq2599/blog_demos.git 该项目源码的仓库地址，ssh协议
这个git项目中有多个文件夹，《java版gRPC实战》系列的源码在grpc-tutorials文件夹下，如下图红框所示：
在这里插入图片描述
grpc-tutorials文件夹下有多个目录，本篇文章对应的服务端代码在client-stream-server-side目录下，客户端代码在client-stream-client-side目录下，如下图：
在这里插入图片描述
在proto文件中定义客户端流类型的gRPC接口
首先要做的就是定义gRPC接口，打开mall.proto，在里面新增方法和相关的数据结构，需要重点关注的是AddToCart方法的入参ProductOrder前面添加了stream修饰，代表该方法是客户端流类型：
// gRPC服务，这是个在线商城的购物车服务
service CartService {
// 客户端流式：添加多个商品到购物车
rpc AddToCart (stream ProductOrder) returns (AddCartReply) {}
}
// 提交购物车时的产品信息
message ProductOrder {
// 商品ID
int32 productId = 1;
// 商品数量
int32 number = 2;
}
// 提交购物车返回结果的数据结构
message AddCartReply {
// 返回码
int32 code = 1;
// 描述信息
string message = 2;
}
双击下图红框中的task即可生成java代码：
在这里插入图片描述
生成下图红框中的文件：
在这里插入图片描述
接下来开发服务端；
开发服务端应用
在父工程grpc-turtorials下面新建名为client-stream-server-side的模块，其build.gradle内容如下：
// 使用springboot插件
plugins {
id ‘org.springframework.boot’
}
dependencies {
implementation ‘org.projectlombok:lombok’
implementation ‘org.springframework.boot:spring-boot-starter’
// 作为gRPC服务提供方，需要用到此库
implementation ‘net.devh:grpc-server-spring-boot-starter’
// 依赖自动生成源码的工程
implementation project(’:grpc-lib’)
// annotationProcessor不会传递，使用了lombok生成代码的模块，需要自己声明annotationProcessor
annotationProcessor ‘org.projectlombok:lombok’
}