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

Apache RocketMQ中 Normal Message（普通消息）的说明

news 2025/8/2 7:30:20

这段内容是关于 Apache RocketMQ 中 Normal Message（普通消息） 的说明。我们来用通俗、清晰的方式，帮你全面理解“普通消息”是什么、它适用于哪些场景、它的生命周期以及使用限制。

定义：
普通消息是 RocketMQ 中最基础、最常用的消息类型，没有特殊功能（如顺序、延迟、事务等），只保证“可靠地从生产者传送到消费者”。

📌 类比理解：

普通消息就像“平邮信件”：
- 能送到 → ✅ 可靠传输
- 什么时候到 → 不确定（无延迟控制）
- 是否按顺序到 → 不保证（除非特别配置）
- 内容是否成功处理 → 需要收件人回执（ACK机制）

✅ 它和以下“特殊消息”相对：

所以：如果你不需要顺序、延迟或事务功能，就用普通消息！

普通消息适用于大多数“异步解耦、数据传输、事件驱动”的场景。

订单系统 → 发送“订单创建”消息↓RocketMQ↓
库存系统 ← 订阅并扣减库存
积分系统 ← 订阅并增加积分
通知系统 ← 订阅并发送短信

📌 特点：

✔️ 典型应用：电商下单、用户注册、支付结果通知等。

前端 App → 产生日志 → 发送到 RocketMQ↓数据分析平台 ← 消费日志做分析日志存储系统 ← 消费日志存入数据库

📌 特点：

✔️ 典型应用：日志收集、数据同步、流式计算数据源。

一条普通消息在 RocketMQ 中会经历以下几个阶段：

阶段	说明
1. Initialized（初始化）	生产者创建消息，设置 Topic、Tag、Body、Keys 等属性，准备发送。
2. Ready（就绪）	消息被成功发送到 Broker，写入 CommitLog。此时消费者可以拉取该消息。
3. Inflight（飞行中）	消费者拉取了消息，正在处理。Broker 会等待消费者返回“消费结果”（ACK）。 ⚠️ 如果超时未返回 ACK，Broker 会自动重试（默认最多重试 16 次）。
4. Acked（已确认）	消费者处理成功，返回 `CONSUME_SUCCESS`，Broker 标记该消息为“已消费”。 ❗注意：消息不会立即删除，只是逻辑标记。
5. Deleted（已删除）	消息保存达到保留时间（默认 72 小时）或磁盘空间不足时，Broker 会从物理文件中删除最老的消息。

📌 关键点：

普通消息只能发送到 MessageType 为 Normal 的 Topic。

📌 解释：

RocketMQ 中的 Topic 有不同类型，比如：
- Normal：普通消息
- FIFO：顺序消息
- Delay：延迟消息
- Transaction：事务消息
你不能把普通消息发到一个声明为 FIFO 的 Topic 上，否则会报错。

✅ 正确做法：

📌 示例（控制台或命令行）：

# 创建一个普通 Topic
mqadmin updateTopic -n localhost:9876 -t OrderTopic -c DefaultCluster --type Normal

然后你的生产者就可以发送普通消息了：

Message msg = new Message("OrderTopic", "CREATE", "订单内容".getBytes());
SendResult result = producer.send(msg);

普通消息是 RocketMQ 的“基础款”消息，它不保证顺序、不支持延迟、不参与事务，但胜在简单、高效、可靠，适用于绝大多数异步通信和数据传输场景。

建议	说明
✅ 优先使用普通消息	大多数场景不需要复杂功能，简单即稳定
✅ 合理设置 Tag	用 Tag 做一级分类（如 `CREATE`, `PAY`, `CANCEL`），便于过滤
✅ 设置 Keys（可选）	为重要消息设置唯一 Key（如订单ID），便于通过控制台查询
✅ 处理消费失败	在 `MessageListener` 中捕获异常，返回 `RECONSUME_LATER` 触发重试
✅ 监控消费延迟	使用 `mqadmin consumerProgress` 查看消费堆积情况
✅ 避免大消息	单条消息建议 < 100KB，太大影响性能