延时任务实现方案

在购买火车票或订外卖时，完成订单后通常会进入支付页面，该页面设有倒计时，要求在规定时间内完成支付，否则订单将自动取消。这是一个典型的延时任务业务场景。关键在于如何在订单超时时立即触发取消订单的操作。

那么，如何实现这种延时任务呢？通常有以下四种方案：

1. 定时任务轮询数据库（DB）

   用户下单后，数据库中会生成一条订单记录，包括订单号、用户ID、创建时间、订单详情和订单状态等信息。假设超时时间为600秒，我们可以启动一个定时任务，每隔固定时间运行一次，每次扫描数据库中的超时订单，并执行取消操作。

   select * from order where createTime < now() - interval '600 seconds'

   登录后复制

   这种方法实现简单，但存在许多缺点。超时时间通常是秒级的，如果定时任务每秒运行一次，会对数据库资源造成巨大消耗，因此定时任务通常不会设置为秒级；然而，如果设置为分钟级，会牺牲即时性，例如，600秒的超时时间，可能在660秒后才取消订单。

2. DelayQueue（JDK的延迟队列）

   JDK的DelayQueue是一种无界阻塞队列，只有在延迟期满时才能从中获取元素。每次生成订单时，除了将订单记录到数据库外，还需要将订单ID等信息投递到延迟队列中。队列会根据超时时间进行排序，最先超时的订单排在队列头部。启动一个独立线程，不断从队列中取出元素并执行取消订单的操作。

   这种方法的最大缺点是超时信息未持久化，服务重启后，延迟队列中的元素不会被恢复。

3. Redis的ZSet

   在Redis中创建一个名为“delayOrders”的ZSet，每个成员（member）是订单ID，分数（score）是订单的超时时间戳。我们从ZSet中取出分数最小的元素（即最先超时的订单），判断其是否已超时。如果已超时，则将其从ZSet中删除并取消订单；如果未超时，则继续下一次循环。

4. RabbitMQ的TTL+DLX

   RabbitMQ可以设置消息的过期时间（TTL），当消息过期后，可以将其投递到队列上设置的死信交换器（DLX）上。然后，消息被投递到死信队列中，重新消费。

   

四种方案的对比如下：

来源：//xiangxianzui.github.io/2020/02/延时任务实现方案

以上就是延时任务实现方案的详细内容，更多请关注php中文网其它相关文章！