gRPC 的基础知识后面跟小伙伴们分享了很多了,明天再写一篇给这个小小的系列收个尾。
咱们后面介绍的都是 gRPC 的根本用法,最终目标当然是心愿可能在 Spring Boot 中用上这个货色,置信大部分小伙伴对于微服务的通信计划如 OpenFeign、Dubbo、音讯驱动都有所理解,然而对于这三种计划之外的其余计划,可能听的多用的少,明天咱们就来实际一下 gRPC 这种计划。
顺便说一下我为什么会想到写 gRPC 教程呢,是因为之前我想给小伙伴们总结一下常见的各种微服务通信计划。整顿到 gRPC 的时候发现我还没写过 gRPC 相干的教程,因而就有了一个小系列。
1. 依赖抉择
Spring Boot 整合 gRPC,官网其实并没有提供相应的依赖,不过目前有一个比拟风行的第三方库能够应用:
- https://github.com/yidongnan/grpc-spring-boot-starter
接下来松哥就联合这个库,来和小伙伴们演示一下 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 就能够进行测试了。