使用Redisson的RDelayedQueue来实现延迟队列的，Redisson是基于Redis的，所以只要有redis中间件就行了。
采用的是多线程来处理延迟队列的，在设计延迟任务时，我们应该根据实际需求来合理设置延迟时间，避免设置过长的延迟时间导致内存占用过高。
在电商、支付等领域，往往会有这样的场景，用户下单后放弃支付了，那这笔订单会在指定的时间段后进行关闭操作，细心的你一定发现了像某宝、某东都有这样的逻辑，而且时间很准确，误差在1s内。就可以用延迟队列来实现。
参考文章：https://blog.csdn.net/u011974797/article/details/138195387
2024-05-22 18:25:49
12KB
1
rabbitmq_delayed_message_exchange-3.8.0 延迟队列插件，放到rabbitmq 的目录， /plugins 是其插件目录中
2022-05-30 10:00:31
41KB
1
Redis流队列
Redis流v5 +上的消息队列。
redis v5 +流，ES6
__keyevent@5__:expired保证__keyevent@5__:expired消息（ __keyevent@5__:expired ）不丢失
采用ES6 +异步/等待+面向对象设计
达到易读懂，方便修改。
vscode上有专项预测开发的扩展插件：
安装
npm install redis-stream-queue
基本用法
const { RedisQueue } = require ( 'redis-stream-queue' )
const IORedis = require ( 'ioredis' )
const client = new IORedis ( opt )
const mq = RedisQueue . init ( { client } )
const sKey =
2022-04-21 19:01:23
19KB
1
本篇文章主要介绍了C#实现rabbitmq 延迟队列功能实例代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
2022-02-17 11:28:52
76KB
1
安装一个插件即可：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
rabbitmq_delayed_message_exchange插件主要是实现延迟队列
延迟队列，即消息发送之后，在一段时间之后延迟被消费端消费的消息队列。比如我们发送一条消息，希望在半个小时之后才可以被消费端消费到的这种场景中就可以用到延迟队列了。
2021-08-23 17:57:04
41KB
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