安装一个插件即可：https://www.rabbitmq.com/community-plugins.html ，下载rabbitmq_delayed_message_exchange插件，然后解压放置到RabbitMQ的插件目录。
接下来，进入RabbitMQ的安装目录下的sbin目录，执行下面命令让该插件生效，然后重启RabbitMQ。
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
2021-10-31 00:47:41
41KB
1
DelayQueue、Redis结合使延迟、定时任务使用
DelayQueue、Redis结合使延迟、定时任务使用
DelayQueue、Redis结合使延迟、定时任务使用
源代码下载
2021-10-19 10:21:21
1.13MB
1
#### 整体结构
整个延迟队列由4个部分组成：
1. JobPool用来存放所有Job的元信息。
2. DelayBucket是一组以时间为维度的有序队列，用来存放所有需要延迟的Job（这里只存放Job Id）。
3. Timer负责实时扫描各个Bucket，并将delay时间大于等于当前时间的Job放入到对应的Ready Queue。
4. ReadyQueue存放处于Ready状态的Job（这里只存放JobId），以供消费程序消费。
2021-07-12 02:41:31
24KB
1
安装一个插件即可：https://www.rabbitmq.com/community-plugins.html ，下载rabbitmq_delayed_message_exchange插件，然后解压放置到RabbitMQ的插件目录。
接下来，进入RabbitMQ的安装目录下的sbin目录，执行下面命令让该插件生效，然后重启RabbitMQ。
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
2021-04-06 16:03:37
41KB