RocketMQ（10）——发送延时消息

Posted 2022-12-02 elim168

发送延时消息

正常发送的非事务消息只要到达了Broker就会写入消息队列，消费者就可以进行消费了。RocketMQ支持我们发送延时消费的消息，即现在发送的消息先发送到Broker，但是需要过一会才能进行消费。如果需要发送延时消息，只需要通过Message的setDelayDelevel()指定一个消息的延时等级即可。RocketMQ内部定义了18个等级，分别是1s、5s、10s、30s、1m、2m、3m、4m、5m、6m、7m、8m、9m、10m、20m、30m、1h、2h，分别对应于1-18，所以如果一条消息需要延时1分钟，需要指定delayLevel为5，延时10分钟，则指定delayLevel为14。下面的代码中一共发送了10条延时消息，分别应用了1-10共10个delayLevel。

@Test
public void testScheduledMessageSend() throws Exception 
   
  DefaultMQProducer produce