RocketMQ进阶-延时消息

在RocketMQ中，延时消息是指发送到队列中的消息，在一定时间后才能被消费者消费。RocketMQ提供了延时级别，允许你设置消息的延时时间。

以下是一个使用RocketMQ发送延时消息的Java代码示例：

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
 
public class DelayProducer {
    public static void main(String[] args) throws Exception {
        // 创建生产者，并指定组名
        DefaultMQProducer producer = new DefaultMQProducer("delay_producer_group");
        // 指定Namesrv地址
        producer.setNamesrvAddr("localhost:9876");
        // 启动生产者
        producer.start();
 
        // 创建消息，指定主题Topic、标签Tag和消息体
        Message message = new Message("TopicTest", "TagA", "Hello, RocketMQ".getBytes(RemotingHelper.DEFAULT_CHARSET));
        // 设置延时级别，例如3秒、5秒等
        message.setDelayTimeLevel(3);
 
        // 发送消息
        producer.send(message);
        // 关闭生产者
        producer.shutdown();
    }
}

在这个例子中，我们设置了消息的延时级别为3，这意味着消息将在发送后的3倍的延时时间（例如，3秒）后才能被消费者消费。你可以根据需要设置不同的延时级别，RocketMQ支持的级别从1秒（设置延时级别1）到2天（延时级别18）。

请确保RocketMQ的Nameserver地址是正确配置的，并且Topic是已经创建好的。如果没有创建，你可以使用RocketMQ控制台或者mqadmin工具来创建。