RocketMQ顺序消息（全局顺序与分区顺序）的实现与对比
RocketMQ如何支持顺序消息？请解释全局顺序（Global Order）和分区顺序（Partition Order）的实现原理：消息队列选择器（MessageQueueSelector）的作用、顺序消息的异常处理（消息重试导致顺序错乱）、以及顺序消息的高可用机制。对比Kafka和Pulsar在顺序消息方面的支持情况。给出一个订单状态变更的顺序消息发送示例。
回答
屠龙少年
RocketMQ顺序消息实现：
1. 全局顺序 vs 分区顺序：
| 类型 | 原理 | 适用场景 | 性能 |
|---|---|---|---|
| 全局顺序 | 所有消息发往同一个Queue，只有一个Consume线程消费 | 银行转账流水 | 极低（单队列瓶颈） |
| 分区顺序 | 相同业务ID发往同一个Queue（hash取模），同Queue内严格顺序 | 订单状态变更 | 高（并行消费多队列） |
2. 分区顺序实现：
// Producer：同orderId发往同Queue
producer.send(msg, new MessageQueueSelector() {
@Override
public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
Long orderId = (Long) arg;
return mqs.get(orderId.intValue() % mqs.size()); // 按orderId固定队列
}
}, orderId);
// Consumer：队列级顺序消费（单线程消费每个队列）
consumer.registerMessageListener(new MessageListenerOrderly() {
@Override
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs,
ConsumeOrderlyContext context) {
for (MessageExt msg : msgs) {
processOrderEvent(msg); // 同一Queue串行处理
}
return ConsumeOrderlyStatus.SUCCESS;
}
});
3. 异常处理（消息重试）：
- 消费失败时，
MessageListenerOrderly自动暂停当前队列消费 - 等待重试（默认重试16次，间隔递增1s→2h）
- 重试期间队列暂停，保证后续消息不先于失败消息被消费
4. 与Kafka/Pulsar对比： | 特性 | RocketMQ | Kafka | Pulsar | |------|----------|-------|--------| | 顺序消息 | ✅ 原生（分区顺序+全局顺序）| ✅ 仅分区内 | ✅ 仅分区内 | | 失败暂停队列 | ✅ 支持 | ❌ 需自定义 | ❌ 需自定义 | | 批量顺序 | ✅ MessageListenerOrderly | ❌ 需单线程poll | ❌ 需单线程消费 | | 死信处理 | 自动进入%DLQ% | 需手动 | 需手动 |
5. 订单状态变更最佳实践：
# 消息结构：
order_id: 20250525123456
status: "CREATED" → "PAID" → "SHIPPED" → "DELIVERED"
# 同一个order_id必须串行处理（不能先处理SHIPPED再处理PAID）
# 使用分区顺序：order_id % QueueCount 路由到固定Queue