百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

一文读懂!Spring Boot3 中使用 gRPC 实现微服务通信

ccwgpt 2025-05-22 09:35 4 浏览 0 评论

在当今互联网大厂的后端开发领域,微服务架构已成为构建大型应用系统的主流方式。随着业务的不断扩张,如何实现微服务之间高效、稳定的通信,成为了开发人员面临的关键挑战。今天,咱们就聚焦于 Spring Boot3 框架,深入探讨如何巧用 gRPC 来达成微服务的通信。

gRPC 是什么,为何选择它?

gRPC,即 Google Remote Procedure Call,是一款现代开源且高性能的远程过程调用框架,能在任何环境中顺畅运行。它基于 HTTP/2 设计,支持多种编程语言和平台,简直就是微服务通信的一把利器。

高性能表现

gRPC 选用 HTTP/2 作为传输协议,具备二进制组帧、多路复用、双向全双工通信以及流式处理等特性,极大地提升了性能。与常见的 JSON 相比,gRPC 消息序列化速度更快,消息体积更小,能显著减少网络传输开销,提升系统响应速度。

跨平台与跨语言优势

对于互联网大厂复杂的技术栈而言,这一特性尤为关键。后端开发可能涉及 C++、Java、Python、Go 等多种语言,gRPC 支持多种编程语言和平台,使得不同语言编写的微服务能够无缝对接,轻松实现统一的 RPC 框架调用。

灵活性与可扩展性佳

gRPC 提供丰富功能,如负载平衡、跟踪、健康检查和身份验证等,且这些功能都可插拔,开发人员能依据项目需求灵活配置和扩展,满足不同业务场景下的通信需求。

安全性保障

在数据传输安全愈发受重视的当下,gRPC 支持 TLS 加密,有力确保数据在传输过程中的安全。同时,它还支持 JWT(JSON Web Tokens)等多种认证机制,为服务访问筑牢安全防线。

在微服务架构里,gRPC 能高效连接多语言服务,实现服务间的快速通信;适用于分布式计算场景,将设备、移动应用程序和浏览器与后端服务紧密相连;与 REST API 相比,gRPC 的 API 设计风格更高效灵活,特别适合对性能和延迟要求严苛的应用场景。

Spring Boot3 基础回顾

在深入 gRPC 与 Spring Boot3 的集成前,咱们先来简单回顾下 Spring Boot3。它是 Spring 框架的重要模块,旨在大幅简化 Spring 应用的开发流程,让开发者能迅速上手并搭建功能完善的应用程序。Spring Boot3 秉持约定优于配置原则,开发人员得以将更多精力聚焦于业务逻辑,而非耗费在繁杂的配置细节上。

它拥有诸多显著优势,像简化的配置,借助自动配置功能,减少了开发者在配置文件中的工作量;强大的依赖管理,自带依赖管理功能,可自动引入所需依赖,降低配置出错几率;快速开发特性,提供大量默认配置,开发者能迅速启动 Spring Boot 应用;内置 Tomcat、Jetty 或 Undertow 服务器,简化了部署流程;还有 Actuator 模块提供的健康监控功能,便于实时掌握应用运行状态。并且,Spring Boot3 与 Spring Cloud 等框架集成良好,对微服务架构开发的支持也十分出色。

Spring Boot3 集成 gRPC 实战

引入相关依赖

在 Spring Boot 项目里使用 gRPC,首先要在项目的pom.xml文件中添加相关 gRPC 依赖。这些依赖涵盖 gRPC 基础库、与 Protobuf 的集成库,以及 Spring Boot 对 gRPC 的支持库。务必保证所使用的版本相互兼容,并依据项目实际需求合理调整。要是项目还需使用 gRPC 的安全认证、健康检查等功能,那就可能得额外添加更多依赖项。例如:

<dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc - netty - shaded</artifactId>
    <version>1.56.1</version>
</dependency>
<dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc - protobuf</artifactId>
    <version>1.56.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring - boot - starter - grpc</artifactId>
    <version>3.4.4</version>
</dependency>

服务定义与代码生成

在 gRPC 中,服务通过.proto文件进行精准定义,开发人员借助 Protocol Buffers(简称 Protobuf)来定义结构化消息。基于.proto文件,gRPC 提供 protoc 编译器,用以生成支持多种编程语言的客户端和服务端代码,轻松实现跨语言 RPC 调用。

比如,定义一个简单的用户服务,.proto文件内容大致如下:

syntax = "proto3";
package com.example.user;
option java_multiple_files = true;
option java_package = "com.example.user";
option java_outer_classname = "UserProto";
message UserRequest {
    string name = 1;
}
message UserResponse {
    string message = 1;
}
service UserService {
    rpc getUser(UserRequest) returns (UserResponse);
}

定义好.proto文件后,通过 protoc 编译器生成 Java 代码。若想在 Maven 编译时自动生成 proto 对应的 Java 代码,还需添加 Maven 插件和相关依赖,参考os - maven - plugin和protobuf - maven - plugin。配置完成后,执行mvn compile指令,就能自动生成所需 Java 代码,无需再借助外部指令。

创建 gRPC 服务

在 Spring Boot 应用中,可创建一个组件来实现 gRPC 服务。先定义服务接口的实现类,以刚才的用户服务为例:

import com.example.user.UserProto;
import com.example.user.UserServiceGrpc;
import io.grpc.stub.StreamObserver;
import net.devh.boot.grpc.server.service.GrpcService;
@GrpcService
public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase {
    @Override
    public void getUser(UserProto.UserRequest request, StreamObserver<UserProto.UserResponse> responseObserver) {
        String name = request.getName();
        String message = "Hello, " + name + "!";
        UserProto.UserResponse response = UserProto.UserResponse.newBuilder()
              .setMessage(message)
              .build();
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

上述代码中,UserServiceImpl类继承自
UserServiceGrpc.UserServiceImplBase,并重写了getUser方法,处理用户请求并返回响应。

调用 gRPC 服务

同样在 Spring Boot 应用里,还需创建一个服务来调用 gRPC 服务。比如创建一个服务类,通过 gRPC 客户端来发起调用:

import com.example.user.UserProto;
import com.example.user.UserServiceGrpc;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import org.springframework.stereotype.Service;
@Service
public class UserClientService {
    private final UserServiceGrpc.UserServiceBlockingStub userServiceBlockingStub;
    public UserClientService() {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
              .usePlaintext()
              .build();
        userServiceBlockingStub = UserServiceGrpc.newBlockingStub(channel);
    }
    public String getUser(String name) {
        UserProto.UserRequest request = UserProto.UserRequest.newBuilder()
              .setName(name)
              .build();
        UserProto.UserResponse response = userServiceBlockingStub.getUser(request);
        return response.getMessage();
    }
}

在这个类中,先构建一个ManagedChannel连接到 gRPC 服务端,然后创建UserServiceBlockingStub用于发起同步阻塞式调用,getUser方法封装了具体的调用逻辑,向服务端发送请求并获取响应。

启动与测试

完成上述配置和代码编写后,分别启动服务端和客户端。当客户端发起调用时,就能通过 gRPC 实现微服务间的通信了。可以编写一些简单的测试代码来验证功能,比如:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class GrpcDemoApplication implements CommandLineRunner {
    @Autowired
    private UserClientService userClientService;
    public static void main(String[] args) {
        SpringApplication.run(GrpcDemoApplication.class, args);
    }
    @Override
    public void run(String... args) throws Exception {
        String name = "张三";
        String result = userClientService.getUser(name);
        System.out.println(result);
    }
}

运行上述代码,若一切正常,控制台会输出Hello, 张三!,表明 gRPC 通信成功实现。

总结

通过在 Spring Boot3 项目中集成 gRPC,我们能够充分利用 gRPC 的高性能、跨语言等特性,高效实现微服务之间的通信。各位互联网大厂的后端开发同仁们,不妨在实际项目中尝试一番,感受 gRPC 带来的便捷与高效。要是在实践过程中有任何疑问或心得,欢迎在评论区交流分享!

相关推荐

如何为Hadoop选择最佳弹性MapReduce框架

ZDNet至顶网服务器频道07月22日新闻消息:亚马逊Web服务的弹性MapReduce是一项基于Hadoop的实施,它可允许你运行大型的预处理工作,如格式转换和数据聚合等。虽然我们可以选择很多的...

《平安小猪》:J.K.罗琳用“魔法”放大的真实

对很多孩子来说,某些玩具是抚慰心灵的“忠实伙伴”,几乎无可替代。J.K.罗琳在看到儿子大卫对玩偶小猪的依恋后创作了“平安小猪”的故事,这也是她自《哈利·波特》之后创作的首部儿童长篇小说。男孩杰克在平安...

一页纸精华 | HDFS

要入门大数据,最好的办法就是理清hadoop的生态系统。本期为你介绍分布式文件系统HDFS。ApacheHadoop2.0生态系统如下图所示:Hadoop2.0生态系统图Hadoop核心项目包括:H...

谷歌搁置与法国出版商的协议,将等候反垄断裁定

据路透社6月29日消息,两位知情消息人士称,谷歌搁置了与一些法国出版商达成的为新闻内容付费的初步协议,将等待反垄断审议结果。该决定可能为欧洲在线新闻的版权谈判定下基调。文件显示,按照谷歌与法国新闻总联...

Java 微服务从源码实战开始 | Gitee 项目推荐

在软件开发的不同时期、阶段,对技术架构的理解、选择和应用都有着不一样的诉求。微服务架构是当前互联网业界的一个技术热点,它的思想也更符合我们的目标:根据业务模块划分服务种类。每个服务可以独立部署并且互相...

快讯|谷歌搁置向法国出版商付费协议:等待反垄断决定

财经网科技6月30日讯,据新浪科技消息,两位知情人士透露,谷歌已经搁置此前与一些法国出版商达成的为新闻内容付费的初步协议。因为谷歌正在等待一项反垄断决定,这项决定可能会为该公司的欧洲在线新闻版权谈判定...

外媒:谷歌搁置与法国出版商的协议 等候反垄断决定

路透中文网30日报道,据两位知情消息人士透露,谷歌GOOGL.O搁置了与一些法国出版商达成的为新闻内容付费的初步协议,等待一项反垄断决定。该决定可能为欧洲在线新闻的版权谈判定下基调。报道显示,根据路透...

大数据任务调度框架Oozie

Oozie(驯象人)是一个基于工作流引擎的开源框架,由Cloudera公司贡献给Apache,提供对HadoopMapReduce、PigJobs的任务调度与协调。Oozie需要部署到JavaS...

惊了!SpringBoot 3.4 触雷,升级后参数绑定竟悄悄破坏你的代码?

背景在微服务架构中,我们经常利用HTTP请求头来控制系统行为,比如实现灰度发布和流量控制。在PIG微服务框架中,我们通过重写SpringCloudLoadBalancer,根据请求he...

《终结者》:科幻电影巅峰的里程碑

在阅读此文之前,麻烦您点击一下“关注”,既方便您进行讨论和分享,又能给您带来不一样的参与感,感谢您的支持。文|庭芥摘要:本文以一位影评家的视角赏析詹姆斯·卡梅隆执导的经典科幻电影《终结者》。通过对该...

AI已经越过红线?复旦大学:在知道自己将被关闭后,AI复制了自己

2024年12月9日,复旦大学的一项研究引发了全球科技界的强烈关注。研究团队对Meta与阿里巴巴旗下的两个大型AI系统展开测试,结果发现,在知晓自身可能被关闭的情况下,它们居然选择自我复制。这不是普通...

重磅开源!LocalAI让你在个人电脑上运行AI大模型,无需显卡,已获28K Star!

随着AI技术的快速发展,如何在本地设备上高效运行AI模型成为了开发者关注的焦点。LocalAI开源项目提供了一个革命性的解决方案-它让用户能够在个人电脑上轻松部署和运行各种AI模型,并且完全兼容...

了解《终结者》的恐怖末日世界观,能让你看懂《终结者6》

相信很多人的科幻动作启蒙片,应该就是《终结者》系列,起码对于我来说,童年的暑假里,不止一次反复看着《终结者2》的电影,深深被影片中施瓦辛格的硬核铁汉形象吸引,也为片中的液态机器人着迷。《终结者》系列成...

Golang底层是用什么语言编写的?

Go底层语言Go语言在1.5版本之前主要由汇编和C语言写的,C语言占比85%以上,另外有少量的周边模块如文档等,带了些htmlshellperl代码,可以忽略不计。1.5版本及之后...

skynet服务的缺陷 lua死循环

服务端高级架构—云风的skynet这边有一个关于云风skynet的视频推荐给大家观看点击就可以观看了!skynet是一套多人在线游戏的轻量级服务端框架,使用C+Lua开发。skynet的显著优点是,...

取消回复欢迎 发表评论: