掃二維碼與項目經(jīng)理溝通
我們在微信上24小時期待你的聲音
解答本文疑問/技術(shù)咨詢/運營咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流
??阻塞生產(chǎn)者消費者模式是一種常見的模式,它具有生產(chǎn)者發(fā)布任務(wù)、消費者消費任務(wù)和消息隊列存儲任務(wù)的三種成分。Redis消費者架構(gòu)實現(xiàn)阻塞生產(chǎn)者消費者模式的思路是,將任務(wù)定義為可阻塞的命令,生產(chǎn)者往Redis消息隊列傳遞任務(wù),消費者從隊列獲取任務(wù),執(zhí)行完任務(wù)則將結(jié)果存入Redis中。

成都創(chuàng)新互聯(lián)公司是由多位在大型網(wǎng)絡(luò)公司、廣告設(shè)計公司的優(yōu)秀設(shè)計人員和策劃人員組成的一個具有豐富經(jīng)驗的團隊,其中包括網(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è)與維護、網(wǎng)絡(luò)推廣、數(shù)據(jù)庫開發(fā),以高性價比制作企業(yè)網(wǎng)站、行業(yè)門戶平臺等全方位的服務(wù)。
??下面具體介紹一下,Redis消費者架構(gòu)實現(xiàn)阻塞生產(chǎn)者消費者模式的實現(xiàn)方式:
1. 定義阻塞生產(chǎn)者消費者模式的實現(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. 啟動消費者:
??消費者啟動后,它會向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ù)器、虛擬主機、網(wǎng)站系統(tǒng)開發(fā)經(jīng)驗。專業(yè)提供云主機、虛擬主機、域名注冊、VPS主機、云服務(wù)器、香港云服務(wù)器、免備案服務(wù)器等。

我們在微信上24小時期待你的聲音
解答本文疑問/技術(shù)咨詢/運營咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流