RocketMQ 是阿里开源的分布式消息中间件，基于 Java 开发，具备高吞吐、高可用、低延迟特性。核心架构包含 NameServer 路由中心、Broker 存储节点、Producer 生产者和 Consumer 消费者四大角色。支持普通、顺序、延时及事务消息，提供集群消费、广播消费模式及死信队列机制。相比 Kafka 更贴合企业级业务需求，相比 ActiveMQ 性能更优。典型应用场景包括异步通信、流量削峰、分布式事务及系统解耦。Java 客户端集成简单，通过 Maven 依赖即可快速接入，适合构建高可靠分布式系统。
RocketMQ 是阿里开源的分布式消息中间件，基于 Java 开发，主打高吞吐、高可用、低延迟、分布式架构，脱胎于阿里内部的 MetaQ，后捐赠给 Apache 基金会成为顶级项目，广泛用于电商、金融、物流等领域的异步通信、流量削峰、分布式事务等场景，是 Java 生态中主流的消息队列之一。
RocketMQ 采用分布式集群架构，核心由 4 个相互协作的角色组成，职责清晰、解耦性强，支撑海量消息的生产与消费，架构图核心逻辑如下：
生产者 (Producer) → 姓名服务器 (NameServer) → 代理服务器 (Broker) ← 消费者 (Consumer)
路由信息注册/发现 | 消息存储/转发
Master/Slave 数据同步
. 拉取 Broker 路由信息 . 发送消息（普通/顺序/事务等）
启动时注册/定时心跳
. 拉取 Broker 路由信息 . 拉取消息并消费
核心能力：
各角色核心职责：
轻量级的路由注册中心，无状态、可集群部署（节点间不通信，靠生产者 / 消费者主动拉取）；管理 Broker 节点的注册与发现：Broker 启动后向所有 NameServer 注册自身信息（地址、存储的 Topic 等），生产者 / 消费者通过 NameServer 获取最新的 Broker 路由信息，实现动态扩容；核心作用：解耦生产者 / 消费者与 Broker，避免硬编码 Broker 地址，提升集群灵活性。
RocketMQ 的核心节点，负责消息的存储、转发、持久化、高可用，是消息的实际载体；可分为 Master 节点（主节点，处理生产 / 消费请求、存储消息）和 Slave 节点（从节点，同步 Master 数据，做容灾备份，默认不处理写请求，可配置为读从节点）；支持多副本、多机房部署，通过同步 / 异步复制保证数据可靠性，是集群高可用的关键。
消息的发送方，基于 Java 等语言开发（原生支持 Java，提供多语言 SDK）；支持集群部署，通过 NameServer 获取 Broker 路由信息后，直接向 Broker 发送消息；提供多种发送模式：同步发送（重要消息，如订单创建）、异步发送（高吞吐场景，如日志采集）、单向发送（无需回执，如心跳包）。
消息的接收方，同样支持集群部署；通过 NameServer 获取 Broker 路由信息，从 Broker 拉取或推送消息（RocketMQ 主流为拉取模式，可根据消费能力动态调整拉取频率，避免消息堆积）；核心消费模式：集群消费（同一条消息仅被消费集群中一个节点处理，适合负载均衡）、广播消费（同一条消息被所有消费节点处理，适合配置同步）。
NameServer → 物流调度中心 职能：掌握所有仓库（Broker）的地址、库存品类（Topic）等信息，是生产者和消费者的'导航系统'。 举例：就像电商平台的调度中心，不存储商品，只记录每个仓库的位置和能发哪些品类的货。 协作逻辑：
Broker → 仓储配送中心 职能：消息的实际存储、转发和交付节点，是整个架构的核心载体。 举例：就像大型仓储配送中心，分为主仓（Master）和备用仓（Slave）。 协作逻辑：
Producer → 商家供应商 职能：产生消息并发送到 Broker，是消息的源头。 举例：就像给电商平台供货的商家，有货要卖时，先问调度中心（NameServer）哪个仓库能收这个品类的货，然后直接把商品送到指定仓库（Broker）。 协作逻辑：
Consumer → 买家用户 职能：从 Broker 拉取消息并消费，是消息的最终使用者。 举例：就像在电商平台下单的买家，先问调度中心（NameServer）哪个仓库有自己要的商品，然后直接去仓库取货。 协作逻辑：
从功能逻辑上，RocketMQ 将整体架构分为三层，每层职责明确，上层依赖下层，实现业务与底层、功能与存储的解耦，提升架构的扩展性和可维护性：
核心组件：Producer 生产者、Consumer 消费者； 核心职责：面向业务系统的消息接入与消费输出，屏蔽底层 RocketMQ 的路由细节和存储细节； 层能力：提供统一的消息发送 / 消费 API，支持多种消息类型（普通、顺序、延时、事务），处理业务侧的消息过滤、负载均衡。
核心组件：NameServer 路由中心、Broker 核心节点； 核心职责：RocketMQ 的核心处理层，负责路由管理、消息转发、高可用保障； 层能力：
核心载体：Broker 内置的消息存储模块（基于磁盘文件存储）； 核心职责：负责消息的持久化存储和快速读取，是 RocketMQ 数据可靠性的基础； 层能力：支持同步刷盘、异步刷盘两种持久化策略，基于高效的文件存储结构，实现海量消息的低延迟写入和读取，同时支持消息的过期删除、磁盘空间管理。
生产者先找路由中心查仓库地址→发消息到指定仓库→仓库持久化 + 主从备份→消费者找路由中心查仓库地址→从仓库拉取消息并消费→反馈消费结果，全程解耦生产者 / 消费者与仓库，无单点依赖。
按'启动准备→消息生产→消息存储→消息消费→异常处理'5 个核心阶段拆解，每个阶段明确角色动作和协作逻辑：
核心：生产者不直接连 Broker，先寻址再发送，支持 3 种发送模式
核心：Broker 是消息实际载体，完成持久化 + 主从同步，保证数据不丢
核心：消费者采用「拉取模式」（Pull），按需拉取消息，支持集群 / 广播消费
demo-topic:* 表示订阅所有标签），Broker 记录消费者所属的消费组信息；%DLQ%+ 消费组名），不再参与正常消费，避免阻塞整个消费队列；业务可单独监控死信队列，人工排查失败原因（如消息格式错误、依赖服务宕机）；1. 启动：NameServer→Broker（注册路由）→Producer/Consumer
2. 生产：Producer 查 NameServer 路由→发消息到 Broker 主节点→Broker 持久化 + 主从同步
3. 消费：Consumer 查 NameServer 路由→从 Broker 拉取消息→执行业务→反馈消费结果
4. 兜底：失败重试→死信队列→Broker 故障自动切换
作为 Java 原生开发的消息队列，对 Java 生态兼容性极佳，同时具备企业级核心能力：
| 特性 | RocketMQ | Kafka | ActiveMQ |
|---|---|---|---|
| 开发语言 | Java（原生适配 Java 生态） | Scala/Java | Java |
| 吞吐能力 | 高（百万级 TPS） | 极高（千万级 TPS） | 中（万级 TPS） |
| 延迟性能 | 低（毫秒级） | 极低（微秒级） | 中（毫秒～秒级） |
| 消息可靠性 | 高（持久化 + 多副本） | 高（持久化 + 多副本） | 中（易丢消息） |
| 功能丰富度 | 高（顺序、延时、事务） | 中（仅普通消息，需扩展） | 中（支持 JMS，功能一般） |
| 分布式事务 | 原生支持 | 不支持（需业务实现） | 支持（JMS 事务） |
| 运维复杂度 | 中（集群部署简单） | 高（依赖 ZooKeeper，调优复杂） | 低（入门简单） |
| 适用场景 | 企业级分布式系统（电商、金融）、异步通信、流量削峰、分布式事务 | 大数据日志采集、流处理、高吞吐低延迟的消息传输 | 小型系统、入门级开发、对性能要求不高的场景 |
核心结论：RocketMQ 是 Java 分布式系统的首选消息队列之一，兼顾了高吞吐、高可用、功能丰富性和运维便捷性，比 Kafka 功能更贴合企业业务需求，比 ActiveMQ 性能和可靠性更高。
<!-- RocketMQ 客户端核心依赖 -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.9.7</version>
<!-- 推荐稳定版本，与服务端一致 -->
</dependency>
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
public class RocketMQProducer {
public static void main(String[] args) throws Exception {
// 1. 创建生产者实例，指定「生产者组」（集群消费必须指定，标识同一组生产者）
DefaultMQProducer producer = new DefaultMQProducer("demo-producer-group");
// 2. 设置 NameServer 地址（多个地址用;分隔）
producer.setNamesrvAddr("127.0.0.1:9876");
// 3. 启动生产者
producer.start();
// 4. 发送消息（Topic：主题，Tag：标签（用于消息过滤），Body：消息体）
Message message = new Message("demo-topic", // 主题（需提前创建，或开启自动创建）
"demo-tag", // 标签
"Hello RocketMQ from Java!".getBytes() // 消息体（字节数组）);
// 同步发送，返回发送结果
producer.send(message);
System.out.println("消息发送成功");
// 5. 关闭生产者（实际项目中建议在服务关闭时执行）
producer.shutdown();
}
}
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;
import java.util.List;
public class RocketMQConsumer {
public static void main(String[] args) throws Exception {
// 1. 创建消费者实例，指定「消费者组」（集群消费的核心标识）
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("demo-consumer-group");
// 2. 设置 NameServer 地址
consumer.setNamesrvAddr("127.0.0.1:9876");
// 3. 订阅主题和标签（* 表示订阅所有标签，demo-tag||demo-tag2 表示订阅多个标签）
consumer.subscribe("demo-topic", "*");
// 4. 设置消息监听器，处理消费逻辑
consumer.registerMessageListener((MessageListenerConcurrently)(msgs, context) -> {
for (MessageExt msg : msgs) {
// 解析消息体
String content = new String(msg.getBody());
System.out.printf("消费消息：topic=%s, tag=%s, content=%s%n", msg.getTopic(), msg.getTags(), content);
}
// 返回消费状态：CONSUME_SUCCESS（成功）、RECONSUME_LATER（重试）
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
// 5. 启动消费者（消费者启动后持续监听，无需手动循环）
consumer.start();
System.out.println("消费者启动成功，开始监听消息");
}
}
补充：使用前需先部署 RocketMQ 服务端（NameServer + Broker），服务端部署简单，支持单机 / 集群模式，官方提供了完整的部署文档，适配 Linux/Windows 环境。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online