RocketMQ 是阿里巴巴开源的分布式消息中间件，用 Java 编写，为互联网业务消息场景量身定制。它既要有 Kafka 级的吞吐与堆积能力，又要提供业务方最关心的三大特性：严格顺序消息、原生事务消息、延迟消息。电商交易、订单、支付、削峰等场景里，这些特性往往比单纯的高吞吐更有价值。

1. 角色与整体架构

四个角色各司其职：

角色	职责
NameServer	轻量级注册中心，Broker 向其注册，Producer/Consumer 从中发现路由信息，无状态、节点间不通信
Broker	消息存储与转发的主体，分 Master 与 Slave
Producer	生产者，从 NameServer 拿路由后直连 Broker 发消息
Consumer	消费者，从 NameServer 拿路由后直连 Broker 拉消息