gRPC 实战之——客户端为 Request，服务端为 Response

转x33g5p2x  于2022-06-06 转载在 其他  
字(10.8k)|赞(0)|评价(0)|浏览(491)

一 编写 proto 文件

  1. syntax = "proto3";
  2. package grpc.proto;
  3. option java_package = "grpc.proto";
  4. option java_outer_classname = "StudentData";
  5. option java_multiple_files = true ;
  6. // 定义接口
  7. service StudentService {
  8.     // 请求一个 Requset 对象，响应一个 Response 对象
  9.     rpc queryStudentNameById(MyRequestId) returns(MyResponseName) {}
  10.     // 请求一个 Requset 对象，响应一个 Stream 对象
  11.     rpc queryStudentsByCourseName(MyRequestCourseName) returns(stream MyResponseStudentsStream) {}
  12.     // 请求一个 Stream 对象，响应一个 Response 对象
  13.     rpc queryStudentsByCourseName2(stream MyRequestCourseName) returns(MyResponseStudents) {}
  14.     // 请求一个 Stream，响应一个 Stream 对象
  15.     rpc queryStudentNameById2(stream MyRequestId) returns(stream MyResponseName) {}
  16. }
  18. message MyRequestId
  19. {
  20.     int32 id = 1 ;
  21. }
  23. message MyResponseName
  24. {
  25.     string name = 1 ;
  26. }
  28. message MyStudent
  29. {
  30.     int32 id = 1 ;
  31.     string name = 2;
  32.     string courseName = 3 ;
  33. }
  35. message MyResponseStudents
  36. {
  37.     // 服务端的响应结果是集合类型，因此需要加上 repeated
  38.     repeated MyStudent students = 1 ;
  39. }
  41. // 数据结构,定义请求的 Request 对象
  42. message MyRequestCourseName
  43. {
  44.     string courseName = 1 ;
  45. }
  46. // 数据结构,定义响应的 Stream
  47. message MyResponseStudentsStream
  48. {
  49.     int32 id = 1 ;
  50.     string name = 2;
  51.     string courseName = 3 ;
  52. }

二 编写接口实现类

  1. package grpc;
  3. import grpc.proto.*;
  4. import io.grpc.stub.StreamObserver;
  6. public class StudentServiceImpl extends StudentServiceGrpc.StudentServiceImplBase {
  7.     @Override
  8.     public void queryStudentNameById(MyRequestId request, StreamObserver<MyResponseName> responseObserver) {
  9.         System.out.println("模拟查询此id的用户名：" + request.getId());
  10.         // 假设此 id 的 name 是“zs”
  11.         responseObserver.onNext(MyResponseName.newBuilder().setName("zs").build());
  12.         responseObserver.onCompleted();
  13.     }
  14. ]

三 编写服务端代码

  1. package grpc;
  3. import io.grpc.Server;
  4. import io.grpc.ServerBuilder;
  6. import java.io.IOException;
  8. public class MyGRPCServer {
  9.     private Server server;
  11.     // 启动服务
  12.     private void start() throws IOException {
  13.         int port = 8888;
  14.         server = ServerBuilder.forPort(port)
  15.                 .addService(new StudentServiceImpl())
  16.                 .build()
  17.                 .start();
  18.         Runtime.getRuntime().addShutdownHook(new Thread(() ->{
  19.                 System.err.println(Thread.currentThread().getName() + "，关闭JVM");
  20.                 // 当 JVM 关闭前，先关闭 MyGRPCServer服务
  21.                 MyGRPCServer.this.stop();
  22.             }
  23.         ));
  24.     }
  26.     // 关闭服务
  27.     private void stop() {
  28.         if (server != null) {
  29.             server.shutdown();
  30.         }
  31.     }
  33.     private void blockUntilShutdown() throws InterruptedException {
  34.         if (server != null) {
  35.             // 等待服务结束
  36.             server.awaitTermination();
  37.         }
  38.     }
  40.     public static void main(String[] args) throws IOException, InterruptedException {
  41.         final MyGRPCServer server = new MyGRPCServer();
  42.         server.start();
  43.         server.blockUntilShutdown();
  44.     }
  45. }

四 编写客户端代码

  1. package grpc;
  3. import grpc.proto.MyRequestId;
  4. import grpc.proto.MyResponseName;
  5. import grpc.proto.StudentServiceGrpc;
  6. import io.grpc.ManagedChannel;
  7. import io.grpc.ManagedChannelBuilder;
  9. public class MyGRPCClient {
  10.     public static void main(String[] args) throws Exception {
  11.         // 创建一个客户端
  12.         ManagedChannel client = ManagedChannelBuilder.forAddress("127.0.0.1", 8888)
  13.                 .usePlaintext().build();
  14.         try {
  15.             // 创建客户端的代理对象，用于代表客户端去访问服务端提供的方法
  16.             StudentServiceGrpc.StudentServiceBlockingStub stub = StudentServiceGrpc
  17.                     .newBlockingStub(client);
  18.             // 请求Request，响应Response
  19.             // 调用服务端提供的方法，查询id为1的姓名
  20.             MyResponseName responseName = stub.queryStudentNameById(MyRequestId.newBuilder()
  21.                     .setId(1).build());
  22.             System.out.println(responseName.getName());
  23.         } finally {
  24.             client.shutdown();
  25.         }
  26.     }
  27. }

五 测试

1 启动服务端和客户端

2 服务端打印如下

模拟查询此id的用户名：1

3 客户端打印如下

zs

六 冲突解决

GRPC-Server报错服务端启动com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String；CLjava异常解决方案_时间是一种解药的博客-CSDN博客

https://blog.csdn.net/cucgyfjklx/article/details/122681339

guava 版本冲突，保留最高版本的 guava 可解决问题。

解决冲突后的 pom 文件如下

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>org.example</groupId>
  8.     <artifactId>demo2022</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  11.     <parent>
  12.         <groupId>org.springframework.boot</groupId>
  13.         <artifactId>spring-boot-starter-parent</artifactId>
  14.         <version>2.0.5.RELEASE</version>
  15.     </parent>
  17.     <properties>
  18.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  19.         <grpc.version>1.15.0</grpc.version><!-- CURRENT_GRPC_VERSION -->
  20.         <protobuf.version>3.5.1</protobuf.version>
  21.         <protoc.version>3.5.1-1</protoc.version>
  22.         <netty.tcnative.version>2.0.7.Final</netty.tcnative.version>
  23.     </properties>
  25.     <dependencies>
  26.         <!--Spring 官方提供的热部署插件 -->
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-devtools</artifactId>
  30.             <optional>true</optional>
  31.         </dependency>
  33.         <!-- easypoi-->
  34.         <dependency>
  35.             <groupId>cn.afterturn</groupId>
  36.             <artifactId>easypoi-base</artifactId>
  37.             <version>4.1.0</version>
  38.             <exclusions>
  39.                 <exclusion>
  40.                     <artifactId>guava</artifactId>
  41.                     <groupId>com.google.guava</groupId>
  42.                 </exclusion>
  43.             </exclusions>
  44.         </dependency>
  45.         <dependency>
  46.             <groupId>cn.afterturn</groupId>
  47.             <artifactId>easypoi-web</artifactId>
  48.             <version>4.1.0</version>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>cn.afterturn</groupId>
  52.             <artifactId>easypoi-annotation</artifactId>
  53.             <version>4.1.0</version>
  54.         </dependency>
  55.         <dependency>
  56.             <groupId>io.netty</groupId>
  57.             <artifactId>netty-all</artifactId>
  58.             <version>4.1.29.Final</version>
  59.             <scope>compile</scope>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>com.google.protobuf</groupId>
  63.             <artifactId>protobuf-java</artifactId>
  64.             <version>3.5.1</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>org.apache.httpcomponents</groupId>
  68.             <artifactId>httpclient</artifactId>
  69.             <version>4.3</version>
  70.             <exclusions>
  71.                 <exclusion>
  72.                     <artifactId>httpcore</artifactId>
  73.                     <groupId>org.apache.httpcomponents</groupId>
  74.                 </exclusion>
  75.             </exclusions>
  76.         </dependency>
  77.         <dependency>
  78.             <groupId>org.apache.httpcomponents</groupId>
  79.             <artifactId>httpcore</artifactId>
  80.             <version>4.4.4</version>
  81.         </dependency>
  82.         <dependency>
  83.             <groupId>com.alibaba</groupId>
  84.             <artifactId>fastjson</artifactId>
  85.             <version>1.1.23</version>
  86.         </dependency>
  87.         <dependency>
  88.             <groupId>org.apache.thrift</groupId>
  89.             <artifactId>libthrift</artifactId>
  90.             <version>0.11.0</version>
  91.             <exclusions>
  92.                 <exclusion>
  93.                     <artifactId>httpcore</artifactId>
  94.                     <groupId>org.apache.httpcomponents</groupId>
  95.                 </exclusion>
  96.                 <exclusion>
  97.                     <artifactId>httpclient</artifactId>
  98.                     <groupId>org.apache.httpcomponents</groupId>
  99.                 </exclusion>
  100.             </exclusions>
  101.         </dependency>
  102.         <dependency>
  103.             <groupId>io.grpc</groupId>
  104.             <artifactId>grpc-netty-shaded</artifactId>
  105.             <version>${grpc.version}</version>
  106.         </dependency>
  107.         <dependency>
  108.             <groupId>io.grpc</groupId>
  109.             <artifactId>grpc-protobuf</artifactId>
  110.             <version>${grpc.version}</version>
  111.             <exclusions>
  112.                 <exclusion>
  113.                     <artifactId>guava</artifactId>
  114.                     <groupId>com.google.guava</groupId>
  115.                 </exclusion>
  116.             </exclusions>
  117.         </dependency>
  118.         <dependency>
  119.             <groupId>io.grpc</groupId>
  120.             <artifactId>grpc-stub</artifactId>
  121.             <version>${grpc.version}</version>
  122.         </dependency>
  123.         <dependency>
  124.             <groupId>io.grpc</groupId>
  125.             <artifactId>grpc-alts</artifactId>
  126.             <version>${grpc.version}</version>
  127.             <exclusions>
  128.                 <exclusion>
  129.                     <artifactId>httpclient</artifactId>
  130.                     <groupId>org.apache.httpcomponents</groupId>
  131.                 </exclusion>
  132.                 <exclusion>
  133.                     <artifactId>grpc-grpclb</artifactId>
  134.                     <groupId>io.grpc</groupId>
  135.                 </exclusion>
  136.             </exclusions>
  137.         </dependency>
  138.         <dependency>
  139.             <groupId>io.grpc</groupId>
  140.             <artifactId>grpc-testing</artifactId>
  141.             <version>${grpc.version}</version>
  142.             <scope>test</scope>
  143.             <exclusions>
  144.                 <exclusion>
  145.                     <artifactId>mockito-core</artifactId>
  146.                     <groupId>org.mockito</groupId>
  147.                 </exclusion>
  148.             </exclusions>
  149.         </dependency>
  151.         <!-- Used in HelloWorldServerTls -->
  152.         <dependency>
  153.             <groupId>io.grpc</groupId>
  154.             <artifactId>grpc-netty</artifactId>
  155.             <version>${grpc.version}</version>
  156.         </dependency>
  157.         <dependency>
  158.             <groupId>io.netty</groupId>
  159.             <artifactId>netty-tcnative-boringssl-static</artifactId>
  160.             <version>${netty.tcnative.version}</version>
  161.         </dependency>
  163.         <dependency>
  164.             <groupId>com.google.api.grpc</groupId>
  165.             <artifactId>proto-google-common-protos</artifactId>
  166.             <version>1.0.0</version>
  167.         </dependency>
  168.         <dependency>
  169.             <groupId>com.google.protobuf</groupId>
  170.             <artifactId>protobuf-java-util</artifactId>
  171.             <version>${protobuf.version}</version>
  172.             <exclusions>
  173.                 <exclusion>
  174.                     <artifactId>guava</artifactId>
  175.                     <groupId>com.google.guava</groupId>
  176.                 </exclusion>
  177.             </exclusions>
  178.         </dependency>
  179.         <dependency>
  180.             <groupId>junit</groupId>
  181.             <artifactId>junit</artifactId>
  182.             <version>4.12</version>
  183.             <scope>test</scope>
  184.         </dependency>
  185.         <dependency>
  186.             <groupId>org.mockito</groupId>
  187.             <artifactId>mockito-core</artifactId>
  188.             <version>1.9.5</version>
  189.             <scope>test</scope>
  190.         </dependency>
  191.     </dependencies>
  193.     <build>
  194.         <extensions>
  195.             <extension>
  196.                 <groupId>kr.motd.maven</groupId>
  197.                 <artifactId>os-maven-plugin</artifactId>
  198.                 <version>1.5.0.Final</version>
  199.             </extension>
  200.         </extensions>
  201.         <plugins>
  202.             <plugin>
  203.                 <groupId>org.springframework.boot</groupId>
  204.                 <artifactId>spring-boot-maven-plugin</artifactId>
  205.                 <configuration>
  206.                     <fork>true</fork><!--必须添加这个配置-->
  207.                 </configuration>
  208.             </plugin>
  209.             <plugin>
  210.                 <groupId>org.xolstice.maven.plugins</groupId>
  211.                 <artifactId>protobuf-maven-plugin</artifactId>
  212.                 <version>0.5.1</version>
  213.                 <configuration>
  214.                     <protocArtifact>com.google.protobuf:protoc:${protoc.version}:exe:${os.detected.classifier}
  215.                     </protocArtifact>
  216.                     <pluginId>grpc-java</pluginId>
  217.                     <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}
  218.                     </pluginArtifact>
  219.                 </configuration>
  220.                 <executions>
  221.                     <execution>
  222.                         <goals>
  223.                             <goal>compile</goal>
  224.                             <goal>compile-custom</goal>
  225.                         </goals>
  226.                     </execution>
  227.                 </executions>
  228.             </plugin>
  229.         </plugins>
  230.     </build>
  231. </project>

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/chengqiuming/article/details/125120179

内容来源于网络，如有侵权，请联系作者删除！

Java

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com