延时队列

背景

平时，可能我们需要到某个时间执行某个任务，比如每周一统计部门人员的工作量，或者每10分钟执行某个任务，这种就是定时器的使用场景。定时器使用比较多，也有比较多的解决方案。 另外，除了定时器，还有一种情况是需要过了多少时间后执行某个任务，这个任务只执行一次，这种情况不像定时器会周期性地执行定时任务，它只会执行一次就可以，就是常说的延时任务。

设想

可以将延时任务放到一条队列里，这条队列就是延时队列，而另外有定时器去延时队列里取任务，取出任务执行一次，那这个延时任务就只会执行一次，从而也达到了延时任务只执行一次的效果。

方案

定时器的具体实现可行方案是比较多，每种语言都会提供比较多的选择，比如Java，可以使用jdk自带的定时器，也可以使用spirng quartz等等。 主要是延时任务，延时任务的特性，需要在多少时间后执行，那它的延时时间是肯定会有的，比如10秒后执行，10分钟后执行。 redis的sorted set数据结构对于延时任务是比较适合的，可以将延时任务的延时时间保存在score，延时任务的任务信息保存在member里，sorted set是根据score排好序的，那我们就比较好取出达到时间点的score，另外一点就是定时器每隔一秒就从sorted set里取出定时任务，如果有需要执行的延时任务就执行即可。 上面的方案有个关键点就是定时器，定时器需要具备健壮性，只有一个定时器进程时，比较难保证定时器是24小时可用的，那可以使用多个定时器消费延时队列。由于redis对处理请求是单线程， 多个定时器同时去消费延时队列时，只会有一个定时器成功消费。