如何实现延迟队列

柔光的暖阳◎ 2022-12-28 08:09 137阅读 0赞

## 业务背景 ##

在平时的业务中我们可能会碰到这样的需求，用户A将任务分配给用户B，如果30天后用户B还没有处理这个任务，那么系统自动将这个任务转发给用户C，或者将任务退回给任务A。

这里我们就可以使用延迟队列，我们写好转发方法或者退回方法，用户A分配任务时将时间记录放入延迟队列。当30天后用户B没有处理，我们获取从延迟队列里面获取这个记录，能获取得到，就执行转发方法或退回方法。如果30天内用户B处理了任务，那么就将延迟队列对应的时间记录删掉。

![图片][f30b01c33589e51a1848741acbf18e1e.png]

任务转办

当然延迟队列还有很多使用场景，比如用户下单30分钟还没付款，就将订单关闭、外卖平台发送订餐通知，下单成功后60s给用户推送短信等。

## Redis实现的延迟队列 ##

我们可以使用Redis的`zset`可以用于作延迟队列，`score`为延迟的时间点，获取时顺序获取端口的值，如果当前时间戳等于`score`则可取出。

![图片][24496fc98f05ec4b81f8d38d5b0bbfd8.png]

至于如何使用Redis做延迟队列，有兴趣的童鞋可以看看我之前下的这篇文章：

> “
> 
> \[Redis实现延迟队列\]([Redis实现延迟队列 (qq.com)][Redis_ _qq.com])
> 
> ”

## Java自带的延迟队列 ##

当然使用Redis做延迟队列并投入生产，其设计还是很复杂的，这里我推荐JDK中的延迟队列API，在`java.util.concurrent`包下`DelayQueue`。

我们来看看它的使用。

![图片][a5823d8112e2d520281348060dcfe8f2.png]

首先我们直接创建一个延迟队列：

// 延迟消息队列
    private static DelayQueue delayQueue = new DelayQueue();

系统启动后，我们先后添加两个消息：

public static void producer() {
        // 添加消息
        delayQueue.put(new MyDelay(1000, "消息1"));
        delayQueue.put(new MyDelay(3000, "消息2"));
    }

我们再来从延迟队列中获取数据：

public static void consumer() throws InterruptedException {
        System.out.println("开始执行时间：" +
                DateFormat.getDateTimeInstance().format(new Date()));
        while (!delayQueue.isEmpty()) {
            System.out.println(delayQueue.take());
        }
        System.out.println("结束执行时间：" +
                DateFormat.getDateTimeInstance().format(new Date()));
    }

测试结果为：

开始执行时间：2020-12-5 13:50:34
    消息1
    消息2
    结束执行时间：2020-12-5 13:50:37

我们看到，消息2在延迟了3s后才从队列中被取出。

关于`DelayQueue`实际是基于优先队列来实现的。所谓的优先队列，出队是按照优先级来出的，并不是像传统的队列那样先进先出。优先队列底层是二叉堆，关于什么是二叉堆，有兴趣的童鞋可以去网上了解下。

下面是优先队列的示例代码：

![20201215170842245.gif][]

实体`Student`的值：

@AllArgsConstructor
    @Data
    public class Student {
        private Integer score;
        private String name;
        ...
    }

这里我们按照`score`值从大到小出队。

代码执行结果：

Name：Zhouzhou Level：100
    Name：Lvshen Level：80
    Name：Hall Level：60

## 关于其它的方式实现延迟队列 ##

我在网上收集了几种延迟队列的实现方式：

> “
> 
>  *  定期轮询（数据库等）
>  *  DelayQueue（JDK的API）
>  *  Timer
>  *  ScheduledExecutorService
>  *  时间轮(kafka)
>  *  RabbitMQ
>  *  Quartz
>  *  Redis Zset
>  *  Koala
>  *  JCronTab
>  *  SchedulerX（阿里）
>  *  有赞延迟队列
> 
> ”

具体实现方式可以看看这篇文章：

> “
> 
> 你真的了解延时队列吗
> 
> ”

好啦今天的文章就到这里啦！如果你的项目中有需要使用延迟队列的地方，希望这篇文章能帮助你。

# **往期推荐** #

*  [我写出这样干净的代码，老板直夸我][Link 1]
 *  [云南丽江旅游攻略][Link 2]
 *  [使用ThreadLocal怕内存泄漏？][ThreadLocal]
 *  [Java进阶之路思维导图][Java]
 *  [程序员必看书籍推荐][Link 3]
 *  [3万字的Java后端面试总结（附PDF）][3_Java_PDF]

扫码二维码，获取更多精彩。或微信搜**Lvshen\_9**，可后台回复获取资料

> 1.  `回复"java" 获取java电子书；`
> 2.  `回复"python"获取python电子书；`
> 3.  `回复"算法"获取算法电子书；`
> 4.  `回复"大数据"获取大数据电子书；`
> 5.  `回复"spring"获取SpringBoot的学习视频。`
> 6.  `回复"面试"获取一线大厂面试资料`
> 7.  `回复"进阶之路"获取Java进阶之路的思维导图`
> 8.  `回复"手册"获取阿里巴巴Java开发手册(嵩山终极版)`
> 9.  `回复"总结"获取Java后端面试经验总结PDF版`
> 10. `回复"Redis"获取Redis命令手册，和Redis专项面试习题（PDF）`
> 11. `回复"并发导图"获取Java并发编程思维导图（xmind终极版）`

另：点击【**我的福利**】有更多惊喜哦。

![format_png][]

[f30b01c33589e51a1848741acbf18e1e.png]: /images/20221120/7f71e38317b746239362fd8795c3a3b6.png
[24496fc98f05ec4b81f8d38d5b0bbfd8.png]: /images/20221120/317296a20d6d42b5b9f49def67c8990a.png
[Redis_ _qq.com]: https://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247483690&idx=3&sn=9614ff5d7fe7b31f3e7b136566ffad61&chksm=cfb8af16f8cf2600663f8993a11896aea9be3e75c866e3b7fbd24ac9fd4c98f3860a45965ec4&token=933129267&lang=zh_CN&scene=21#wechat_redirect
[a5823d8112e2d520281348060dcfe8f2.png]: /images/20221120/5b11bf47f250460c95401257499de6bc.png
[20201215170842245.gif]: /images/20221120/89a18fc39949497b945fef99268833da.png
[Link 1]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247487966&idx=1&sn=7810bd4f62f2b92bec831db2e1f35b97&chksm=cfb8bfe2f8cf36f4295a3560fc8fde094bf73e8e187ff589c6559ae7ed38584d8c67c1c20330&scene=21#wechat_redirect
[Link 2]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247487391&idx=1&sn=5847806bce7a105d6503eab52ea725be&chksm=cfb8a1a3f8cf28b517b36ded4dc1ec97334b0a685e5deb6f75d9a668c96d3fbc0c058e5432d8&scene=21#wechat_redirect
[ThreadLocal]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247486830&idx=1&sn=3aa8095371b2e04dc0c954443a890ef4&chksm=cfb8a352f8cf2a444a4c54d19a5e74b03879c03e79209a1f7688fd9edd81edb35b43fea9578d&scene=21#wechat_redirect
[Java]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247486701&idx=2&sn=8b6c8da8802d4fceb4ad06c229af5391&chksm=cfb8a2d1f8cf2bc71415098ecc807dfcb6bcfdde399ec92f79ead84f0f4352a5fdb7cf766593&scene=21#wechat_redirect
[Link 3]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247486232&idx=1&sn=ac1ba6a9f543f7115098f820a7b41165&chksm=cfb8a524f8cf2c326861c7a0783a6ada2ba7a3e76c633cb9632af99f32de64a984fef5ba8a75&scene=21#wechat_redirect
[3_Java_PDF]: http://mp.weixin.qq.com/s?__biz=Mzg4NDMyNTIwMw==&mid=2247488123&idx=1&sn=9567232df10afbfede9688e4762c988c&chksm=cfb8bc47f8cf35512bced50381acb94713b51bb8691e895ba880a2b7863d7c882f4b54aec190&scene=21#wechat_redirect
[format_png]: /images/20221120/896a7c0bbae04672a1885b783fdbb56f.png