延迟队列
 1. java 自带延迟队列
 2. redis 延迟队列
 3. RabbitMq 延迟队列
 4. 应用
 4.1. 异步通知
 4.2. 下单未支付取消
 4.3. 考试系统定时交卷
 4.4. 其他
 4.5. 定时任务实现
 4.6. 相关文章
 5. 相关文章

延迟队列 [Top]

与时间相关场景的应用，经常用于延后多少时间执行什么任务。

java 自带延迟队列 [Top]

class Solution {
    public static void main(String[] args) throws InterruptedException {
        DelayQueue<DelayMealTask> queue = new DelayQueue<>();
        DelayMealTask task = new DelayMealTask(System.nanoTime() + ThreadLocalRandom.current().nextLong(100000000L, 300000000L));
        queue.add(task);
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        System.out.println("begin to take task");
        DelayMealTask take = queue.take();
        System.out.println("get task complete id :" + take.getTaskId());
        stopWatch.stop();
        System.out.println("cost time : " + stopWatch.getTotalTimeMillis());
    }
}
// output ~

//begin to take task
//get task complete id :1
//cost time : 110

redis 延迟队列 [Top]

使用zset当延迟队列，使用时间戳当score。
redission 内部实现使用lua 脚本。结合zset、list和发布订阅模型
在zset的添加的时候，获取第一个元素发布消息。QueueTransferService 接受到消息，通过判断过期时间与当前时间戳的差值执行不同的策略。
若时间戳时延在10以内，则立即触发zset 元素到list的转移。若时延大于10，则新建定时任务，更新QueueTransferService 的最后触发定时任务时间。


<dependency>
   <groupId>org.redisson</groupId>
   <artifactId>redisson</artifactId>
   <version>3.8.0</version>
</dependency> 

public void producer(){
    RedissonClient redissonClient = Redisson.create(config);
    // 阻塞队列用于后端服务器的消费
    RBlockingQueue<CallCdr> blockingFairQueue = redissonClient.getBlockingQueue("delay_queue");
    
    RDelayedQueue<CallCdr> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
    for (int i = 0; i <10 ; i++) {
     try {
         Thread.sleep(1*1000);
     } catch (InterruptedException e) {
         e.printStackTrace();
     }
     // 一分钟以后将消息发送到指定队列
    //相当于1分钟后取消订单
    // 延迟队列包含callCdr 1分钟，然后将其传输到blockingFairQueue中
     //在1分钟后就可以在blockingFairQueue 中获取callCdr了 
    // (CallCdr自定义的类)
     CallCdr callCdr = new CallCdr(30000.00);
     callCdr.setPutTime();
     delayedQueue.offer(callCdr, 1, TimeUnit.MINUTES);
    
    }
    // 在该对象不再需要的情况下，应该主动销毁。
    // 仅在相关的Redisson对象也需要关闭的时候可以不用主动销毁。
    delayedQueue.destroy();
...
}


public void comsumer() {
    ...
    RedissonClient redissonClient = Redisson.create(config);
    RBlockingQueue<CallCdr> blockingFairQueue = redissonClient.getBlockingQueue("delay_queue");
    RDelayedQueue<CallCdr> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
    while (true){
     CallCdr callCdr = null;
     try {
         callCdr = blockingFairQueue.take();
     } catch (InterruptedException e) {
         e.printStackTrace();
     }
        System.out.println("订单取消时间："+new SimpleDateFormat("hh:mm:ss").format(new Date())+"==订单生成时间"+callCdr.getPutTime());
    }
    ...
}