gRPC三种客户端类型实践Java版

　　本文承袭Grpc服务开发和接口测试初探【Java】内容，学会了基本的gRPC的基本Demo之后，自然要开始了各类客户端的学习。由于服务端的代码都是由开发写好的，所以作为新手测试来说，我觉得学好客户端的代码优先级更高一些。
　　书接上文，gRPC客户端有三种实现方式，其实就是从io。grpc。ManagedChannel创建客户端Stub的过程。三种方式分别为：newBlockingStub、newStub、newFutureStub。下面通过代码演示来分享三种的区别和优劣。
　　gRPC客户端目前用起来跟HTTP协议一样，调用方式跟HttpClient调用一样。分成了阻塞、异步和future，有兴趣可以移步HTTP异步连接池和多线程实践。服务端
　　服务端是上期进行改造，主要是增加了响应等待时间和时间信息，方便后面验证不同客户端功能。代码如下：packagecom。funtester。grpc；importcom。funtester。frame。SourceCode；importcom。funtester。fungrpc。HelloRequest；importcom。funtester。fungrpc。HelloResponse；importcom。funtester。fungrpc。HelloServiceGrpc；importcom。funtester。utils。Time；importio。grpc。stub。StreamObserver；importorg。apache。logging。log4j。LogManager；importorg。apache。logging。log4j。Logger；publicclassHelloServiceImplextendsHelloServiceGrpc。HelloServiceImplBase｛privatestaticfinalLoggerloggerLogManager。getLogger（HelloServiceImpl。class）；OverridepublicvoidexecuteHi（HelloRequestrequest，StreamObserverHelloResponseresponseObserver）｛HelloResponseresponseHelloResponse。newBuilder（）。setMsg（你好request。getName（）Time。getDate（））。build（）；SourceCode。sleep（1。0）；logger。info（用户｛｝来了，request。getName（））；responseObserver。onNext（response）；responseObserver。onCompleted（）；｝｝newBlockingStub
　　顾名思义，这个是阻塞调用的gRPC客户端类型，实际使用中跟HTTP接口请求响应一样，代码如下：packagecom。funtest。grpcimportcom。funtester。frame。SourceCodeimportcom。funtester。fungrpc。HelloRequestimportcom。funtester。fungrpc。HelloResponseimportcom。funtester。fungrpc。HelloServiceGrpcimportio。grpc。ManagedChannelimportio。grpc。ManagedChannelBuilderimportjava。util。concurrent。ExecutionExceptionclassBlockClientextendsSourceCode｛publicstaticvoidmain（String〔〕args）throwsExecutionException，InterruptedException｛ManagedChannelmanagedChannelManagedChannelBuilder。forAddress（localhost，8080）。usePlaintext（）。build（）HelloServiceGrpc。HelloServiceBlockingStubhelloServiceBlockingStubHelloServiceGrpc。newBlockingStub（managedChannel）。withCompression（gzip）HelloRequesthelloRequestHelloRequest。newBuilder（）。setName（FunTester）。build（）5。times｛HelloResponseorderResponsehelloServiceBlockingStub。executeHi（helloRequest）output（收到响应：orderResponse。getMsg（））｝managedChannel。shutdown（）｝｝
　　控制台输出：20：46：04。664main当前用户：oker，工作目录：UsersokerIdeaProjectsfuntester，系统编码格式：UTF8，系统MacOSX版本：10。1620：46：04。675main20：46：06。517main收到响应：你好FunTester2022050920：46：0520：46：07。521main收到响应：你好FunTester2022050920：46：0620：46：08。531main收到响应：你好FunTester2022050920：46：0720：46：09。542main收到响应：你好FunTester2022050920：46：0820：46：10。552main收到响应：你好FunTester2022050920：46：09进程已结束，退出代码0
　　比较简单，这里不多做介绍了。newStub
　　看名字有点猜不出来，这是个纯异步调用客户端。写上去代码可能比较多，但是如果把io。grpc。stub。StreamObserver对象拆开看就会比较容易懂一些。代码如下：packagecom。funtest。grpcimportcom。funtester。frame。SourceCodeimportcom。funtester。fungrpc。HelloRequestimportcom。funtester。fungrpc。HelloResponseimportcom。funtester。fungrpc。HelloServiceGrpcimportio。grpc。ManagedChannelimportio。grpc。ManagedChannelBuilderimportio。grpc。stub。StreamObserverimportjava。util。concurrent。ExecutionExceptionclassSyncClientextendsSourceCode｛publicstaticvoidmain（String〔〕args）throwsExecutionException，InterruptedException｛ManagedChannelmanagedChannelManagedChannelBuilder。forAddress（localhost，8080）。usePlaintext（）。build（）HelloServiceGrpc。HelloServiceStubhelloServiceStubHelloServiceGrpc。newStub（managedChannel）。withCompression（gzip）HelloRequesthelloRequestHelloRequest。newBuilder（）。setName（FunTester）。build（）StreamObserverHelloResponsehelloResponseStreamObservernewStreamObserverHelloResponse（）｛OverridevoidonNext（HelloResponsevalue）｛output（value。getMsg（））｝OverridevoidonError（Throwablet）｛output（t。getMessage（））｝OverridevoidonCompleted（）｛｝｝5。times｛helloServiceStub。executeHi（helloRequest，helloResponseStreamObserver）｝sleep（2000）managedChannel。shutdown（）｝｝
　　由于都是异步，所以相当于自动多线程了。控制台输出如下：20：50：59。053main20：51：00。816grpcdefaultexecutor4你好FunTester2022050920：50：5920：51：00。816grpcdefaultexecutor1你好FunTester2022050920：50：5920：51：00。816grpcdefaultexecutor3你好FunTester2022050920：50：5920：51：00。816grpcdefaultexecutor0你好FunTester2022050920：50：5920：51：00。816grpcdefaultexecutor2你好FunTester2022050920：50：59进程已结束，退出代码0
　　可以看到，所有请求响应的结果时间都是一样的，说明请求到达服务端时间是一样的。newFutureStub
　　这种客户端也是异步的，之所以放在最后将是因为它具有同步客户端的属性，在实际使用中，既可以当做异步客户端使用也可以当做一个同步的客户端使用。下面是演示代码：packagecom。funtest。grpcimportcom。funtester。frame。SourceCodeimportcom。funtester。fungrpc。HelloRequestimportcom。funtester。fungrpc。HelloResponseimportcom。funtester。fungrpc。HelloServiceGrpcimportcom。google。common。util。concurrent。ListenableFutureimportio。grpc。ManagedChannelimportio。grpc。ManagedChannelBuilderimportjava。util。concurrent。ExecutionExceptionclassFutureClientextendsSourceCode｛publicstaticvoidmain（String〔〕args）throwsExecutionException，InterruptedException｛ManagedChannelmanagedChannelManagedChannelBuilder。forAddress（localhost，8080）。usePlaintext（）。build（）HelloServiceGrpc。HelloServiceFutureStubhelloServiceFutureStubHelloServiceGrpc。newFutureStub（managedChannel）。withCompression（gzip）HelloRequesthelloRequestHelloRequest。newBuilder（）。setName（FunTester）。build（）同步客户端的使用方式5。times｛ListenableFutureHelloResponsehelloResponseListenableFuturehelloServiceFutureStub。executeHi（helloRequest）HelloResponsehelloResponsehelloResponseListenableFuture。get（）output（helloResponse。getMsg（））｝异步客户端的使用方式defres〔〕5。times｛ListenableFutureHelloResponsehelloResponseListenableFuturehelloServiceFutureStub。executeHi（helloRequest）reshelloResponseListenableFuture｝res。each｛output（it。get（）。getMsg（））｝managedChannel。shutdown（）｝｝
　　控制台输出：21：03：07。312main21：03：09。226main你好FunTester2022050921：03：0821：03：10。232main你好FunTester2022050921：03：0921：03：11。238main你好FunTester2022050921：03：1021：03：12。247main你好FunTester2022050921：03：1121：03：13。255main你好FunTester2022050921：03：1221：03：14。262main你好FunTester2022050921：03：1321：03：14。281main你好FunTester2022050921：03：1321：03：14。281main你好FunTester2022050921：03：1321：03：14。282main你好FunTester2022050921：03：1321：03：14。282main你好FunTester2022050921：03：13进程已结束，退出代码0
　　可以看到，前面五个请求是串行的，后面的五个请求是并行的。在实际工作中，使用到异步调用又要处理结果的地方也是这种类型使用较多，而使用Java的线程同步类，往往比较麻烦也不够优雅。HaveFunTester！