实战：十种实现延迟任务的方法，附代码！

好了，话不多说，直接进入今天的主题，本文的主要内容如下图所示：,顾名思议，我们把需要延迟执行的任务叫做延迟任务。,延迟任务的使用场景有以下这些：,等事件都需要使用延迟任务。,延迟任务实现的关键是在某个时间节点执行某个任务。基于这个信息我们可以想到实现延迟任务的手段有以下两个：,而通过 JDK 实现延迟任务我们能想到的关键词是：DelayQueue、ScheduledExecutorService，而第三方提供的延迟任务执行方法就有很多了，例如：Redis、Netty、MQ 等手段。,下面我们将结合代码来讲解每种延迟任务的具体实现。,此方式我们需要开启一个无限循环一直扫描任务，然后使用一个 Map 集合用来存储任务和延迟执行的时间，实现代码如下：,以上程序执行的结果为：,程序启动时间：2020-04-12T18:51:28.188,执行任务：task-1 ，执行时间：2020-04-12T18:51:31.189,可以看出任务延迟了 3s 钟执行了，符合我们的预期。,Java API 提供了两种实现延迟任务的方法：DelayQueue 和 ScheduledExecutorService。,我们可以使用 ScheduledExecutorService 来以固定的频率一直执行任务，实现代码如下：,以上程序执行的结果为：,程序启动时间：2020-04-12T21:28:10.416,执行任务 ，执行时间：2020-04-12T21:28:12.421,执行任务 ，执行时间：2020-04-12T21:28:14.422,……,可以看出使用 ScheduledExecutorService#scheduleWithFixedDelay(…) 方法之后，会以某个频率一直循环执行延迟任务。,DelayQueue 是一个支持延时获取元素的无界阻塞队列，队列中的元素必须实现 Delayed 接口，并重写 getDelay(TimeUnit) 和 compareTo(Delayed) 方法，DelayQueue 实现延迟队列的完整代码如下：,开始时间：2020-4-12 20:40:38,2020-4-12 20:40:39,2020-4-12 20:40:41,2020-4-12 20:40:43,结束时间：2020-4-12 20:40:43,使用 Redis 实现延迟任务的方法大体可分为两类：通过 zset 数据判断的方式，和通过键空间通知的方式。,我们借助 zset 数据类型，把延迟任务存储在此数据集合中，然后在开启一个无线循环查询当前时间的所有任务进行消费，实现代码如下(需要借助 Jedis 框架)：,默认情况下 Redis 服务器端是不开启键空间通知的，需要我们通过 config set notify-keyspace-events Ex 的命令手动开启，开启键空间通知后，我们就可以拿到每个键值过期的事件，我们利用这个机制实现了给每个人开启一个定时任务的功能，实现代码如下：,Netty 是由 JBOSS 提供的一个 Java 开源框架，它是一个基于 NIO 的客户、服务器端的编程框架，使用 Netty 可以确保你快速和简单的开发出一个网络应用，例如实现了某种协议的客户、服务端应用。Netty 相当于简化和流线化了网络应用的编程开发过程，例如：基于 TCP 和 UDP 的 socket 服务开发。,可以使用 Netty 提供的工具类 HashedWheelTimer 来实现延迟任务，实现代码如下。,首先在项目中添加 Netty 引用，配置如下：,Netty 实现的完整代码如下：,以上程序执行的结果为：,程序启动时间：2020-04-13T10:16:23.033,执行任务 ，执行时间：2020-04-13T10:16:26.118,HashedWheelTimer 是使用定时轮实现的，定时轮其实就是一种环型的数据结构，可以把它想象成一个时钟，分成了许多格子，每个格子代表一定的时间，在这个格子上用一个链表来保存要执行的超时任务，同时有一个指针一格一格的走，走到那个格子时就执行格子对应的延迟任务，如下图所示：,以上的图片可以理解为，时间轮大小为 8，某个时间转一格(例如 1s)，每格指向一个链表，保存着待执行的任务。,如果专门开启一个 MQ 中间件来执行延迟任务，就有点杀鸡用宰牛刀般的奢侈了，不过已经有了 MQ 环境的话，用它来实现延迟任务的话，还是可取的。,几乎所有的 MQ 中间件都可以实现延迟任务，在这里更准确的叫法应该叫延队列。本文就使用 RabbitMQ 为例，来看它是如何实现延迟任务的。,RabbitMQ 实现延迟队列的方式有两种：,注意：延迟插件 rabbitmq-delayed-message-exchange 是在 RabbitMQ 3.5.7 及以上的版本才支持的，依赖 Erlang/OPT 18.0 及以上运行环境。,由于使用死信交换器比较麻烦，所以推荐使用第二种实现方式 rabbitmq-delayed-message-exchange 插件的方式实现延迟队列的功能。,首先，我们需要下载并安装 rabbitmq-delayed-message-exchange 插件，下载地址：http://www.rabbitmq.com/community-plugins.html,选择相应的对应的版本进行下载，然后拷贝到 RabbitMQ 服务器目录，使用命令 rabbitmq-plugins enable rabbitmq_delayed_message_exchange 开启插件，在使用命令 rabbitmq-plugins list 查询安装的所有插件，安装成功如下图所示：,最后重启 RabbitMQ 服务，使插件生效。,首先，我们先要配置消息队列，实现代码如下：,然后添加增加消息的代码，具体实现如下：,再添加消费消息的代码：,最后，我们使用代码测试一下：,以上程序的执行结果如下：,发送时间：2020-04-13 20:47:51,接收时间:2020-04-13 20:47:54,消息内容：Hi Admin.,从结果可以看出，以上程序执行符合延迟任务的实现预期。,如果你使用的是 Spring 或 SpringBoot 的项目的话，可以使用借助 Scheduled 来实现，本文将使用 SpringBoot 项目来演示 Scheduled 的实现，实现我们需要声明开启 Scheduled，实现代码如下：,然后添加延迟任务，实现代码如下：,此时当我们启动项目之后就可以看到任务以延迟了 2s 的形式一直循环执行，结果如下：,任务执行，时间：2020-04-13T14:07:53.349,任务执行，时间：2020-04-13T14:07:55.350,任务执行，时间：2020-04-13T14:07:57.351,…,我们也可以使用 Corn 表达式来定义任务执行的频率，例如使用 @Scheduled(cron = “0/4 * * * * ?”) 。,Quartz 是一款功能强大的任务调度器，可以实现较为复杂的调度功能，它还支持分布式的任务调度。,我们使用 Quartz 来实现一个延迟任务，首先定义一个执行任务代码如下：,在定义一个 JobDetail 和 Trigger 实现代码如下：,最后在 SpringBoot 项目启动之后开启延迟任务，实现代码如下：,以上程序的执行结果如下：,从结果可以看出在项目启动 3s 之后执行了延迟任务。,本文讲了延迟任务的使用场景，以及延迟任务的 10 种实现方式：