MQ四兄弟：如何实现延时消息

news2024/11/13 12:32:25

RabbitMQ延时消息

RabbitMQ 本身并没有直接支持延时消息的功能，但是可以通过使用 RabbitMQ 插件或构建消息死信队列（Dead Letter Exchange, DLX）的方式来实现延时消息。以下是两种实现延时消息的方法：

1、死信队列 (Dead-Letter Queue):

当消息被拒绝接收，或者在队列中的存活时间超过了设置的TTL（Time-To-Live），或者队列达到最大长度时，消息会变成死信。
死信会被重新发布到另一个交换机上，这个交换机就是DLX（Dead-Letter Exchange）。
在声明业务队列时，可以添加一个x-dead-letter-exchange参数，值为死信交换机，这样死信就会被RabbitMQ重新发布到配置的这个交换机上.

2、延时插件 (Delayed Message Plugin):

需要先安装 RabbitMQ Delayed Message 插件

wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v3.8.0/rabbitmq_delayed_message_exchange-3.8.0.ez
mv rabbitmq_delayed_message_exchange-3.8.0.ez /usr/lib/rabbitmq/lib/rabbitmq_server-<version>/plugins/
rabbitmq-plugins enable rabbitmq_delayed_message_exchange

声明一个类型为x-delayed-message的交换机，并添加一个x-delayed-type参数，值为交换机的类型，用于路由键的映射。
这种方式允许消息在交换机中延迟一定时间，然后再根据路由键发送到相应的队列.

RocketMQ延时消息

RocketMQ把持实现延时消息相对简单，因为它内置了对延时消息的支持。RocketMQ 通过设置消息的定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。

比如，在分布式定时调度场景下，需要实现各类精度的定时任务，例如每天5点执行文件清理，每隔2分钟触发一次消息推送等需求。

以下是实现延时消息的详细步骤：

1、Producer发送延时消息

RocketMQ 通过设置消息的 delayTimeLevel 属性来实现延时投递。

在 Producer 端，通过设置消息的 delayTimeLevel 属性来发送延时消息。RocketMQ 内置了一组延迟级别，可以通过 delayTimeLevel 来指定延迟时间。


// 创建消息
Message message = new Message("TopicTest", "TagA", "delayed message".getBytes());

// 设置延时级别
message.setDelayTimeLevel(3);  // 延时级别 3，对应于延时 10 秒

2、延时级别对照表

RocketMQ 预定义了多个延时级别，每个级别对应不同的延时时间。以下是默认的延时级别对照表：

可以根据需要选择合适的延时级别，并设置到 message.setDelayTimeLevel(level) 方法中。

3、Consumer 接收消息

在 Consumer 端，接收和处理延时消息与普通消息相同。

4、调整配置

如果默认的延时级别不满足需求，可以通过修改 RocketMQ 配置文件 broker.conf 来调整延时级别和对应的延时时间：

messageDelayLevel = 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

修改完配置文件后，重启 Broker 生效。

小结

可以看到RocketMQ 5.x已经更新了延时消息的实现，在官方文档可以看到已经改成定时、延时消息，原本4.x文档中的延时级别对照表已经去掉了，统一成时间戳的实现。

RocketMQ 5.x 版本对延时消息的实现进行了重大更新。与之前版本相比，5.x 版本可以更灵活地处理消息的延迟时间，允许用户指定准确的延迟时间而不仅仅是预设的延迟级别。

下面来具体看看，实时/延时消息概念：

定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。

定时消息：例如，当前系统时间为2022-06-09 17:30:00，您希望消息在下午19:20:00定时投递，则定时时间为2022-06-09 19:20:00，转换成时间戳格式为1654773600000。
延时消息：例如，当前系统时间为2022-06-09 17:30:00，您希望延时1个小时后投递消息，则您需要根据当前时间和延时时长换算成定时时刻，即消息投递时间为2022-06-09 18:30:00，转换为时间戳格式为1654770600000。