RocketMQ源码分析：延迟消息

这一节我们来看下RocketMQ的延迟消息

1.发送延迟消息 public class Producer { public static void main(String[] args) throws Exception { // 实例化一个生产者来产生延时消息 DefaultMQProducer producer = new DefaultMQProducer("DELAY_P_G"); producer.setNamesrvAddr("127.0.0.1:9876"); // 启动生产者 producer.start(); for (int i = 0; i < 1; i++) { Message message = new Message(MQConstant.DELAY_TOPIC, ("Hello scheduled message " + i).getBytes()); /** * MessageStoreConfig * messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h"; * * 共18个等级，依次是从1-18 * 比如，level=3, 表示延迟10s 消费 */ message.setDelayTimeLevel(4); // 发送消息 SendResult send = producer.send(message); System.out.println("send = " + send); } // 关闭生产者 producer.shutdown(); } } 1.发送延迟消息 public class Produc