devbox
AllinToyou
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot 集成 Dubbo 启用 gRPC 协议

作者：AllinToyou | 2024-02-22 05:25:44

赞

踩

dubbo grpc 调用

本文记录下SpringBoot集成Dubbo启用gRPC协议，以及与原生 gRPC 在代码编写过程中的区别。

前言

Dubbo 在 2.7.5 版本开始支持原生 gRPC 协议，对于计划使用 HTTP/2 通信或者期望 gRPC 协议支持服务治理能力的，都可以考虑接入 Dubbo 体系启用 gRPC 协议。

由于官网给的 代码示例 是基于 spring，现在基本上都是基于SpringBoot开发，所以本文提供一下 SpringBoot 的代码示例。

此外还会简单说明 Dubbo 支持的原生 gRPC 协议与原生 gRPC 协议在代码开发时的区别。

如果对gRPC协议不了解的，后续文章会有更新，请持续关注。

项目结构

根据现在微服务开发的常见方式，先搭建一个项目，结构如下

718636081cb4854b41d9539bee511d0c.png

这样的项目结构可以将服务的声明和实现隔离开，如果有 client 调用，直接添加api module 的依赖即可。

代码示例

项目结构确定好后需要做三件事

  • 在项目中需要用到 grpc 和 dubbo 相关依赖，所以在父工程中的 pom.xml 文件添加两者的 BOM。

  • gRPC 支持的序列化协议为 protobuf，我们在 api module 下添加 gRPC 所需依赖、插件以及 proto IDL文件。

  • 在 service module 添加相关配置并进行 api service 的实现。

详细代码如下：

父工程

父工程中的 pom.xml 文件添加 grpc 和 dubbo 的 BOM。

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.demo</groupId>
  6.     <artifactId>nava</artifactId>
  7.     <version>0.0.1-SNAPSHOT</version>
  8.     <packaging>pom</packaging>
  9.     <name>nava</name>
  10.     <description>Demo project for Spring Boot</description>
  11.     <properties>
  12.         <java.version>1.8</java.version>
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  14.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  15.         <dubbo.version>3.1.7</dubbo.version>
  16.         <grpc.version>1.44.1</grpc.version>
  17.         <spring-boot.version>2.6.11</spring-boot.version>
  18.     </properties>
  19.  
  20.     <modules>
  21.         <module>nava-api</module>
  22.         <module>nava-service</module>
  23.     </modules>
  24.  
  25.     <dependencyManagement>
  26.         <dependencies>
  27.             <dependency>
  28.                 <groupId>io.grpc</groupId>
  29.                 <artifactId>grpc-bom</artifactId>
  30.                 <version>${grpc.version}</version>
  31.                 <type>pom</type>
  32.                 <scope>import</scope>
  33.             </dependency>
  34.             <dependency>
  35.                 <groupId>org.springframework.boot</groupId>
  36.                 <artifactId>spring-boot-dependencies</artifactId>
  37.                 <version>${spring-boot.version}</version>
  38.                 <type>pom</type>
  39.                 <scope>import</scope>
  40.             </dependency>
  41.             <dependency>
  42.                 <groupId>org.apache.dubbo</groupId>
  43.                 <artifactId>dubbo-bom</artifactId>
  44.                 <version>${dubbo.version}</version>
  45.                 <type>pom</type>
  46.                 <scope>import</scope>
  47.             </dependency>
  48.             <dependency>
  49.                 <groupId>com.demo</groupId>
  50.                 <artifactId>nava-api</artifactId>
  51.                 <version>0.0.1-SNAPSHOT</version>
  52.             </dependency>
  53.             <dependency>
  54.                 <groupId>com.demo</groupId>
  55.                 <artifactId>nava-service</artifactId>
  56.                 <version>0.0.1-SNAPSHOT</version>
  57.             </dependency>
  58.         </dependencies>
  59.     </dependencyManagement>
  60.  
  61.     <build>
  62.         <plugins>
  63.             <plugin>
  64.                 <groupId>org.apache.maven.plugins</groupId>
  65.                 <artifactId>maven-compiler-plugin</artifactId>
  66.                 <version>3.8.1</version>
  67.                 <configuration>
  68.                     <source>1.8</source>
  69.                     <target>1.8</target>
  70.                     <encoding>UTF-8</encoding>
  71.                 </configuration>
  72.             </plugin>
  73.         </plugins>
  74.     </build>
  75.  
  76. </project>

api module

在 api module 中的 pom.xml 文件添加 dubbo 、gRPC 所需依赖、插件。

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>com.demo</groupId>
  7.         <artifactId>nava</artifactId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.         <relativePath>../pom.xml</relativePath>
  10.     </parent>
  11.     <artifactId>nava-api</artifactId>
  12.     <name>nava-api</name>
  13.     <description>api 模块，对外提供的 API</description>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>io.grpc</groupId>
  17.             <artifactId>grpc-netty</artifactId>
  18.             <exclusions>
  19.                 <exclusion>
  20.                     <groupId>io.netty</groupId>
  21.                     <artifactId>netty-codec-http2</artifactId>
  22.                 </exclusion>
  23.                 <exclusion>
  24.                     <groupId>io.netty</groupId>
  25.                     <artifactId>netty-handler-proxy</artifactId>
  26.                 </exclusion>
  27.             </exclusions>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>io.grpc</groupId>
  31.             <artifactId>grpc-netty-shaded</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>io.grpc</groupId>
  35.             <artifactId>grpc-protobuf</artifactId>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>io.grpc</groupId>
  39.             <artifactId>grpc-stub</artifactId>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.apache.dubbo</groupId>
  43.             <artifactId>dubbo-common</artifactId>
  44.         </dependency>
  45.  
  46.     </dependencies>
  47.  
  48.     <build>
  49.         <plugins>
  50.             <plugin>
  51.                 <groupId>kr.motd.maven</groupId>
  52.                 <artifactId>os-maven-plugin</artifactId>
  53.                 <version>1.7.1</version>
  54.                 <executions>
  55.                     <execution>
  56.                         <id>os-maven-plugin</id>
  57.                         <phase>initialize</phase>
  58.                         <goals>
  59.                             <goal>detect</goal>
  60.                         </goals>
  61.                     </execution>
  62.                 </executions>
  63.             </plugin>
  64.             <plugin>
  65.                 <groupId>org.xolstice.maven.plugins</groupId>
  66.                 <artifactId>protobuf-maven-plugin</artifactId>
  67.                 <version>0.6.1</version>
  68.                 <configuration>
  69.                     <protocArtifact>com.google.protobuf:protoc:3.7.1:exe:${os.detected.classifier}</protocArtifact>
  70.                     <pluginId>grpc-java</pluginId>
  71.                     <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}</pluginArtifact>
  72.                     <protocPlugins>
  73.                         <protocPlugin>
  74.                             <id>dubbo-grpc</id>
  75.                             <groupId>org.apache.dubbo</groupId>
  76.                             <artifactId>dubbo-compiler</artifactId>
  77.                             <version>0.0.1</version>
  78.                             <mainClass>org.apache.dubbo.gen.grpc.DubboGrpcGenerator</mainClass>
  79.                         </protocPlugin>
  80.                     </protocPlugins>
  81.                 </configuration>
  82.                 <executions>
  83.                     <execution>
  84.                         <id>protobuf-maven-plugin</id>
  85.                         <goals>
  86.                             <goal>compile</goal>
  87.                             <goal>compile-custom</goal>
  88.                         </goals>
  89.                     </execution>
  90.                 </executions>
  91.             </plugin>
  92.         </plugins>
  93.     </build>
  94.  
  95. </project>

在main文件夹下面创建proto文件夹，以及 DemoService.proto 文件。

11945ad4e3434ca7581c5b68369a7167.png

DemoService.proto

  1. syntax = "proto3";
  2.  
  3. option java_multiple_files = true;
  4. option java_package = "com.demo.nava";
  5. option java_outer_classname = "DemoServiceProto";
  6. option objc_class_prefix = "DSP";
  7.  
  8. // The greeting service definition.
  9. service DemoService {
  10.   // Sends a greeting
  11.   rpc service (RequestData) returns (ResponseData) {}
  12. }
  13.  
  14. // The request message containing the user's name.
  15. message RequestData {
  16.   string name = 1;
  17. }
  18.  
  19. // The response message containing the greetings
  20. message ResponseData {
  21.   string message = 1;
  22. }

service module

在 service module 中的 pom.xml 文件添加 api module 的依赖以及 dubbo 其他依赖。

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>com.demo</groupId>
  7.         <artifactId>nava</artifactId>
  8.         <version>0.0.1-SNAPSHOT</version>
  9.         <relativePath>../pom.xml</relativePath>
  10.     </parent>
  11.     <artifactId>nava-service</artifactId>
  12.     <name>nava-service</name>
  13.     <description>service 模块，存放核心业务逻辑代码</description>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.springframework.boot</groupId>
  17.             <artifactId>spring-boot-starter</artifactId>
  18.         </dependency>
  19.         <dependency>
  20.             <groupId>com.demo</groupId>
  21.             <artifactId>nava-api</artifactId>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.apache.dubbo</groupId>
  25.             <artifactId>dubbo-registry-nacos</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.apache.dubbo</groupId>
  29.             <artifactId>dubbo-spring-boot-starter</artifactId>
  30.         </dependency>
  31.  
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-test</artifactId>
  35.             <scope>test</scope>
  36.         </dependency>
  37.     </dependencies>
  38.  
  39.     <build>
  40.         <plugins>
  41.             <plugin>
  42.                 <groupId>org.apache.maven.plugins</groupId>
  43.                 <artifactId>maven-compiler-plugin</artifactId>
  44.                 <version>3.8.1</version>
  45.                 <configuration>
  46.                     <source>1.8</source>
  47.                     <target>1.8</target>
  48.                     <encoding>UTF-8</encoding>
  49.                 </configuration>
  50.             </plugin>
  51.             <plugin>
  52.                 <groupId>org.springframework.boot</groupId>
  53.                 <artifactId>spring-boot-maven-plugin</artifactId>
  54.                 <version>2.6.11</version>
  55.                 <configuration>
  56.                     <mainClass>com.demo.nava.NavaApplication</mainClass>
  57.                 </configuration>
  58.                 <executions>
  59.                     <execution>
  60.                         <id>repackage</id>
  61.                         <goals>
  62.                             <goal>repackage</goal>
  63.                         </goals>
  64.                     </execution>
  65.                 </executions>
  66.             </plugin>
  67.         </plugins>
  68.     </build>
  69.  
  70. </project>

在 application.properties 文件中添加 dubbo 相关配置

application.properties

  1. # 设置dubbo传输协议
  2. dubbo.protocol.name=grpc
  3. dubbo.protocol.port=-1
  4. # dubbo nacos注册中心说明 https://cn.dubbo.apache.org/zh-cn/overview/mannual/java-sdk/reference-manual/registry/nacos/
  5. dubbo.registry.address: nacos://nacos:nacos@${nacos.address:127.0.0.1}:8848

在 SpringBoot 启动类添加 @EnableDubbo 注解

bfc553505a20900f3999b4b8b32079a3.png

添加 DemoServiceImpl 实现类进行业务编码。

DemoServiceImpl.java

  1. package com.demo.nava.service;
  2.  
  3. import com.demo.nava.DubboDemoServiceGrpc;
  4. import com.demo.nava.RequestData;
  5. import com.demo.nava.ResponseData;
  6. import io.grpc.stub.StreamObserver;
  7. import org.apache.dubbo.config.annotation.DubboService;
  8.  
  9. @DubboService
  10. public class DemoServiceImpl extends DubboDemoServiceGrpc.DemoServiceImplBase implements DubboDemoServiceGrpc.IDemoService {
  11.  
  12.     @Override
  13.     public void service(RequestData request, StreamObserver<ResponseData> responseObserver) {
  14.         ResponseData reply = ResponseData.newBuilder().setMessage("Hello " + request.getName()).build();
  15.         responseObserver.onNext(reply);
  16.         responseObserver.onCompleted();
  17.     }
  18. }

注意事项

经过以上的步骤，一个简单的 SpringBoot 集成 Dubbo 启用 gRPC 协议的示例就完成了。这个时候直接启动项目是会报错的，因为protobuf相关的代码还没生成，我们需要对项目进行 maven install 以及 maven reload 操作。

maven install 的目的是为了生成protobuf相关代码，这个时候我们可以在 target 中看到

8eaf09a76a54926da18aece42750130f.png

maven reload 的目的是为了更新加载 pom.xml 文件，从而将 api module 中生成的代码加载到 service module。

操作后就可以成功启动项目了。

区别

在项目启动成功后可以回头看下 Dubbo 支持的原生 gRPC 与原生 gRPC 在代码编写过程中的区别

1.maven plugin 的区别，dubbo 在原先的基础上添加了 dubbo-grpc 的 plugin，目的是生成扩展的代码做到对 grpc 的支持。

cecec79ea4ec84d215c18c07f7d9915b.png

对应生成的代码如下

179611549ce528c1c85fb1ac572650f4.png

2.service 实现区别，dubbo-grpc 的 plugin 生成了 dubbo 相关的 protobuf 的代码，所以在实现上有所区别。

3894e7b143e56f164e141b70b886d4eb.png

3.RPC 调用区别，因为 grpc 接入了 dubbo 体系，所以使用 Dubbo 风格，基于接口的编程来定义和使用远程服务。

66ffdafe97b4d2c7651a88f62a0d6578.png

来源：blog.csdn.net/qq_28314431/

article/details/130090121

推荐

Java面试题宝典

技术内卷群，一起来学习！！

34d8e4f65d1fe166a8fa84115d544458.jpeg

PS：因为公众号平台更改了推送规则，如果不想错过内容，记得读完点一下“在看”，加个“星标”，这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧!

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/AllinToyou/article/detail/128699
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号