Apache RocketMQ

定义

Apache RocketMQ 是阿里巴巴自研并捐赠给 Apache 基金会的分布式消息中间件,2017 年毕业为顶级项目,前身与阿里内部的 MetaQ、Notify 一脉相承,长期支撑双十一大促的交易链路。

架构

RocketMQ 由 NameServer(轻量注册中心)、Broker(存储与投递)、Producer 和 Consumer 组成。消息统一写入 CommitLog 顺序文件,再通过 ConsumeQueue 索引分发,兼顾写入吞吐与消费效率。

核心特性

• 事务消息:通过半消息加回查机制实现本地事务与消息发送的最终一致;
• 顺序消息:同一分区队列内严格有序;
• 延迟消息、消息轨迹、死信队列、消费重试等企业级能力完善。

应用

RocketMQ 在国内电商、金融、物流系统中应用广泛,阿里云上的商业化版本为消息队列 RocketMQ 版。5.x 版本引入存算分离与无状态 Proxy,向云原生方向演进。