共计 2191 个字符，预计需要花费 6 分钟才能阅读完成。
在咱们日常生活中，咱们能够发现：在淘宝、京东等购物平台高低单，超过肯定工夫未付款，订单会主动勾销。打车的时候，在规定工夫没有车主接单，平台会勾销你的单并揭示你临时没有车主接单。点外卖的时候，如果商家在 10 分钟还没接单，就会主动勾销订单。收快递的时候，如果咱们没有点确认收货，在一段时间后程序会主动实现订单。在平台实现订单后，如果咱们没有在规定工夫评论商品，会主动默认买家不评论。……. 这时，咱们能够想想为什么要这样做？因为这样能够保障商品的库存能够开释给其他人购买，你能够不必始终期待打车却得不到回复，你能够及时换一家店点到外卖。那么这些状况都是如何实现的呢？这时咱们能够看看这个图，来看看音讯提早是如何解决的：
当用户发送一个音讯申请给服务器后盾的时候，服务器会检测这条音讯是否须要进行延时解决，如果须要就放入到延时队列中，由延时工作检测器进行检测和解决，对于不须要进行延时解决的工作，服务器会立马对音讯进行解决，并把解决后的后果返会给用户。
对于在延时工作检测器外部的话，有查问提早工作和执行延时工作两个职能，工作检测器会先去延时工作队列进行队列中信息读取，判断以后队列中哪些工作曾经工夫到期并将曾经到期的工作输入执行（设置一个定时工作）。这时，咱们能够想一想在 Redis 的数据结构中有哪些能进行工夫设置标记的命令？是不是想到的 zset 这个命令，具备去重有序（分数排序）的性能。没错，你想对了呀！咱们能够应用 zset（sortedset）这个命令，用设置好的工夫戳作为 score 进行排序，应用 zadd score1 value1 …. 命令就能够始终往内存中生产音讯。再利用 zrangebysocre 查问符合条件的所有待处理的工作，通过循环执行队列工作即可。也能够通过 zrangebyscore key min max withscores limit 0 1 查问最早的一条工作，来进行生产。
总的来说，你能够通过以下两种形式来实现（(^▽^) 如果你想到其余办法，也能够通知我下呀~）：应用 zrangebyscore 来查问以后延时队列中所有工作，找出所有须要进行解决的延时工作，在顺次进行操作。查找以后最早的一条工作，通过 score 值来判断工作执行的时候是否大于了以后零碎的时候，比如说：最早的工作执行工夫在 3 点，零碎工夫在 2 点 58 分），示意这个应该须要立马被执行啦，工夫快到了（冲冲冲，他来了他来了，他带着死神的步调来了）。咱们能够想一想 Redis 来实现延时队列有何劣势呢？其实，Redis 用来进行实现延时队列是具备这些劣势的：Redis zset 反对高性能的 score 排序。Redis 是在内存上进行操作的，速度十分快。Redis 能够搭建集群，当音讯很多时候，咱们能够用集群来进步音讯解决的速度，进步可用性。Redis 具备长久化机制，当呈现故障的时候，能够通过 AOF 和 RDB 形式来对数据进行复原，保障了数据的可靠性这时候，会有小伙伴问了还有没有其余实现延时队列的形式呀！emmm…. 当然有的，只有想不到的没有做不到。搜寻 Java 知音，回复“后端面试”，送你一份面试宝典.pdf 办法一：在 MQ 中咱们能够对 Queue 设置 x-expires 过期工夫或者对 Message 设置超时工夫 x -message-ttl。（这里要留神下：延时雷同的音讯咱们要扔到同一个队列中，对于每一个延时要建设一个与之对应的队列—这是因为 MQ 的过期检测是惰性检测的。）办法二：咱们能够用 RabbitMQ 的插件 rabbitmq-delayed-message-exchange 插件来实现延时队列。达到可投递工夫时并将其通过 x-delayed-type 类型标记的交换机类型投递至指标队列。
rocketmq 在发送延时音讯时，是先把音讯依照延迟时间段发送到指定的队列中（把延时时间段雷同的音讯放到同一个队列中，保障了音讯解决的程序性，能够让同一个队列中音讯延时工夫是雷同的，整个 RocketMQ 中延时音讯时依照递增程序排序，保障信息处理的先后顺序性。）。之后，通过一个定时器来轮询解决这些队列里的信息，判断是否到期。对于到期的音讯会发送到相应的解决队列中，进行解决。留神：目前 RocketMQ 只反对特定的延时时间段，1s,5s,10s,…2h，不能反对任意时间段的延时设置。有趣味的小伙伴能够去理解下它是相干常识呀~Kafka 基于工夫轮自定义了一个用于实现提早性能的定时器（SystemTimer），Kafka 中的工夫轮（TimingWheel）是一个存储定时工作的环形队列，能够进行相干的延时队列设置。
Netty 也有基于工夫轮算法来实现延时队列。Netty 在构建延时队列次要用 HashedWheelTimer，HashedWheelTimer 底层数据结构是应用 DelayedQueue，采纳工夫轮的算法来实现。
Java 中有自带的 DelayQueue 数据类型，咱们能够用这个来实现延时队列。DelayQueue 是封装了一个 PriorityQueue（优先队列），在向 DelayQueue 队列中增加元素时，会给元素一个 Delay（延迟时间）作为排序条件，队列中最小的元素会优先放在队首，对于队列中的元素只有到了 Delay 工夫才容许从队列中取出。这种实现形式是数据保留在内存中，可能面临数据失落的状况，同时它是无奈反对分布式系统的。