這篇文章將為大家詳細(xì)講解有關(guān)Java中延遲隊列的原理是什么，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
創(chuàng)新互聯(lián)公司服務(wù)項目包括尼元陽網(wǎng)站建設(shè)、尼元陽網(wǎng)站制作、尼元陽網(wǎng)頁制作以及尼元陽網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，尼元陽網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到尼元陽省份的部分城市，未來相信會繼續(xù)擴大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
Java是一門面向?qū)ο缶幊陶Z言，可以編寫桌面應(yīng)用程序、Web應(yīng)用程序、分布式系統(tǒng)和嵌入式系統(tǒng)應(yīng)用程序。
一、消息體
重慶分公司
重慶分公司
package com.delqueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
public class Message implements Delayed {
private int id;
private String body; // 消息內(nèi)容
private long excuteTime;// 延遲時長，這個是必須的屬性因為要按照這個判斷延時時長。
public int getId() {
return id;
}
public String getBody() {
return body;
}
public long getExcuteTime() {
return excuteTime;
}
public Message(int id, String body, long delayTime) {
this.id = id;
this.body = body;
this.excuteTime = TimeUnit.NANOSECONDS.convert(delayTime, TimeUnit.MILLISECONDS) + System.nanoTime();
}
// 自定義實現(xiàn)比較方法返回 1 0 -1三個參數(shù)
@Override
public int compareTo(Delayed delayed) {
Message msg = (Message) delayed;
return Integer.valueOf(this.id) > Integer.valueOf(msg.id) ? 1
: (Integer.valueOf(this.id) < Integer.valueOf(msg.id) ? -1 : 0);
}
// 延遲任務(wù)是否到時就是按照這個方法判斷如果返回的是負(fù)數(shù)則說明到期否則還沒到期
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(this.excuteTime - System.nanoTime(), TimeUnit.NANOSECONDS);
}
}二、消息消費者
package com.delqueue;
import java.util.concurrent.DelayQueue;
public class Consumer implements Runnable {
// 延時隊列 ,消費者從其中獲取消息進行消費
private DelayQueue queue;
public Consumer(DelayQueue queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
Message take = queue.take();
System.out.println("消費消息id：" + take.getId() + " 消息體：" + take.getBody());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} 三、延時隊列
package com.delqueue;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class DelayQueueTest {
public static void main(String[] args) {
// 創(chuàng)建延時隊列
DelayQueue queue = new DelayQueue();
// 添加延時消息,m1 延時3s
Message m1 = new Message(1, "world", 3000);
// 添加延時消息,m2 延時10s
Message m2 = new Message(2, "hello", 10000);
//將延時消息放到延時隊列中
queue.offer(m2);
queue.offer(m1);
// 啟動消費線程 消費添加到延時隊列中的消息，前提是任務(wù)到了延期時間
ExecutorService exec = Executors.newFixedThreadPool(1);
exec.execute(new Consumer(queue));
exec.shutdown();
}
} 將消息體放入延遲隊列中，在啟動消費者線程去消費延遲隊列中的消息，如果延遲隊列中的消息到了延遲時間則可以從中取出消息否則無法取出消息也就無法消費。
這就是延遲隊列demo，下面我們來說說在真實環(huán)境下的使用。
使用場景描述：
在打車軟件中對訂單進行派單的流程，當(dāng)有訂單的時候給該訂單篩選司機，然后給當(dāng)訂單綁定司機，但是有時運氣沒那么好，訂單進來后第一次沒有篩選到合適的司機，但我們也不能就此結(jié)束派單，而是將該訂單的信息放到延時隊列中過個2秒鐘在進行一次，其實這個2秒鐘就是一個延遲，所以這里我們就可以使用延時隊列來實現(xiàn)……
下面看看簡單的流程圖：
下面來看看具體代碼實現(xiàn)：
在項目中有如下幾個類：第一 、任務(wù)類 第二、按照任務(wù)類組裝的消息體類 第三、延遲隊列管理類
任務(wù)類即執(zhí)行篩選司機、綁單、push消息的任務(wù)類
package com.test.delayqueue;
/**
* 具體執(zhí)行相關(guān)業(yè)務(wù)的業(yè)務(wù)類
* @author whd
* @date 2017年9月25日 上午12:49:32
*/
public class DelayOrderWorker implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
//相關(guān)業(yè)務(wù)邏輯處理
System.out.println(Thread.currentThread().getName()+" do something ……");
}
}消息體類，在延時隊列中這個實現(xiàn)了Delayed接口的消息類是比不可少的，實現(xiàn)接口時有一個getDelay(TimeUnit unit)方法，這個方法就是判斷是否到期的
這里定義的是一個泛型類，所以可以將我們上面的任務(wù)類作為其中的task，這樣就將任務(wù)類分裝成了一個消息體
