五张图带你理解 RocketMQ 顺序消息实现机制

大家好，我是君哥。今天聊一聊 RocketMQ 的顺序消息实现机制。

在有些场景下，使用 MQ 需要保证消息的顺序性，比如在电商系统中，用户提交订单、支付订单、订单出库这 3 个消息应该保证顺序性，如下图：

对于 RocketMQ 来说，主要是通过 Producer 和 Consumer 来保证消息顺序的。

1、Producer

下面代码是 Producer 发送顺序消息的官方示例：

public static void main(String[] args) throws UnsupportedEncodingException {

try {

DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");

producer.start();

String[] tags = new String[] {"TagA", "TagB", "TagC", "TagD", "TagE"};

for (int i = 0; i