RocketMQ（04）——发送顺序消息

Posted 2022-12-12 elim168

发送顺序消息

如果你的业务上对消息的发送和消费顺序有较高的需求，那么在发送消息的时候你需要把它们放到同一个消息队列中，因为只有同一个队列的消息才能确保消费的顺序性。下面代码我们在发送消息的时候，调用的是需要传递MessageQueueSelector的send()，该方法还可以传递一个额外的参数，其对应MessageQueueSelector的select()的最后一个参数。下面代码中我们一共发送了10条消息，从1开始算顺序为奇数的都放到第一个队列中，顺序为偶数的都放第二个队列中。所以最终第一个队列放了顺序号为1/3/5/7/9的消息，第二个队列中放了顺序号为2/4/6/8/10的消息。

@Test
public void testOrderSend() throws Exception 
   
  DefaultMQProducer producer = new DefaultMQProducer