当前位置：首页 > news >正文

Spring Cloud Alibaba + RocketMQ

news 2026/6/19 3:30:20

RocketMQ

在微服务的世界里，服务间的消息就像快递包裹，如果没有高效可靠的传递方式，小摊位之间的信息就容易丢失或者延迟。这时候，你就需要 RocketMQ——微服务界的“快递小能手”，帮你高效、安全、准时地传递每一个消息。

本文将带你全面了解 RocketMQ，从原理、配置到实战经验，让你快速上手。

1. RocketMQ 是什么？

RocketMQ 是阿里巴巴开源的分布式消息中间件，核心特点包括：

功能	类比小故事	作用
高吞吐量	快递小哥跑得快	能处理大量消息，保证性能
高可靠性	包裹安全送达	消息不丢失，支持事务消息
顺序消费	包裹按顺序送	消息顺序消费保证业务一致性
延时/定时消息	预约送货	支持延时和定时发送
消息追踪	包裹跟踪系统	可查看消息的发送、消费情况

简单说，RocketMQ 就是微服务系统里的 “快递小能手+物流管理系统”，保证每条消息都能安全送达、按时消费。

2. RocketMQ 与 Spring Cloud Alibaba 的集成

Spring Cloud Alibaba 提供了对 RocketMQ 的原生支持：

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-rocketmq</artifactId>
</dependency>

比喻：就像给微服务安装了快递系统客户端，轻松发送和接收消息。

3. RocketMQ 核心概念

Producer（生产者）
- 负责发送消息，就像寄快递的小摊位。
Consumer（消费者）
- 负责接收消息，就像收快递的摊位。
Topic（主题）
- 消息的类别，就像不同的快递柜号。
Tag（标签）
- 消息子分类，用于筛选消费。
Message Queue（消息队列）
- 消息的存放位置，每个 Topic 可以有多个队列，支持并行消费。

4. RocketMQ 实战示例

4.1 生产者发送消息

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
public class ProducerController {private final RocketMQTemplate rocketMQTemplate;public ProducerController(RocketMQTemplate rocketMQTemplate) {this.rocketMQTemplate = rocketMQTemplate;}@GetMapping("/send")public String send(String message) {rocketMQTemplate.convertAndSend("demo-topic:tag1", message);return "消息发送成功：" + message;}
}

就像小摊位把包裹交给快递小哥，并指定快递柜号（Topic）和标签（Tag）。

4.2 消费者接收消息

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;@Component
@RocketMQMessageListener(topic = "demo-topic", consumerGroup = "demo-group")
public class DemoConsumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {System.out.println("收到消息: " + message);}
}