Spring Boot与gRPC的完美融合：构建高效用户服务与订单服务通信

news2024/9/26 1:28:11

gRPC 是一种由 Google 开发的高性能、开源的远程过程调用（Remote Procedure Call, RPC）框架。它允许在不同的计算机系统或进程之间进行通信，使得分布式系统和微服务架构中的服务之间能够轻松地相互调用方法。gRPC 基于 HTTP/2 协议，并使用 Protocol Buffers（Protobuf）作为其接口定义语言和序列化格式。

gRPC 的主要特点和优点：

  1. 跨语言支持：
    gRPC 支持多种编程语言，包括 C++, Java, Python, Go, C#, Node.js 等，因此不同语言编写的服务之间可以无缝通信。

  2. 高性能：
    gRPC 使用 HTTP/2 协议，这意味着它支持双向流、多路复用和头部压缩，能更高效地利用网络资源，降低延迟。

  3. 协议定义：
    gRPC 使用 Protocol Buffers 作为其接口定义语言（IDL）。开发者通过定义 .proto 文件，描述服务和消息结构，gRPC 工具可以自动生成对应语言的客户端和服务器端代码。

  4. 简单易用：
    gRPC 提供了一套简洁的 API，开发者可以轻松创建和调用远程服务，就像调用本地方法一样。

  5. 双向流和流控：
    gRPC 不仅支持传统的一次性请求-响应模型，还支持双向流，使得客户端和服务器之间可以发送多个消息，并且这些消息可以并行地传输和处理。

  6. 安全性：
    gRPC 原生支持 SSL/TLS，可以很容易地实现安全的通信。

gRPC 的应用场景：

  1. 微服务架构：
    在微服务架构中，服务之间需要进行大量的通信，gRPC 提供了高效、跨语言的解决方案，适用于需要低延迟和高吞吐量的应用。

  2. 分布式系统：
    在分布式系统中，多个节点之间可能需要频繁通信，gRPC 的高性能和双向流支持非常适合这种场景。

  3. 实时通信：
    gRPC 的双向流特性使其非常适合需要实时数据交换的应用，例如实时聊天、视频流、物联网（IoT）应用等。

  4. 跨平台服务：
    由于 gRPC 支持多种语言和平台，它非常适合构建跨平台的分布式服务。

总结来说，gRPC 是一种高效、灵活的远程调用框架，特别适合需要跨语言、高性能通信的分布式系统和微服务架构。

一个常见的 gRPC 使用实例是在微服务架构中，尤其是像 Uber 这样的公司，它们拥有多个微服务，需要在不同的服务之间进行高效、低延迟的通信。

需求：用户服务和订单服务的通信

假设有一个电商平台，它的系统由多个微服务组成，其中包括：

  1. 用户服务（User Service）：管理用户信息，如注册、登录、个人资料等。
  2. 订单服务（Order Service）：处理用户的订单信息，如创建订单、查询订单状态等。
  3. grpc-api：将 gRPC 的 Protobuf 定义提取到一个独立的 grpc-api 模块中，其他微服务（如用户服务和订单服务）可以引用该模块，共享 gRPC 定义和生成的代码。

用户在下订单时，订单服务需要验证用户的身份，并获取用户的相关信息（如地址、支付方式等）。在这种情况下，订单服务需要调用用户服务来获取这些信息。

模块的目录结构

├─grpc-api
│  └─src
│      └─main
│          ├─java
│          │  └─com
│          │      └─song
│          │          └─api
│          ├─proto
│          └─resources
├─grpc-order
│  └─src
│      └─main
│          ├─java
│          │  └─com
│          │      └─song
│          │          ├─service
│          │          └─web
│          └─resources
└─grpc-user
    └─src
        └─main
            ├─java
            │  └─com
            │      └─song
            │          └─service
            └─resources

1. 创建 grpc-api 模块

创建一个 Maven 项目 grpc-api，用于存放 .proto 文件和生成的 gRPC Java 代码。这个模块将被其他服务（如用户服务和订单服务）依赖。

2. 在 grpc-api 模块中定义 .proto 文件

在 grpc-api 模块的 src/main/proto/ 目录下创建 .proto 文件，例如：

syntax = "proto3";

package com.song.api;
// 创建一个rpc 服务
service UserService {
  rpc GetUserInfo (GetUserInfoRequest) returns (GetUserInfoResponse);
}
//方法的入参请求对象与入参 。参数必须有唯一标识并还是有顺序的
message GetUserInfoRequest {
  string user_id = 1;
}
//方法的响应请求对象与响应参数 。参数必须有唯一标识并还是有顺序的
message GetUserInfoResponse {
  string name = 1;
  string email = 2;
  string address = 3;
}

3. 配置 grpc-api 模块的 pom.xml

在 grpc-api 模块的 pom.xml 中，配置 gRPC 和 Protobuf 相关的依赖和插件，以便自动生成 gRPC 代码。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>yqmm-grpc</artifactId>
        <groupId>com.song</groupId>
        <version>1.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>grpc-api</artifactId>
    <description>grpc公共api提取</description>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <grpc-version>1.40.1</grpc-version>
        <protobuf-version>3.21.9</protobuf-version>
    </properties>

    <dependencies>
        <!-- gRPC 依赖 -->
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-all</artifactId>
            <version>${grpc-version}</version>
        </dependency>

        <dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java</artifactId>
            <version>${protobuf-version}</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.google.protobuf/protoc -->
        <dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protoc</artifactId>
            <version>${protobuf-version}</version>
            <type>pom</type>
        </dependency>
    </dependencies>

    <build>
        <extensions>
            <extension>
                <groupId>kr.motd.maven</groupId>
                <artifactId>os-maven-plugin</artifactId>
            </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.19.1:exe:${os.detected.classifier}</protocArtifact>
                    <pluginId>grpc-java</pluginId>
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.50.2:exe:${os.detected.classifier}</pluginArtifact>
                    <!-- 设置输出目录 -->
                    <outputDirectory>${project.basedir}/src/main/java</outputDirectory>
                    <!-- 设置proto文件所在目录 -->
                    <protoSourceRoot>${project.basedir}/src/main/proto</protoSourceRoot>
                    <!-- 是否清除输出目录 -->
                    <clearOutputDirectory>false</clearOutputDirectory>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>compile-custom</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>

            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <layout>NONE</layout>
                    <skip>true</skip>           <!--    自己打出的包也能用 ,就是打出的包不包含BOOT-INF目录        -->
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

4. 生成 gRPC 代码

在 grpc-api 模块根目录下运行以下命令来生成 gRPC 代码：

mvn compile

或者
在这里插入图片描述

编译后，Protobuf 文件会被编译成 Java 类，生成的 gRPC 类会存放在 target/generated-sources/protobuf 目录中，并打包到 grpc-api 的 jar 文件中。

5. 创建用户服务模块

创建一个新的 Maven 模块（如 grpc-user），该模块将实现 gRPC 服务端，使用 grpc-api 共享的 gRPC 定义。

用户服务模块的 pom.xml

在 grpc-user 模块的 pom.xml 中，添加对 grpc-api 的依赖以及 gRPC 相关的依赖：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>yqmm-grpc</artifactId>
        <groupId>com.song</groupId>
        <version>1.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>grpc-user</artifactId>
    <description>服务端</description>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <grpc-service-version>2.14.0.RELEASE</grpc-service-version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.song</groupId>
            <artifactId>grpc-api</artifactId>
            <version>1.1-SNAPSHOT</version>
        </dependency>
<!--        服务端-->
        <dependency>
            <groupId>net.devh</groupId>
            <artifactId>grpc-server-spring-boot-starter</artifactId>
            <version>${grpc-service-version}</version>
        </dependency>
    </dependencies>
</project>
实现 gRPC 服务

在 grpc-user 模块中，基于 grpc-api 中的生成代码实现 gRPC 服务端：

/**
 * 自定义数据查询  提供给客户端数据
 */
@GrpcService
@Slf4j
public class UserService extends UserServiceGrpc.UserServiceImplBase{


    @Override
    public void getUserInfo(User.GetUserInfoRequest request,
                            StreamObserver<User.GetUserInfoResponse> responseObserver) {
        log.info("客户端发来的请求参数UserId>>>>>>>{}",request.getUserId());
        // todo 客户端发来的请求参数UserId 查询数据库db
        // todo 模拟db返回出来的用户数据
        User.GetUserInfoResponse response = User.GetUserInfoResponse.newBuilder()
                .setName("song-name")
                .setEmail("song.com")
                .setAddress("北京")
                .build();

        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

配置：application.yml

grpc:
  server:
    port: 9190  # 设置 gRPC 服务器端口
server:
  port: 10002

spring:
  application:
    name: grpc-user

启动类


@SpringBootApplication
public class UserApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserApplication.class, args);
    }
}

6. 创建订单服务模块

同样，创建订单服务模块（如 grpc-order），该模块将作为 gRPC 客户端调用用户服务。

订单服务模块的 pom.xml

在 grpc-order 模块的 pom.xml 中，添加对 grpc-api 模块的依赖以及 gRPC 相关的依赖：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>yqmm-grpc</artifactId>
        <groupId>com.song</groupId>
        <version>1.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>grpc-order</artifactId>
    <description>客户端</description>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <grpc-client-version>2.14.0.RELEASE</grpc-client-version>
    </properties>

    <dependencies>
<!--        客户端-->
        <dependency>
            <groupId>net.devh</groupId>
            <artifactId>grpc-client-spring-boot-starter</artifactId>
            <version>${grpc-client-version}</version>
        </dependency>
<!--        grpc-api -->
        <dependency>
            <groupId>com.song</groupId>
            <artifactId>grpc-api</artifactId>
            <version>1.1-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>
调用 gRPC 客户端

在 grpc-order 中，通过 gRPC 客户端调用用户服务获取用户信息：

@Service
public class UserClient {

    @GrpcClient("grpc-user") // yml里面指定访问服务端地址
    private UserServiceGrpc.UserServiceBlockingStub userServiceBlockingStub;



    public User.GetUserInfoResponse getUserInfo(String userId) {
        User.GetUserInfoRequest request = User.GetUserInfoRequest.newBuilder()
                .setUserId(userId)
                .build();
        return userServiceBlockingStub.getUserInfo(request);
    }
}
订单服务控制调用层

在订单服务中，可以使用 UserServiceClient 来获取用户信息并处理订单：

@RestController
public class OrderController {

    private final UserClient userClient;

    public OrderController(UserClient userClient) {
        this.userClient = userClient;
    }

    @GetMapping("/order")
    public String createOrder(@RequestParam String userId) {
        // 远程调用
        User.GetUserInfoResponse userInfo = userClient.getUserInfo(userId);
        // 处理订单逻辑
        return "为用户创建的订单：" + userInfo.getName()+userInfo.getAddress()+userInfo.getEmail();
    }
}

配置：application.yml

server:
  port: 10001

grpc:
  client:
    grpc-user: # 自定义服务名
      address: 'static://127.0.0.1:9190' # 调用 gRPC 的地址
      negotiation-type: plaintext # 明文传输
spring:
  application:
    name: grpc-order

启动类

@SpringBootApplication
public class OrderApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }
}

7. 启动和运行微服务

确保用户服务和订单服务的端口配置正确，启动两个服务：

  • 启动用户服务，它会在指定的 gRPC 端口监听（如 9190）。
  • 启动订单服务，通过 gRPC 客户端调用用户服务来获取用户信息并处理订单。
    客户端调用地址
    http://localhost:10001/order?userId=123
    在这里插入图片描述
    服务端执行信息
    在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2137911.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

21章 规则集和映射

21章 规则集和映射

1.同20章 线性表、栈、队列和优先队列的第10题。 2.同20章 线性表、栈、队列和优先队列的第1题。 3.修改程序清单21-7中的程序。如果关键字在注释或者字符串中&#xff0c;则不进行统计。将Java文件名从命令行传递。 import java.io.*; import java.util.Arrays; import jav…
阅读更多...
轨道列车舱门检测系统源码分享

轨道列车舱门检测系统源码分享

轨道列车舱门检测检测系统源码分享 [一条龙教学YOLOV8标注好的数据集一键训练_70全套改进创新点发刊_Web前端展示] 1.研究背景与意义 项目参考AAAI Association for the Advancement of Artificial Intelligence 项目来源AACV Association for the Advancement of Computer…
阅读更多...
【Android 13源码分析】WindowContainer窗口层级-3-实例分析

【Android 13源码分析】WindowContainer窗口层级-3-实例分析

在安卓源码的设计中&#xff0c;将将屏幕分为了37层&#xff0c;不同的窗口将在不同的层级中显示。 对这一块的概念以及相关源码做了详细分析&#xff0c;整理出以下几篇。 【Android 13源码分析】WindowContainer窗口层级-1-初识窗口层级树 【Android 13源码分析】WindowCon…
阅读更多...
Redis的AOF持久化、重写机制、RDB持久化、混合持久化

Redis的AOF持久化、重写机制、RDB持久化、混合持久化

1、AOF持久化 1.1.AOF持久化大致过程 概括&#xff1a;命令追加&#xff08;append&#xff09;、文件写入、文件同步&#xff08;sync&#xff09; Redis 每执行一条写操作命令&#xff0c;就把该命令以追加的方式写入到一个文件里&#xff0c;然后重启 Redis 的时候&#…
阅读更多...
Pytest配置文件pytest.ini如何编写生成日志文件？

Pytest配置文件pytest.ini如何编写生成日志文件？

1、新建pytest.ini文件 [pytest] log_clitrue log_leveLNOTSET log_format %(asctime)s %(levelname)s %(message)s %(filename)s %(funcName)s %(lineno)d log_date_format %Y-%m-%d %H:%M:%Slog_file ./logdata/log.log log_file_level info log_file_format %(asctime…
阅读更多...
实时（按帧）处理的低通滤波C语言实现

实时（按帧）处理的低通滤波C语言实现

写在前面&#xff1a; 低通滤波采用一般的FIR滤波器&#xff0c;因为本次任务&#xff0c;允许的延迟较多&#xff0c;或者说前面损失的信号可以较多&#xff0c;因此&#xff0c;涉及一个很高阶的FIR滤波器&#xff0c;信号起始段的信号点可以不处理&#xff0c;以及&#xf…
阅读更多...
召回01 基于物品是协同过滤 ItemCF

召回01 基于物品是协同过滤 ItemCF

相似度&#xff0c;类似机器学习里面常用的cosine相似度
阅读更多...
python AssertionError: Torch not compiled with CUDA enabled

python AssertionError: Torch not compiled with CUDA enabled

查看&#xff1a;torch import torch# 输出带CPU&#xff0c;表示torch是CPU版本的 print(ftorch的版本是&#xff1a;{torch.__version__}) # print(ftorch是否能使用cuda&#xff1a;{torch.cuda.is_available()}) 修改一下代码&#xff0c;将cuda改成cpu 最后运行正常&…
阅读更多...
【React源码解析】深入理解react时间切片和fiber架构

【React源码解析】深入理解react时间切片和fiber架构

时间切片 假如React一个更新需要耗时200ms&#xff0c;我们可以将其拆分为40个5ms的更新&#xff08;后续会讲到如何拆分&#xff09;&#xff0c;然后每一帧里只花5ms来执行更新。那么&#xff0c;每一帧里不就剩余16.7 - 5 11.7ms的时间可以进行用户事件&#xff0c;渲染等…
阅读更多...
13 Midjourney从零到商用·进阶篇：灯光、角度与风格等精细控制方法

13 Midjourney从零到商用·进阶篇：灯光、角度与风格等精细控制方法

在前面我们了解了提示词的书写&#xff0c;那么如何利用提示词来精确控制生成画面的灯光、角度与风格 呢&#xff1f;在本篇文章中我么一起来探讨一下。 一、灯光 在摄影中&#xff0c;对灯光的要求都是非常高的。灯光能对人物、动物、物体、场景等进行修饰。每一种微小的的灯光…
阅读更多...
链接升级：Element UI ＜el-link＞ 的应用

链接升级：Element UI ＜el-link＞ 的应用

链接升级&#xff1a;Element UI 的应用 一 . 创建文字链接1.1 注册路由1.2 创建文字链接 二 . 文字链接的属性2.1 文字链接的颜色2.2 是否显示下划线2.3 是否禁用状态2.4 填写跳转地址2.5 加入图标 在本篇文章中&#xff0c;我们将深入探索Element UI中的<el-link>组件—…
阅读更多...
本地不能訪問linux的kafka服務

本地不能訪問linux的kafka服務

1.本地使用kafka客戶端工具連接kafka服務&#xff0c;提示連接失敗 2. 本地使用telnet ip port命令也失敗 3.查看zookeeper和kafka服務是否正常 ps -ef | grep zookeeper ps -ef | grep kafka 3.關閉操作系統的防火墻(僅限于測試使用) 3.1.禁用防火墙 systemctl stop firew…
阅读更多...
先有正态分布，还是先有高斯函数？

先有正态分布，还是先有高斯函数？

正态分布&#xff08;也称为高斯分布&#xff09;是由德国数学家卡尔弗里德里希高斯在研究天文学中的误差分布时提出的。而高斯函数通常指的是正态分布的概率密度函数&#xff0c;它是描述正态分布特性的一个数学表达式。因此&#xff0c;可以明确地说&#xff0c;是先有正态分…
阅读更多...
eureka.client.service-url.defaultZone的坑

eureka.client.service-url.defaultZone的坑

错误的配置 eureka: client: service-url: default-zone: http://192.168.100.10:8080/eureka正确的配置 eureka: client: service-url: defaultZone: http://192.168.100.10:8080/eureka根据错误日志堆栈打断电调试 出现两个key&#xff0c;也就是defaultZone不支持snake-c…
阅读更多...
Vue: watch5种监听情况

Vue: watch5种监听情况

目录 一.watch的性质与作用 1.watch 的性质包括&#xff1a; 2.watch 常用于以下场景&#xff1a; 二.监视ref定义的基本类型数据 三.监视ref定义的对象类型数据 四.监视reactive定义的对象类型数据 五.监视ref或reactive定义的对象类型数据中的某个属性 六.监视上述的…
阅读更多...
c++题目_【模板】最小生成树Prim

c++题目_【模板】最小生成树Prim

题目描述 这是一道最小生成树Prim的模板题&#xff0c;本题与【模板】最小生成树Kruskal&#xff0c;仅仅只有nn和mm的大小不同 给出一个无向图&#xff0c;求出最小生成树&#xff0c;如果该图不连通&#xff0c;则输出orz 输入 第一行输入2个正整数n,mn,m&#xff0c;代表…
阅读更多...
【自然语言处理】实验三：新冠病毒的FAQ问答系统

【自然语言处理】实验三：新冠病毒的FAQ问答系统

目录 前言 1.新建data_process.py 1.1导入包并定义功能模块1用来读取问题和答案FAQ的文件 1.2功能模块2&#xff1a;进行问题/问题列表处理&#xff08;正则化&#xff0c;分词&#xff09; 1.3功能模块3&#xff1a;处理输入的问题 1.4功能模块4&#xff1a;计算输入问题与问题…
阅读更多...
Java | Leetcode Java题解之第403题青蛙过河

Java | Leetcode Java题解之第403题青蛙过河

题目&#xff1a; 题解&#xff1a; class Solution {public boolean canCross(int[] stones) {int n stones.length;boolean[][] dp new boolean[n][n];dp[0][0] true;for (int i 1; i < n; i) {if (stones[i] - stones[i - 1] > i) {return false;}}for (int i 1…
阅读更多...
redis windows安装包下载路径

redis windows安装包下载路径

https://github.com/tporadowski/redis/releases 通过网盘分享的文件&#xff1a;Redis-x64-5.0.14.1.zip 链接: https://pan.baidu.com/s/12XQOfKB75yajJ0fJLzl4rQ?pwd1234 提取码: 1234
阅读更多...
C++数据结构-树的概念及分类介绍（基础篇）

C++数据结构-树的概念及分类介绍（基础篇）

1.什么是树 树是数据结构中的一种&#xff0c;其属于非线性数据结构结构的一种&#xff0c;我们前文所提到的数据结构多数都是线性的&#xff0c;这也是较为简单的数据结构&#xff0c;而接下来的树与图均属于非线性数据结构&#xff0c;也是概念极多的一类。 树是由结点或顶…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023