Redisson延迟队列是怎么搞的?

昨天,记录了Spring Boot基于Redisson实现订单状态延迟处理的思路后,就想着,还是要去搞清楚RedissonDelayedQueue的实现思路,所以,今天就忙里偷闲,去Github下载Redisson源码来大概查略一番 。
如何创建RedissonDelayedQueue队列
在Test中,可以看到这样一段代码
RBlockingQueue<Integer> queue1 = redisson 。getBlockingQueue(“test”); //按名称获取一个阻塞队列实例
【Redisson延迟队列是怎么搞的?】RDelayedQueue<Integer> dealyedQueue = redisson 。getDelayedQueue(queue1); //按名称获取一个延迟队列实例 。参数是`RQueue<V>`
在获取DelayedQueue队列时,会初始化两个队列名称redisson_delay_queue_{队列名}和redisson_delay_queue_timeout_{队列名},还会创建一个QueueTransferTask队列中转的定时任务,

    推荐阅读