實現(xiàn)任務(wù)隊列之前，我們先了解一下使用任務(wù)隊列有哪些好處:

1.松耦合。生產(chǎn)者和消費(fèi)者無需知道彼此的實現(xiàn)細(xì)節(jié)，只需要約定好任務(wù)的描述格式。這使得生產(chǎn)者和消費(fèi)者可以由不同的團(tuán)隊使用不同的編程語言編寫。

2.易于擴(kuò)展。消費(fèi)者可以由多個，而且可以分布在不同的服務(wù)器中，借此可以輕易地降低單臺服務(wù)器的負(fù)載。

要實現(xiàn)隊列很自然就想到Redis的列表類型，以及LPUSH和RPOP命令。如果要實現(xiàn)任務(wù)隊列，只需要讓生產(chǎn)者將任務(wù)使用LPUSH命令加入到某個鍵中，另一邊讓消費(fèi)者不斷的使用RPOP命令從該鍵中取出任務(wù)即可。Redis的偽代碼實現(xiàn)如下：

Redis偽代碼

#?無限循環(huán)讀取任務(wù)隊列中的內(nèi)容
loop
????$task?=?RPOP?queue
????if?$task
????????#?如果任務(wù)隊列中有任務(wù)，則執(zhí)行它
????????execute($task)????
????else
?????????#?如果沒有任務(wù)，則等待1秒，以免過于頻繁的請求數(shù)據(jù)
?????????wait?1?second

至此，一個使用Redis實現(xiàn)的簡單任務(wù)隊列就寫好了，不過還有一點問題：當(dāng)任務(wù)隊列中沒有任務(wù)時，消費(fèi)者每秒都會調(diào)用一次RPOP命令查看是否有新任務(wù)。

優(yōu)化：借助BRPOP命令，可以實現(xiàn)一旦有新任務(wù)加入隊列就通知消費(fèi)者

BRPOP命令接收兩個參數(shù)，第一個是鍵名，第二個是超時時間，單位是秒。當(dāng)超過了此時間仍然沒有獲得新元素的話就會返回nil。如果超時時間設(shè)為“0”，表示不限制等待的時間，如果沒有新元素加入列表就會永遠(yuǎn)阻塞下去。

BRPOP和RPOP命令相似，唯一區(qū)別是：任務(wù)列表中沒有元素時BRPOP命令會一直阻塞住連接，直到有新元素加入。上面的偽代碼可以優(yōu)化為：

Redis偽代碼

loop
????#?如果任務(wù)隊列中沒有新任務(wù)，BRPOP命令會一直阻塞，不會執(zhí)行execute()
????$task?=?BRPOP?queue,?0
????#?返回值是一個數(shù)組，數(shù)組的第二個元素是我們需要的任務(wù)
????execute($task[1])

隊列有的時候需要優(yōu)先級。比如：系統(tǒng)需要發(fā)送確認(rèn)郵件和通知郵件兩種任務(wù)同時存在時，應(yīng)該優(yōu)先執(zhí)行確認(rèn)郵件。具體場景如下，訂閱一個名人的博客的用戶有10萬人，當(dāng)該博客發(fā)布一篇新文章后，博客就會向任務(wù)隊列中添加10萬個發(fā)送通知郵件的任務(wù)。如果每一封郵件需要10ms，那么全部完成這10萬個任務(wù)就需要：100 000*10/1000=1000秒（將近20分鐘）。加入這期間有新用戶想訂閱該博客，當(dāng)提交完自己的郵箱并看到網(wǎng)頁提示查收確認(rèn)郵件時，該用戶并不知道向自己發(fā)送的確認(rèn)郵件的任務(wù)被加入到已經(jīng)有10萬個任務(wù)的隊列中，需要為此等待近20分鐘。

分析具體場景，發(fā)布新文章后通知訂閱用戶的任務(wù)并不很緊急，延遲20分鐘完全可以接受。所以可以得出如下結(jié)論：當(dāng)發(fā)送確認(rèn)郵件和發(fā)送通知郵件兩種任務(wù)同時存在時，應(yīng)該優(yōu)先執(zhí)行前者。為了實現(xiàn)這一目的，我們需要實現(xiàn)一個優(yōu)先級隊列。

BRPOP命令可以同時接受多個鍵，其完整的命令格式為：BRPOP key[key...]timeout,如：BRPOP queue1 queue2 0.著意味著同時檢測多個鍵，如果其中有一個鍵有元素，則從該鍵中彈出元素；如果多個鍵都有元素，則按照從左到右的順序取第一個鍵中的第一個元素。

借此特性可以實現(xiàn)區(qū)分優(yōu)先級的任務(wù)隊列。我們分別使用queue:confirmation.email和queue.notification.email兩個鍵存儲發(fā)送確認(rèn)郵件和發(fā)送通知郵件兩種任務(wù)，然后將消費(fèi)者的偽代碼修改為：

Redis偽代碼

loop
????$task?=?
????BRPOP??queue:confirmationl.email,
????????????????queue:notification.email,
????????????????0
????execute($task[1])

這時，一旦發(fā)送確認(rèn)郵件的任務(wù)被加入到queue.confirmation.email隊列中，無論queue：notification.email還有多少任務(wù)，消費(fèi)者都會優(yōu)先完成發(fā)送確認(rèn)郵件的通知任務(wù)。

Java隊列：http://m.ilovecolors.com.cn/tutorial_javaqueue/

以上就是對“Java利用Redis實現(xiàn)任務(wù)隊列”的介紹，希望對大家有所幫助，如有疑問，請在線咨詢，有專業(yè)老師隨時為你服務(wù)。