新聞中心
??阻塞生產(chǎn)者消費(fèi)者模式是一種常見的模式,它具有生產(chǎn)者發(fā)布任務(wù)、消費(fèi)者消費(fèi)任務(wù)和消息隊列存儲任務(wù)的三種成分。Redis消費(fèi)者架構(gòu)實(shí)現(xiàn)阻塞生產(chǎn)者消費(fèi)者模式的思路是,將任務(wù)定義為可阻塞的命令,生產(chǎn)者往Redis消息隊列傳遞任務(wù),消費(fèi)者從隊列獲取任務(wù),執(zhí)行完任務(wù)則將結(jié)果存入Redis中。

成都創(chuàng)新互聯(lián)公司是由多位在大型網(wǎng)絡(luò)公司、廣告設(shè)計公司的優(yōu)秀設(shè)計人員和策劃人員組成的一個具有豐富經(jīng)驗(yàn)的團(tuán)隊,其中包括網(wǎng)站策劃、網(wǎng)頁美工、網(wǎng)站程序員、網(wǎng)頁設(shè)計師、平面廣告設(shè)計師、網(wǎng)絡(luò)營銷人員及形象策劃。承接:成都做網(wǎng)站、網(wǎng)站設(shè)計、網(wǎng)站改版、網(wǎng)頁設(shè)計制作、網(wǎng)站建設(shè)與維護(hù)、網(wǎng)絡(luò)推廣、數(shù)據(jù)庫開發(fā),以高性價比制作企業(yè)網(wǎng)站、行業(yè)門戶平臺等全方位的服務(wù)。
??下面具體介紹一下,Redis消費(fèi)者架構(gòu)實(shí)現(xiàn)阻塞生產(chǎn)者消費(fèi)者模式的實(shí)現(xiàn)方式:
1. 定義阻塞生產(chǎn)者消費(fèi)者模式的實(shí)現(xiàn)命令:
??首先定義有關(guān)ESTABLISH,CONSUME和RESULT的命令,其格式如下:
ESTABLISH:
CONSUME:
RESULT:
2. 啟動生產(chǎn)者:
??生產(chǎn)者啟動后,會從隊列中任務(wù)并往Redis消息隊列傳遞ESTABLISH命令。
# 生產(chǎn)者啟動
while True:
# 從隊列中取出任務(wù)信息
task = dequeue()
# 將ESTABLISH命令傳遞到Redis消息隊列
rc.lpush('ESTABLISH', json.dumps({'task_id': task.task_id, 'data': task.data}))
3. 啟動消費(fèi)者:
??消費(fèi)者啟動后,它會向Redis消息隊列發(fā)送CONSUME命令,用于獲取任務(wù),取出的任務(wù)就是隊列中的任務(wù);當(dāng)然,如果不加任務(wù)的話,CONSUME會一直發(fā)送,直到發(fā)現(xiàn)任務(wù)
香港服務(wù)器選創(chuàng)新互聯(lián),2H2G首月10元開通。
創(chuàng)新互聯(lián)(www.cdcxhl.com)互聯(lián)網(wǎng)服務(wù)提供商,擁有超過10年的服務(wù)器租用、服務(wù)器托管、云服務(wù)器、虛擬主機(jī)、網(wǎng)站系統(tǒng)開發(fā)經(jīng)驗(yàn)。專業(yè)提供云主機(jī)、虛擬主機(jī)、域名注冊、VPS主機(jī)、云服務(wù)器、香港云服務(wù)器、免備案服務(wù)器等。
標(biāo)題名稱:消費(fèi)者Redis架構(gòu)實(shí)現(xiàn)阻塞生產(chǎn)者消費(fèi)者模式(redis阻塞生產(chǎn)者)
瀏覽地址:http://www.fisionsoft.com.cn/article/cdppcco.html


咨詢
建站咨詢
