手把手教你寫一個(gè)SpringBoot+gRPC服務(wù)
更新時(shí)間：2023年12月01日 17:01:25 作者：酸奶小肥陽(yáng)
本文將在本地環(huán)境下搭建gRPC客戶端和服務(wù)端,并成功建立通訊發(fā)送消息的方式,從而幫助大家深入了解gRPC在Spring Boot項(xiàng)目中的應(yīng)用,有需要的小伙伴可以參考下
請(qǐng)注意，本文不會(huì)對(duì)gRPC基礎(chǔ)概念進(jìn)行解釋，而是著重介紹服務(wù)的搭建過(guò)程。如果你是零基礎(chǔ)的伙伴，請(qǐng)先自行學(xué)習(xí)gRPC的基礎(chǔ)知識(shí)。接下來(lái)，讓我們?cè)诒镜丨h(huán)境下搭建gRPC客戶端和服務(wù)端，并成功建立通訊發(fā)送消息的方式，來(lái)學(xué)習(xí)gRPC在Spring Boot項(xiàng)目中的應(yīng)用。
客戶端（發(fā)送rpc請(qǐng)求）
1、導(dǎo)入maven依賴
包含rpc所使用的依賴和構(gòu)建protobuf的插件。完整的<dependencies>和<build>如下：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-netty-shaded</artifactId>
<version>1.59.1</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-protobuf</artifactId>
<version>1.59.1</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-stub</artifactId>
<version>1.59.1</version>
</dependency>
<dependency> <!-- necessary for Java 9+ -->
<groupId>org.apache.tomcat</groupId>
<artifactId>annotations-api</artifactId>
<version>6.0.53</version>
<scope>provided</scope>
</dependency>
</dependencies>
<build>
<extensions>
<extension>
<groupId>kr.motd.maven</groupId>
<artifactId>os-maven-plugin</artifactId>
<version>1.7.1</version>
</extension>
</extensions>
<plugins>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.24.0:exe:${os.detected.classifier}</protocArtifact>
<pluginId>grpc-java</pluginId>
<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.59.1:exe:${os.detected.classifier}</pluginArtifact>
</configuration>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
導(dǎo)入成功后，可以在maven的插件中看到protobuf選項(xiàng)；
2、編寫Proto文件
在main目錄下創(chuàng)建proto軟件包，將編寫好的Proto文件放在該目錄（src/main/proto）下。示例Proto文件內(nèi)容如下
syntax = "proto3";
option java_multiple_files = true;
option java_package = "com.example.server";
option java_outer_classname = "HelloWorldProto";
option objc_class_prefix = "HLW";
package com.example.server;
service Greeter {
rpc SayHello (HelloRequest) returns (HelloReply) {}
}
message HelloRequest {
string name = 1;
}
message HelloReply {
string message = 1;
}
完成Proto文件編寫后，執(zhí)行mvn install命令。你會(huì)在target/generated-sources/protobuf路徑下看到gRPC編譯生成的Java代碼。這些生成的代碼是實(shí)現(xiàn)gRPC在不同語(yǔ)言間進(jìn)行RPC通訊的基礎(chǔ)。
3、編寫客戶端代碼
創(chuàng)建一個(gè)HelloWorldClient類，實(shí)例化stub對(duì)象，并發(fā)送rpc請(qǐng)求的方法；
@Service
public class HelloWorldClient {
private GreeterGrpc.GreeterBlockingStub stub;
@Value("${grpc.hello-world.host}")
private String host;
@Value("${grpc.hello-world.port}")
private Integer port;
@PostConstruct
void init() {
ManagedChannel channel =
ManagedChannelBuilder.forAddress(host, port)
.keepAliveWithoutCalls(true)
.keepAliveTime(60, TimeUnit.SECONDS)
.keepAliveTimeout(3, TimeUnit.SECONDS)
.idleTimeout(60, TimeUnit.SECONDS)
.maxInboundMessageSize(Integer.MAX_VALUE)
.usePlaintext().build();
stub = GreeterGrpc.newBlockingStub(channel);
}
/**
* 說(shuō)“你好”
*
* @param name 名字
* @return {@link String}
*/
public String sayHello(String name) {
HelloRequest request = HelloRequest.newBuilder().setName(name).build();
HelloReply helloReply = stub.sayHello(request);
return helloReply.getMessage();
}
}
這里我配置的gRPC服務(wù)端地址如下，請(qǐng)根據(jù)實(shí)際情況修改host和port的值。
grpc:
hello-world:
host: 127.0.0.1
port: 6565
接下來(lái)，讓我們繼續(xù)開(kāi)發(fā)服務(wù)端的代碼。
服務(wù)端（處理rpc請(qǐng)求并返回處理數(shù)據(jù)）
1、導(dǎo)入maven依賴
與客戶端依賴略有不同，服務(wù)端中我們使用了grpc-spring-boot-starter
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-protobuf</artifactId>
<version>1.53.0</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-stub</artifactId>
<version>1.53.0</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.lognet</groupId>
<artifactId>grpc-spring-boot-starter</artifactId>
<version>2.3.2</version>
</dependency>
</dependencies>
<!-- 添加protobuf-maven-plugin插件 編譯proto文件-->
<build>
<extensions>
<extension>
<groupId>kr.motd.maven</groupId>
<artifactId>os-maven-plugin</artifactId>
<version>1.6.2</version>
</extension>
</extensions>
<plugins>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.17.3:exe:${os.detected.classifier}</protocArtifact>
<pluginId>grpc-java</pluginId>
<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.42.0:exe:${os.detected.classifier}</pluginArtifact>
</configuration>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
2、導(dǎo)入Proto文件
這里的proto文件盡量和客戶端的保持一致，完成和客戶端步驟2同樣的事兒。需要注意的是，在proto文件中，用package聲明生成的Java類的包名，請(qǐng)與服務(wù)端實(shí)現(xiàn)類的包結(jié)構(gòu)保持一致，這樣才能正常地完成依賴導(dǎo)入和方法重寫；
例如：
3、編寫服務(wù)端實(shí)現(xiàn)類代碼
@GRpcService：用于標(biāo)記這個(gè)類是一個(gè)gRPC服務(wù)端的實(shí)現(xiàn)類。它告訴Spring Boot框架將這個(gè)類注冊(cè)為一個(gè)gRPC服務(wù)端，并自動(dòng)處理gRPC請(qǐng)求。- 繼承自
GreeterGrpc.GreeterImplBase類，表示它是rpc服務(wù)Greeter的實(shí)現(xiàn)類，在類中，我們可以重寫rpc接口的實(shí)現(xiàn)方法，來(lái)處理接收到請(qǐng)求；
/**
* hello service impl
*
* @author yangyang
* @date 2023/11/30
*/
@GRpcService
@Slf4j
public class HelloServiceImpl extends GreeterGrpc.GreeterImplBase {
@Override
public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
// 獲取客戶端發(fā)送的請(qǐng)求消息
String name = request.getName();
// 構(gòu)建響應(yīng)消息
HelloReply response = HelloReply.newBuilder()
.setMessage("Hello, " + name + "!")
.build();
log.info("[grpc server]: response: {}", response);
// 發(fā)送響應(yīng)消息
responseObserver.onNext(response);
// 通知客戶端響應(yīng)已經(jīng)完成
responseObserver.onCompleted();
}
}
4、配置端口號(hào)，啟動(dòng)服務(wù)
可通過(guò)此配置修改rpc的端口號(hào)（默認(rèn)6565）
grpc: # grpc server port port: 6565 server: port: 8081
服務(wù)啟動(dòng)后，可以在日志中看到端口信息
可以選擇使用通過(guò)客戶端發(fā)送請(qǐng)求來(lái)測(cè)試服務(wù)，或者使用postman等工具發(fā)送rpc接口。至此，一個(gè)簡(jiǎn)單且完整的SpringBoot gRPC客戶端與服務(wù)端開(kāi)發(fā)完成！
以上就是手把手教你寫一個(gè)SpringBoot+gRPC服務(wù)的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot gRPC服務(wù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:
相關(guān)文章
Java設(shè)計(jì)模式之java責(zé)任鏈模式詳解
這篇文章主要介紹了JAVA 責(zé)任鏈模式的的相關(guān)資料，文中講解非常細(xì)致，代碼幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下2021-09-09
Java使用DateFormatter格式化日期時(shí)間的方法示例
這篇文章主要介紹了Java使用DateFormatter格式化日期時(shí)間的方法,結(jié)合具體實(shí)例分析了java使用DateFormatter格式化日期時(shí)間的相關(guān)操作技巧,需要的朋友可以參考下2017-04-04
Mybatis?在?insert?插入操作后返回主鍵?id的操作方法
這篇文章主要介紹了Mybatis?在?insert?插入操作后返回主鍵?id的操作方法,本文結(jié)合示例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-12-12
java設(shè)計(jì)模式之單例模式學(xué)習(xí)
單例對(duì)象（Singleton）是一種常用的設(shè)計(jì)模式。在Java應(yīng)用中，單例對(duì)象能保證在一個(gè)JVM中，該對(duì)象只有一個(gè)實(shí)例存在2014-01-01
SpringBoot+WebSocket實(shí)現(xiàn)IM及時(shí)通訊的代碼示例
項(xiàng)目中碰到需要及時(shí)通訊的場(chǎng)景,使用springboot集成websocket,即可實(shí)現(xiàn)簡(jiǎn)單的及時(shí)通訊,本文介紹springboot如何集成websocket、IM及時(shí)通訊需要哪些模塊、開(kāi)發(fā)和部署過(guò)程中遇到的問(wèn)題、以及實(shí)現(xiàn)小型IM及時(shí)通訊的代碼,需要的朋友可以參考下2023-10-10
簡(jiǎn)單實(shí)現(xiàn)java音樂(lè)播放器
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)音樂(lè)播放器的相關(guān)代碼，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-06-06
基于java HashMap插入重復(fù)Key值問(wèn)題
這篇文章主要介紹了基于java HashMap插入重復(fù)Key值問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
使用IDEA開(kāi)發(fā)配置Java Web的初始化過(guò)程
該教程使用idea開(kāi)發(fā)工具初始化javaweb項(xiàng)目，該運(yùn)行在tomcat服務(wù)器上通過(guò)配置項(xiàng)目環(huán)境變量保證tomcat正常啟動(dòng)，具體操作配置教程參考下本文2021-06-06
MyBatis3傳遞多個(gè)參數(shù)(Multiple Parameters)
這篇文章主要介紹了MyBatis3傳遞多個(gè)參數(shù)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
SpringBoot結(jié)合Redis實(shí)現(xiàn)會(huì)話管理功能
在Web應(yīng)用程序中，會(huì)話管理是一項(xiàng)重要的任務(wù)，它涉及跟蹤用戶的身份驗(yàn)證狀態(tài)和其他相關(guān)信息，以確保用戶在與應(yīng)用程序交互時(shí)的連續(xù)性和安全性，在本文中，我們將探討如何使用Spring Boot和Redis實(shí)現(xiàn)高效的會(huì)話管理2023-06-06