延遲隊列DelayQueue簡單入門

1、DelayQueue是什麼

DelayQueue是一個無界的BlockingQueue，用於放置實現了Delayed接口的對象，其中的對象只能在其到期時才能從隊列中取走。這種隊列是有序的，即隊頭對象的延遲到期時間最長。注意：不能將null元素放置到這種隊列中。

2、DelayQueue能作什麼

1. 淘寶訂單業務:下單以後若是三十分鐘以內沒有付款就自動取消訂單。 
2. 餓了嗎訂餐通知:下單成功後60s以後給用戶發送短信通知。

3、實際開發中的應用

簡單的延時隊列要有三部分：第一實現了Delayed接口的消息體、第二消費消息的消費者、第三存放消息的延時隊列
1.消息體。實現接口 Delayed ，重寫方法 compareTo 和 getDelay

public class Message implements Delayed{

    private Map<String,String> body=new HashMap<>();  //消息內容
    private long excuteTime;//執行時間
    private String type;

    public Map<String, String> getBody() {
        return body;
    }
    public void setBody(Map<String, String> body) {
        this.body = body;
    }
    public long getExcuteTime() {
        return excuteTime;
    }
    public void setExcuteTime(long excuteTime) {
        this.excuteTime = excuteTime;
    }
    public String getType() {
        return type;
    }
    public void setType(String type) {
        this.type = type;
    }
    public Message(long delayTime,String type) {
        this.excuteTime = TimeUnit.NANOSECONDS.convert(delayTime, TimeUnit.MILLISECONDS) + System.nanoTime();
        this.type=type;
    }
    @Override
    public int compareTo(Delayed delayed) {
        long d = (getDelay(TimeUnit.NANOSECONDS) - delayed.getDelay(TimeUnit.NANOSECONDS));
        return (d == 0) ? 0 : ((d < 0) ? -1 : 1);
    }
    @Override
    public long getDelay(TimeUnit unit) {
        return  unit.convert(this.excuteTime - System.nanoTime(), TimeUnit.NANOSECONDS);
    }
}

2.聲明消費者。實現接口Runnable

public class Consumer implements Runnable {

    // 延時隊列
    private DelayQueue<Message> queue;
    public static boolean  isRun=false;

    public Consumer(DelayQueue<Message> queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        isRun=true;
        while (true) {
            try {
                Message take = queue.take();
                System.out.println("消息類型：" + take.getType());
                Map<String,String> map=take.getBody();
                System.out.println("消息內容：");
                for (String key:map.keySet()){
                    System.out.println("key="+map.get(key));
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

3.延遲隊列管理者，用於在任何地方獲取 DelayQueue 

public class DelayQueueManager {

    private static DelayQueue<Message> delayQueue=null;

    static {
        // 建立延時隊列
       delayQueue = new DelayQueue<Message>();
    }

    public static DelayQueue<Message> getDelayQueue(){
        return delayQueue;
    }
}

4.使用延遲隊列發送消息

// 添加延時消息,m1 延時5s
	Message m1 = new Message( 5000,"訂單");
	m1.getBody().put("content","12345");
	// 添加延時消息,m1 延時5s
	DelayQueueManager.getDelayQueue().offer(m1);
	if(!Consumer.isRun){
		// 啓動消費線程
		new Thread(new Consumer(DelayQueueManager.getDelayQueue())).start();
	}

以上就是延遲隊列delayQueue的簡單入門配置和使用，但願對你有幫助！

文章參考：
https://blog.csdn.net/zhu_tianwei/article/details/53549653