教你在Spring Boot微服务中集成gRPC通讯的方法

更新时间：2021年09月09日 10:44:35 作者：麦神-mirson

这篇文章主要介绍了教你在Spring Boot微服务中集成gRPC通讯的方法,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

一、首先声明gRPC接口

这里引入的是最新的gRpc-core 1.37版本，采用的grcp-spring-boot-starter封装的版本进行实现，github地址：

https://github.com/yidongnan/grpc-spring-boot-starter

要实现gRpc通讯，先定义接口以及入参出参信息

syntax = "proto3";

option java_multiple_files = true;
option java_package = "com.grpc.spring.api.order";
option java_outer_classname = "OrderServiceProto";

// The service definition.
service OrderService {
    // The service method
    rpc GetOrderInfo (GetOrderRequest) returns (GetOrderReply) {
    }
}

// The request message
message GetOrderRequest {
    string orderNo = 1;
}

// The response message
message GetOrderReply {
    string orderNo = 1;
    string userName = 2;
    string address = 3;
    int64 price = 4;
}

定义好之后，就需要通过protoc工具，生成对应的JAVA代码。

为便于使用，这里封装了bat脚本，并提供了对应的protoc执行程序。

@echo off
for %%i in (proto/*.proto) do (
  d:/TestCode/protoc.exe --plugin=protoc-gen-grpc-java=d:/TestCode/protoc-grpc.exe --java_out=../java --grpc-java_out=../java ./proto/%%i
  echo generate %%i to java file successfully!
)

该脚本意思，会扫描当前proto目录下的所有proto脚本文件，通过protoc-grpc插件，在指定目录下生成gRpc通讯接口的JAVA代码。

生成后的JAVA代码

file

执行成功后，会生成GPRC通讯接口，入参和出参信息。

二、如何在服务端集成gRPC

首先整理配置好POM依赖，这里将共用的依赖抽取到父级POM文件中。

父级POM依赖：

<dependencies>
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>javax.servlet-api</artifactId>
        <version>3.1.0</version>
    </dependency>
    <!-- spring boot grpc 依赖 -->
    <dependency>
        <groupId>net.devh</groupId>
        <artifactId>grpc-spring-boot-starter</artifactId>
        <version>${gprc.spring.version}</version>
    </dependency>
    <!-- jackson -->
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>${jackson.verson}</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-core</artifactId>
        <version>${jackson.verson}</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-annotations</artifactId>
        <version>${jackson.verson}</version>
    </dependency>
    <!-- lombok 插件， 简化开发代码 -->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
        <version>1.18.8</version>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.grpc.spring</groupId>
            <artifactId>grpc-spring-api</artifactId>
            <version>${grpc.api.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>${spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>${spring.boot.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>2020.0.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>2021.1</version>
        </dependency>
    </dependencies>
</dependencyManagement>

服务端POM配置

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>net.devh</groupId>
        <artifactId>grpc-server-spring-boot-starter</artifactId>
        <version>${gprc.spring.version}</version>
    </dependency>
    <dependency>
        <groupId>com.grpc.spring</groupId>
        <artifactId>grpc-spring-api</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        <version>3.0.2</version>
        <exclusions>
            <exclusion>
                <artifactId>servlet-api</artifactId>
                <groupId>javax.servlet</groupId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>

作为服务端，需要加入gRpc服务端的依赖grpc-server-spring-boot-starter，同时引入eureka，可以实现微服务之间的调用以及负载。

服务端接口实现

这里为作测试验证，定义个订单服务接口， GrpcOrderService：

/**
 * 订单服务接口实现
 */
@GrpcService
public class GrpcOrderService extends OrderServiceGrpc.OrderServiceImplBase {

    @Value("${server.port}")
    private String serverPort;

    @Override
    public void getOrderInfo(GetOrderRequest request, StreamObserver<GetOrderReply> responseObserver) {
        GetOrderReply reply =GetOrderReply.newBuilder().setOrderNo(request.getOrderNo())
                .setAddress("广东省深圳市,端口号" + serverPort)
                .setUserName("tester")
                .setPrice(System.currentTimeMillis())
                .build();
        responseObserver.onNext(reply);
        responseObserver.onCompleted();
    }
}

要实现gRpc服务端接口，必须做声明，采用@GrpcService注解，然后继承gRpc生成的接口OrderServiceGrpc，重新getOrderInfo获取订单信息接口，实现具体的处理逻辑。

服务端的配置

application.yml

server:
  port: 18082
spring:
  application:
    name: grpc-spring-server
grpc:
  server:
    port: 0
eureka:
  instance:
    prefer-ip-address: true
  client:
    register-with-eureka: true
    fetch-registry: false
    service-url:
      defaultZone: http://${eureka.instance.hostname:eureka.kyeapi.com}:${eureka.server.port:18761}/eureka/

服务端的gRpc端口配置为0代表随机分配， gRpc服务信息会注册至eureka。

三、如何在客户单集成gRPC：

客户端的POM依赖配置

<dependencies>
    <dependency>
        <groupId>com.grpc.spring</groupId>
        <artifactId>grpc-spring-api</artifactId>
    </dependency>
    <dependency>
        <groupId>net.devh</groupId>
        <artifactId>grpc-client-spring-boot-starter</artifactId>
        <version>${gprc.spring.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        <version>3.0.2</version>
    </dependency>

    <!-- 添加 Spring Boot 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        <version>3.0.2</version>
        <exclusions>
            <exclusion>
                <artifactId>servlet-api</artifactId>
                <groupId>javax.servlet</groupId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>

加入提供的客户端依赖grpc-client-spring-boot-starter，这里注意，添加的eureka-client依赖，要排除servlet-api，以免启动冲突。

客户端调用实现

GrpcOrderClientService：

/**
 *  订单信息获取客户端接口
 */
@Service
@Log4j2
public class GrpcOrderClientService {

    @GrpcClient("grpc-server")
    private OrderServiceGrpc.OrderServiceBlockingStub orderServiceBlockingStub;

    /**
     * 获取订单信息
     * @param orderNo
     * @return
     */
    public String getOrderInfo(String orderNo) {
        try {
            //将远程调用的Grpc服务端接口信息, 返回给客户端。
            GetOrderRequest request  = GetOrderRequest.newBuilder().setOrderNo(orderNo).build();
            final GetOrderReply response = orderServiceBlockingStub.getOrderInfo(request);
            String result = "orderNo: " + response.getOrderNo() + ", userName: " + response.getUserName() + ", address: " + response.getAddress();
            return result;
        }catch (Exception e) {
            log.error(e.getMessage(), e);
            return "error! " + e.getMessage();
        }
    }
}

这里通过@GrpcClient注解，引入gRpc接口，这里的gRpc服务端名称grpc-server要与配置文件的名称保持一致。

客户端配置

application.yml

server:
  port: 18080
spring:
  application:
    name: grpc-spring-client
grpc:
  client:
    grpc-server:
      address: 'discovery:///grpc-spring-server'
      enableKeepAlive: true
      keepAliveWithoutCalls: true
      negotiationType: plaintext
eureka:
  instance:
    prefer-ip-address: true
    status-page-url-path: /actuator/info
    health-check-url-path: /actuator/health
  client:
    register-with-eureka: false
    fetch-registry: true
    service-url:
      defaultZone: http://${eureka.instance.hostname:eureka.kyeapi.com}:${eureka.server.port:18761}/eureka/

这里定义了一个gRpc的连接信息grpc-server，与前面注解的名称保持一致， adress要配置gRpc服务端的名称，不需要配置具体的IP和端口，会通过eureka来拉取服务端的具体连接信息。

四、测试验证

启动服务

启动Eureka服务、gRpc服务端与客户端，为便于测试负载，这里启动两个服务端实例，端口号分别为18081与108082。

调用验证

第一调用：

file

第二次调用：

file

可以看到，能够正常调用gRpc服务接口，同时gRpc也是可以支持负载均衡。

最后，需要的完整的源码，可以从以下链接获取：

http://xiazai.jb51.net/202109/yuanma/grpcv_jb51.rar

到此这篇关于教你在Spring Boot微服务中集成gRPC通讯的方法的文章就介绍到这了,更多相关Spring Boot集成gRPC微服务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

基于String实现同步锁的方法步骤
这篇文章主要给大家介绍了关于基于String实现同步锁的方法步骤，文中通过示例代码介绍的非常详细，对大家学习或者使用String具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-09-09
Java swing框架实现的贪吃蛇游戏完整示例
这篇文章主要介绍了Java swing框架实现的贪吃蛇游戏,结合完整实例形式分析了java使用swing框架结合awt图形绘制实现贪吃蛇游戏的具体步骤与相关实现技巧,需要的朋友可以参考下
2017-12-12
SpringBoot如何配置CROS Filter
这篇文章主要介绍了SpringBoot如何配置CROS Filter问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-12-12
Java高性能新一代构建工具Maven-mvnd(实践可行版)
这篇文章主要介绍了Java高性能新一代构建工具Maven-mvnd(实践可行版),本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-06-06
Gradle使用Maven仓库的方法
本篇文章主要介绍了Gradle使用Maven仓库的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-02-02
SpringBoot整合easyExcel实现CSV格式文件的导入导出
这篇文章主要为大家详细介绍了SpringBoot整合easyExcel实现CSV格式文件的导入导出,文中的示例代码讲解详细,具有一定的参考价值,感兴趣的小伙伴可以参考下
2024-02-02
java开发SSM框架具有rest风格的SpringMVC
这篇文章主要介绍了java开发中如何使SSM框架具有rest风格的SpringMVC实现解析，有需要的朋友可以借鉴参考下，希望能够有所帮助
2021-10-10
详解OAuth2 Token 一定要放在请求头中吗
这篇文章主要介绍了详解OAuth2 Token 一定要放在请求头中吗，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-07-07
java获取当前时间的四种方法代码实例
这篇文章主要介绍了java获取当前时间的四种方法代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-09-09
基于JVM-jinfo的使用方式
这篇文章主要介绍了JVM-jinfo的使用方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-10-10