Springboot之接入gRPC

1、maven依赖

<properties><!-- grpc --><protobuf.version>3.5.1</protobuf.version><protobuf-plugin.version>0.6.1</protobuf-plugin.version><grpc.version>1.42.1</grpc.version><os-maven-plugin.version>1.6.0</os-maven-plugin.version>
</properties><!-- grpc -->
<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><groupId>io.grpc</groupId><artifactId>grpc-netty</artifactId><version>${grpc.version}</version>
</dependency>

2、编译环境构建

<build><extensions><!-- os-maven-plugin --><extension><groupId>kr.motd.maven</groupId><artifactId>os-maven-plugin</artifactId><version>${os-maven-plugin.version}</version></extension></extensions><plugins><!-- protobuf-maven-plugin --><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><!--默认值--><protoSourceRoot>${project.basedir}/src/main/proto</protoSourceRoot><outputDirectory>${project.basedir}/src/main/java</outputDirectory><!--设置是否在生成java文件之前清空outputDirectory的文件，默认值为true，设置为false时也会覆盖同名文件--><clearOutputDirectory>false</clearOutputDirectory></configuration><executions><execution><goals><goal>compile</goal><goal>compile-custom</goal></goals></execution></executions></plugin></plugins></build>

3、添加proto文件

在src/java同级添加proto文件夹，内部添加proto文件

修改java_package，生成包路径

syntax = "proto3";option java_multiple_files = true;
option java_package = "com.bhl.biz.grpc";package media_broker;// The service definition.
service MediaBroker {rpc open(MediaObject) returns (MediaStatus) {};rpc fetchFrame(MediaObject) returns (FrameObject) {};rpc fetchImage(MediaObject) returns (ImageObject) {};rpc close(MediaObject) returns (MediaStatus) {};
}message MediaObject {string address = 1;
}message MediaStatus {bool status = 1;string message = 2;
}

4、生成代码

依次执行protobuf:compile、compile-custom

随后生成对应代码文件

5、注册grpc

官方参考demo

https://github.com/grpc/grpc-java/blob/master/examples/src/main/java/io/grpc/examples/helloworld/HelloWorldClient.java

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;private ManagedChannel channel;
private MediaBrokerGrpc.MediaBrokerBlockingStub blockingStub;void init(){// 127.0.0.1 50051channel = ManagedChannelBuilder.forAddress(grpcConfig.getHost(), grpcConfig.getPort()).usePlaintext().build();blockingStub = MediaBrokerGrpc.newBlockingStub(channel);
}

核心文件 MediaBrokerGrpc

三种通信方式

6、发送请求

请求为已注册的服务

// 请求对象
MediaObject object = MediaObject.newBuilder().setAddress(address).build();
// 发送请求
MediaStatus status = blockingStub.open(object);
log.info(status.toString());
boolean result = status.getStatus();