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

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


咨詢
建站咨詢
