Spring Boot+Nacos+gRPC，一个区别于 OpenFeign 的微服务通信方案！-六虎

gRPC 的基础知识前面跟小伙伴们共享了很多了，今日再写一篇给这个小小的系列收个尾。

咱们前面介绍的都是 gRPC 的根本用法，终究意图当然是期望能够在 Spring Boot 中用上这个东西，信任大部分小伙伴关于微服务的通讯计划如 OpenFeign、Dubbo、音讯驱动都有所了解，但是关于这三种计划之外的其他计划，可能听的多用的少，今日咱们就来实践一下 gRPC 这种计划。

顺便说一下我为什么会想到写 gRPC 教程呢，是因为之前我想给小伙伴们总结一下常见的各种微服务通讯计划。整理到 gRPC 的时分发现我还没写过 gRPC 相关的教程，因而就有了一个小系列。

1. 依靠挑选

Spring Boot 整合 gRPC，官方其实并没有供给相应的依靠，不过现在有一个比较流行的第三方库能够运用：

github.com/yidongnan/g…

接下来松哥就结合这个库，来和小伙伴们演示一下 Spring Boot+Nacos+gRPC 的用法。

可能有小伙伴也会见到一些其他的第三方库，这个其实都能够，只需安稳可靠就行，本文就以上面这个库为例来和小伙伴们介绍。

2. 准备工作

这儿我采用了 Nacos 来做服务注册中心，运用的 Nacos 版别是 2.0.2 这个版别。Nacos 简略安装一下就行了，为了省事，数据耐久化啥的能够先不装备。也便是 Nacos 下载解压之后，直接履行如下命令单体运转就行了：

sh startup.sh -m standalone

这块没啥好说的，松哥在 vhr 系列里也有相关的视频教程，这儿就不烦琐了。

3. 代码实践

首先咱们来看看咱们的项目结构：

├─grpc-api
│  └─src
│      └─main
│          └─proto
├─grpc-client
│  └─src
│      ├─main
│      │  ├─java
│      │  └─resources
│      └─test
└─grpc-server
    └─src
        ├─main
        │  ├─java
        │  └─resources
        └─test

首先有一个公共的模块 grpc-api，这个模块用来放咱们的公共代码和依靠，包含 Protocol Buffers 文件也放在这儿。

grpc-client 和 grpc-server 就不用多说了，分别是咱们的客户端和服务端。

3.1 grpc-api

grpc-api 中主要是处理 grpc 相关的工作，包含添加需要的依靠、插件等，编写 Protocol Buffers 文件等。

咱们先来看看该项意图 pom.xml 文件中的依靠：

<properties>
    <maven.compiler.source>17</maven.compiler.source>
    <maven.compiler.target>17</maven.compiler.target>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <protobuf.version>3.21.7</protobuf.version>
    <protobuf-plugin.version>0.6.1</protobuf-plugin.version>
    <grpc.version>1.52.1</grpc.version>
</properties>
<dependencies>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-stub</artifactId>
        <version>${grpc.version}</version>
    </dependency>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-protobuf</artifactId>
        <version>${grpc.version}</version>
    </dependency>
    <dependency>
        <!-- Java 9+ compatibility - Do NOT update to 2.0.0 -->
        <groupId>jakarta.annotation</groupId>
        <artifactId>jakarta.annotation-api</artifactId>
        <version>1.3.5</version>
        <optional>true</optional>
    </dependency>
</dependencies>
<build>
    <extensions>
        <extension>
            <groupId>kr.motd.maven</groupId>
            <artifactId>os-maven-plugin</artifactId>
            <version>1.7.0</version>
        </extension>
    </extensions>
    <plugins>
        <plugin>
            <groupId>org.xolstice.maven.plugins</groupId>
            <artifactId>protobuf-maven-plugin</artifactId>
            <version>${protobuf-plugin.version}</version>
            <configuration>
                <protocArtifact>com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier}</protocArtifact>
                <pluginId>grpc-java</pluginId>
                <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}</pluginArtifact>
            </configuration>
            <executions>
                <execution>
                    <goals>
                        <goal>compile</goal>
                        <goal>compile-custom</goal>
                    </goals>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>

这块的依靠跟咱们之前的 gRPC 文章中案例的依靠根本上都是共同的，没有区别，再来看看咱们的 Protocol Buffers 文件：

syntax = "proto3";
option java_multiple_files = true;
option java_package = "org.javaboy.grpc.api";
option java_outer_classname = "LoginProto";
import "google/protobuf/wrappers.proto";
package login;
service HelloService{
  rpc sayHello(google.protobuf.StringValue) returns (google.protobuf.StringValue);
}

很简略的一个 HelloService 服务。

3.2 grpc-server

grpc-server 则是咱们的服务端，这是一个 Spring Boot 工程，项目依靠如下：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.7</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>org.javaboy</groupId>
<artifactId>grpc-server</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>grpc-server</name>
<description>grpc-server</description>
<properties>
    <java.version>17</java.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.javaboy</groupId>
        <artifactId>grpc-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>net.devh</groupId>
        <artifactId>grpc-server-spring-boot-starter</artifactId>
        <version>2.14.0.RELEASE</version>
    </dependency>
</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>2021.0.5.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

由于第三方库 grpc-server-spring-boot-starter 在支持 Spring Boot3 上还有一些瑕疵，因而我这儿运用了 Spring Boot2.7.7 这个版别。

这儿需要留意的是便是添加了 gRPC 的依靠 grpc-server-spring-boot-starter 和 nacos 的依靠。其他都是常规装备。

接下来咱们来在服务端供给 gRPC 办法的完成：

@GrpcService
public class HelloServiceImpl extends HelloServiceGrpc.HelloServiceImplBase {
    @Override
    public void sayHello(StringValue request, StreamObserver<StringValue> responseObserver) {
        String value = request.getValue();
        responseObserver.onNext(StringValue.newBuilder().setValue("hello " + value).build());
        responseObserver.onCompleted();
    }
}

小伙伴们看到，经过 @GrpcService 注解去符号咱们的一个服务即可。

最终，在 application.yaml 中进行装备，将当时服务注册到 nacos 容器中：

grpc:
  server:
    port: 9099
spring:
  cloud:
    nacos:
      discovery:
        server-addr: hc.javaboy.org:8848
        username: nacos
        password: nacos
        enabled: true
  application:
    name: grpc_server

OK，服务端搞定。

3.3 grpc-client

最终再来看看客户端。

先来看依靠：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.7</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>org.javaboy</groupId>
<artifactId>grpc-client</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>grpc-client</name>
<description>grpc-client</description>
<properties>
    <java.version>17</java.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.javaboy</groupId>
        <artifactId>grpc-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>net.devh</groupId>
        <artifactId>grpc-client-spring-boot-starter</artifactId>
        <version>2.14.0.RELEASE</version>
    </dependency>
</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>2021.0.5.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

留意，客户端 grpc 的依靠是 grpc-client-spring-boot-starter，其他的根本上和服务端共同。

然后装备客户端，将之注册到 nacos 上，如下：

server:
  port: 8088
spring:
  cloud:
    nacos:
      discovery:
        enabled: true
        server-addr: hc.javaboy.org:8848
        username: nacos
        password: nacos
  application:
    name: grpc_client
grpc:
  client:
    grpc_server:
      negotiation-type: plaintext

最终面有一个 grpc_server，这个是固定的（根据便是 grpc_server 注册到 nacos 上的名称），表示这个服务的通讯不运用 TLS 加密。

最终再来看看调用代码：

@RestController
public class HelloController {
    @Autowired
    GrpcClientService grpcClientService;
    @GetMapping("/hello")
    public void hello() {
        grpcClientService.hello();
    }
}
@Component
public class GrpcClientService {
    @GrpcClient("grpc_server")
    HelloServiceGrpc.HelloServiceBlockingStub helloServiceBlockingStub;
    public void hello() {
        StringValue s = helloServiceBlockingStub.sayHello(StringValue.newBuilder().setValue("javaboy").build());
        System.out.println("s = " + s.getValue());
    }
}

这儿的核心其实便是经过 @GrpcClient 注解注入一个 HelloServiceBlockingStub 实例，其间 @GrpcClient 注解中的参数便是注册到 nacos 上服务的姓名，将来会自动根据服务的姓名查找到服务的具体地址进行调用。

好啦，大功告成。

接下来咱们启动 grpc_server 和 grpc_client 就能够进行测试了。

Spring Boot+Nacos+gRPC，一个区别于 OpenFeign 的微服务通信方案！

1. 依靠挑选

2. 准备工作

3. 代码实践

3.1 grpc-api

3.2 grpc-server

3.3 grpc-client

相关文章

Java并发——ThreadLocal总结

烂大街的 RPC 项目，如何和字节面试官聊出花儿来？

AutoGPT 使用教程及上手体验（一分钟配置可用）

URL长链接转短链接：为什么成为现代社会中必不可少的技术？

作者信息