文章内容收录到个人网站,方便阅读:http://hardyfish.top/RocketMQ顺序消息(Ordered Message)保证消息严格按照顺序消费,但顺序消费天然会限制消息吞吐量。如果需要提高吞吐量,可以从以下几个维度进行优化:一、增加队列数(合理划分队列粒度)顺序消息在RocketMQ中是基于单个Queue顺序消费的,队列越多,并发消费能力就越强。实践: 将消息按照顺序要求的业务主键进行分片(如订单号、用户ID),同一个分片的消息投递到同一个队列中,不同分片的消息可以并行消费,从而提高整体吞吐量。例如: // 根据订单号取模,确定投递的队列 int queueNum = orde...