RocketMQ 核心知识：架构、消息类型、使用场景、高可用、避坑

1 RocketMQ 是什么

阿里开源分布式消息队列，高吞吐、高可用、可堆积、适合金融 / 电商 / 微服务。

2 核心架构

• NameServer：注册中心，管理 Broker 路由
• Broker：存储消息、提供读写
• Producer：生产者
• Consumer：消费者（推 / 拉）
• Topic：消息主题
• Queue：消息分片（负载均衡）

3 消息类型

1. 普通消息
2. 顺序消息（全局 / 分区有序）
3. 延时消息
4. 事务消息（最终一致性神器）
5. 批量消息

4 核心特性

• 消息重试
• 死信队列 DeadLetter
• 消息轨迹
• 消息过滤（TAG/SQL）
• 削峰填谷、异步解耦、流量控制

5 使用场景

• 订单创建 → 异步通知
• 支付成功 → 积分 / 优惠券
• 日志收集
• 缓存同步
• 分布式事务最终一致性

6 高可用机制

• Broker 主从架构
• 同步双写 / 异步复制
• NameServer 集群
• 消费者负载均衡

7 生产最佳实践

• 消息必须幂等（消费不重复）
• 禁止超大消息（<4MB）
• 合理设置重试次数
• 死信单独监控
• 发送方用同步发送保证可靠
• 消费者不要抛异常，要捕获处理

Rocket MQ| ProcessOn免费在线作图,在线流程图,在线思维导图