在购买火车票或订外卖时，完成订单后通常会进入支付页面，该页面设有倒计时，要求在规定时间内完成支付，否则订单将自动取消。这是一个典型的延时任务业务场景。关键在于如何在订单超时时立即触发取消订单的操作。
那么，如何实现这种延时任务呢？通常有以下四种方案：
定时任务轮询数据库（DB）
用户下单后，数据库中会生成一条订单记录，包括订单号、用户ID、创建时间、订单详情和订单状态等信息。假设超时时间为600秒，我们可以启动一个定时任务，每隔固定时间运行一次，每次扫描数据库中的超时订单，并执行取消操作。
select * from order where createTime < now() - interval '600 seconds'
这种方法实现简单，但存在许多缺点。超时时间通常是秒级的，如果定时任务每秒运行一次，会对数据库资源造成巨大消耗，因此定时任务通常不会设置为秒级；然而，如果设置为分钟级，会牺牲即时性，例如，600秒的超时时间，可能在660秒后才取消订单。
DelayQueue（JDK的延迟队列）
JDK的DelayQueue是一种无界阻塞队列，只有在延迟期满时才能从中获取元素。每次生成订单时，除了将订单记录到数据库外，还需要将订单ID等信息投递到延迟队列中。队列会根据超时时间进行排序，最先超时的订单排在队列头部。启动一个独立线程，不断从队列中取出元素并执行取消订单的操作。
这种方法的最大缺点是超时信息未持久化，服务重启后，延迟队列中的元素不会被恢复。
Redis的ZSet
ViiTor实时翻译
AI实时多语言翻译专家！强大的语音识别、AR翻译功能。
116 查看详情
在Redis中创建一个名为“delayOrders”的ZSet，每个成员（member）是订单ID，分数（score）是订单的超时时间戳。我们从ZSet中取出分数最小的元素（即最先超时的订单），判断其是否已超时。如果已超时，则将其从ZSet中删除并取消订单；如果未超时，则继续下一次循环。
RabbitMQ的TTL+DLX
RabbitMQ可以设置消息的过期时间（TTL），当消息过期后，可以将其投递到队列上设置的死信交换器（DLX）上。然后，消息被投递到死信队列中，重新消费。
四种方案的对比如下：
定时任务轮询DB实现简单，无技术难点，异常恢复，支持分布式/集群环境影响数据库性能，时效性差DelayQueue实现简单，性能较好无法异常恢复，分布式/集群实现困难Redis的ZSet解耦，异常恢复，扩展性强，支持分布式/集群环境增加Redis维护，占用带宽RabbitMQ的TTL+DLX解耦，异常恢复，扩展性强，支持分布式/集群环境增加RabbitMQ维护，占用带宽
来源：//xiangxianzui.github.io/2020/02/延时任务实现方案
以上就是延时任务实现方案的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/483197.html
微信扫一扫 
支付宝扫一扫 
