延迟队列调研

调研延迟队列的实现方案：

使用 RocketMQ 设置延迟时间级别延时投递的延时队列
使用 Redisson 提供的 DelayedQueue
使用 Redis 的过期监听 -- key过期事件的时效性问题(惰性清除、定时随机删除)
使用 RabbitMQ 的死信队列 --

死信队列的设计目的是为了存储没有被正常消费的消息，便于排查和重新投递。死信队列没有对投递时间做出保证，在第一条消息成为死信之前，后面的消息即使过期也不会投递为死信。

为了解决这个问题，Rabbit 官方推出了延迟投递插件 rabbitmq-delayed-message-exchange ，推荐使用官方插件来做延时消息

使用非持久化的时间轮

参考：https://mp.weixin.qq.com/s/dopgOC5zdvyoy5phjAlH3A

利用 Redis 的 sorted set + list + 轮询来自研延时队列

参考：https://tech.youzan.com/queuing_delay/

综合考虑决定：采用了Redisson实现延迟队列，Redisson命令都采用Lua表达式执行，保证原子性，线程安全。

第一个任务延迟的问题，Redisson方案理论上是没有延迟的，但是当消息数量增加，消费者消费缓慢这个情况下可能会导致延迟任务消费的延迟。

第二个丢消息的问题，Redisson方案很大程度上减轻了丢消息的可能性，因为所有的任务都是存在list和sorted set两种数据类型中，Redis有持久化机制，就算Redis宕机，也就可能会丢一点点数据。

第三个广播消费任务的问题，这个是不会出现的，因为每个客户端都是从同一个目标队列中获取任务的。

实现代码

RBlockingQueue<Object> blockingQueue = redissonClient.getBlockingQueue(delayQueueCode);RDelayedQueue<Object> delayQueue = redissonClient.getDelayedQueue(blockingQueue);delayQueue.offer(task, seconds, TimeUnit.SECONDS);Object task = blockingQueue.poll();

版本配套：https://blog.csdn.net/Mr_lqh325/article/details/132557086

Redisson延迟队列实现原理：

pgDelayQueue前面的前缀都是固定的，Redisson创建的时候会拼上前缀。

redisson_delay_queue_timeout:pgDelayQueue，sorted set数据类型，存放所有延迟任务，按照延迟任务的到期时间戳（提交任务时的时间戳 + 延迟时间）来排序的，所以列表的最前面的第一个元素就是整个延迟队列中最早要被执行的任务。
redisson_delay_queue:pgDelayQueue，list数据类型，也是存放所有的任务，主要用来复制数据和提供阻塞实现。
pgDelayQueue，list数据类型，被称为目标队列，这个里面存放的任务都是已经到了延迟时间的，可以被消费者获取的任务，RBlockingQueue的take方法和pull方法是从这个目标队列中获取到任务。
redisson_delay_queue_channel:pgDelayQueue，是一个channel，用来通知客户端开启一个延迟任务