RocketMQ顺序消息如何增加吞吐量?

RocketMQ顺序消息（Ordered Message）保证消息严格按照顺序消费，但顺序消费天然会限制消息吞吐量。

如果需要提高吞吐量，可以从以下几个维度进行优化。

增加队列数（合理划分队列粒度）

顺序消息在RocketMQ中是基于单个Queue顺序消费的，队列越多，并发消费能力就越强。

实践：

将消息按照顺序要求的业务主键进行分片（如订单号、用户ID），同一个分片的消息投递到同一个队列中。

不同分片的消息可以并行消费，从而提高整体吞吐量。

例如：

1
2
// 根据订单号取模，确定投递的队列
int queueNum = orderId % queueCount;

常见实践技巧

提高队列数量（最常见）

调整Topic的队列数量，例如从4个队列调整到8或16个。

根据消息的业务标识分配到不同的Queue。

单队列保证单分片顺序，多队列并行提高吞吐。

1
2
3
4
5
/ 消息发送示例（自定义消息队列选择器）
SendResult sendResult = producer.send(msg, (mqs, msg, arg) -> {
    int index = (arg.hashCode()) % mqs.size();
    return mqs.get(index);
}, orderId);

降低单条消息的业务处理时长

顺序消息的消费速度受限于单个消息的消费速度，因此：

  • 减少顺序消息处理过程中的耗时操作，快速提交消费结果。
  • 异步处理耗时逻辑，顺序消费只负责确认顺序并快速落盘或提交。

例如：

1
2
3
4
5
6
7
8
// 快速消费，异步提交耗时任务
consumer.registerMessageListener((msgs, context) -> {
    // 同步轻量级逻辑，快速返回
    quicklySaveToDB(msgs);
    // 异步线程池处理复杂任务
    asyncExecutor.execute(() -> handleComplexTask(msgs));
    return ConsumeOrderlyStatus.SUCCESS;
});

增加消费者线程数

虽然单个队列是严格串行消费，但多个Queue之间可并发消费，增加消费端线程数或消费者实例数量，提升整体吞吐。

  • 增加消费者实例数量，提升并发处理能力。
  • 合理规划Queue数量，队列数一般建议 >= 消费者实例数。

例如：

1
2
3
4
RocketMQ:
- Topic: 订单顺序消费
- Queue数量: 16 (建议适当增加Queue数)
- 消费者实例数: >= Queue数

推荐的最佳实践组合方案：

发送端： 按照业务逻辑（如订单号）分片，多Queue投递。

消费端：

  • 适度增加消费者线程数量。
  • 增加消费者节点（水平扩容），提高并发能力。
  • 快速消费，耗时操作异步化。

注意事项：

队列越多并行越高，但维护成本也会上升，需要结合具体业务场景平衡。

顺序消息消费端严禁长时间阻塞或耗时较长的操作，否则即使增加队列也无法提高吞吐量。