微服务消息驱动组件 SpringCloud Stream

墨蓝 2024-03-25 21:34 165阅读 0赞

### 简介 ###

SpringCloud Stream 是一个用于构建与共享消息系统连接的高度可扩展的事件驱动微服务组件。它提供了一个灵活的编程模型，基于Spring Boot 建立独立的生产级 Spring 应用程序，并使用 Spring Integration 提供与消息代理的连接可以让我们在使用时几乎无需关心具体的消息队列实现。它屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型，让开发人员能够更多的关注自己的业务。

### 架构模型 ###

![format_png][]

或许我们也可以看一个更为简洁的图

![format_png 1][]

我们可以看到，每个系统只依赖于自己的 `Binder` 和消息中间件或者说其他系统交互， Stream 隐藏了所有消息的发送细节，对于它来说只关心三个核心模块

*  **Destination Binders**：目标绑定器，告诉 Stream 你需要绑定到哪个消息队列服务的 `Binder` 实现即可。例如 `RabbitMQ` 还是 `Kafka` 的 `Binder`？这是它的核心构建块，负责支持和提供与我们拥有的外部系统或外部消息传递系统的集成
 *  **Destination Bindings**：目的地绑定，把消息生产者和消费者之间的桥梁提供给 Stream 。例如对于 `RabbitMQ` 来说，你需要告诉 Stream 当前系统发送消息所使用的的 `channel -> exchange -> routingKey -> queue` 分别是什么（当然这些都是在配置文件中完成的）
 *  **Message**：就是我们需要发送的消息

对于任何消息来说，只需要提供上述三个核心模块即可，我们无需去关心发送的细节。

直至 SpringCloud Stream 3.2.1 版本，它已经支持了几乎所有市面上流行的消息队列产品。`RabbitMQ、Kafka、RocketMQ、AWS SNS/SQS` 等等，主要是因为这种一统江湖的趋势让不同的消息中间件厂商都开发了自己的绑定器 `Binder` 提供给 SpringCloud Stream。

###  ###

初体验

下面以 RabbitMQ 为例体验一下 Stream 消息驱动开发。首先我们需要引入依赖

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>
    复制代码

接下来我们需要在配置文件中指定相关配置，在此之前请确保你对 RabbitMQ 中的组件有一个基本的认识，否则请先阅读

[format_png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/3f83bcaf9431442886a870044506c008.png
[format_png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/68eabf13af9b49e8bd7ed7a1b2fd159e.png