redis 隊(duì)列的優(yōu)點(diǎn)是輕量級(jí)，業(yè)務(wù)足夠簡(jiǎn)單時(shí)不需要使用rabbitMq這樣專業(yè)的消息中間件；缺點(diǎn)是彈出隊(duì)列中的元素時(shí)，即使該消息處理失敗也無法再次進(jìn)行消費(fèi)

Redis隊(duì)列 List

簡(jiǎn)單演示如下

普通的redis隊(duì)列，為了實(shí)現(xiàn)業(yè)務(wù)，通常會(huì)使用while進(jìn)行循環(huán)，這樣的話沒有消息時(shí)依舊會(huì)頻繁的執(zhí)行循環(huán)，造成cpu的空轉(zhuǎn)，所以一般會(huì)在代碼中增加sleep來解決該問題，但因此又會(huì)造成消息延遲問題。

阻塞隊(duì)列可以很好的解決這些問題。

Redis阻塞隊(duì)列

redis隊(duì)列提供了 “阻塞式” 拉取消息的命令：BRPOP / BLPOP，這里的 B 指的是阻塞（Block）。如果隊(duì)列為空，消費(fèi)者在拉取消息時(shí)就「阻塞等待」，一旦有新消息過來，就通知消費(fèi)者立即處理新消息。

阻塞隊(duì)列實(shí)現(xiàn)：

使用 BRPOP 這種阻塞式方式拉取消息時(shí)，還支持傳入一個(gè)「超時(shí)時(shí)間」，如果設(shè)置為 0，則表示不設(shè)置超時(shí)，直到有新消息才返回，否則會(huì)在指定的超時(shí)時(shí)間后返回 NULL

下面是某業(yè)務(wù)完整的消費(fèi)者代碼

注意：

1. 阻塞時(shí)間結(jié)束后代碼會(huì)繼續(xù)向下執(zhí)行
2. 如果設(shè)置的超時(shí)時(shí)間太長(zhǎng)，這個(gè)連接太久沒有活躍過，可能會(huì)被 Redis Server 判定為無效連接，之后 Redis Server 會(huì)強(qiáng)制把這個(gè)客戶端踢下線。所以，客戶端要有處理機(jī)制。實(shí)際項(xiàng)目中redis連接超時(shí)時(shí)間遠(yuǎn)大于20s，因此正常情況不會(huì)出現(xiàn)redis超時(shí)問題。以防萬(wàn)一增加redis異常捕獲，出現(xiàn)異常時(shí)殺掉當(dāng)前進(jìn)程，同時(shí)supervisord會(huì)自動(dòng)重新拉起該進(jìn)程

 到此這篇關(guān)于Redis隊(duì)列和阻塞隊(duì)列的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Redis隊(duì)列和阻塞隊(duì)列內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論