RocketMQ 延时消息

RocketMQ 延时消息可以在指定时间后消费。本节将学习 RocketMQ 延时消息。

本节将学习：延时消息概念、延时消息实现、延时级别，以及使用场景。

延时消息概念

定义

延时消息： 消息在指定时间后才会被消费。

应用场景

延时消息应用场景：

• 定时任务
• 订单超时
• 延时通知

延时消息实现

实现方式

@Autowired
private RocketMQTemplate rocketMQTemplate;

public void sendDelayedMessage(String topic, String message, int delayLevel) {
    Message<String> msg = MessageBuilder.withPayload(message).build();
    msg.setDelayTimeLevel(delayLevel);
    rocketMQTemplate.syncSend(topic, msg);
}

延时级别

级别说明

延时级别：

• 18 个固定级别
• 1s、5s、10s、30s、1m、2m、3m、4m、5m、6m、7m、8m、9m、10m、20m、30m、1h、2h

使用场景

适用场景

延时消息使用场景：

• 订单超时取消
• 延时通知
• 定时任务

官方资源

• RocketMQ 延时消息：https://rocketmq.apache.org/docs/delay-example/

本节小结

在本节中，我们学习了：

第一个是延时消息概念。 延时消息的定义和应用场景。

第二个是延时消息实现。 如何实现延时消息。

第三个是延时级别。 RocketMQ 的延时级别。

第四个是使用场景。 延时消息的适用场景。

这就是 RocketMQ 延时消息。使用延时消息，可以实现定时任务和延时通知。

在下一节，我们将学习 Dubbo RPC 框架。