一種可控式大并發(fā)分布式消息隊(duì)列推送方法

基本信息

申請(qǐng)?zhí)?/td> CN201610677468.3 申請(qǐng)日 -
公開（公告）號(hào) CN106330750A 公開（公告）日 2017-01-11
申請(qǐng)公布號(hào) CN106330750A 申請(qǐng)公布日 2017-01-11
分類號(hào) H04L12/803(2013.01)I;H04L12/863(2013.01)I;H04L12/24(2006.01)I;H04L29/08(2006.01)I 分類 電通信技術(shù);
發(fā)明人 粟超 申請(qǐng)（專利權(quán)）人 成都聚美優(yōu)品科技有限公司
代理機(jī)構(gòu) 北京康盛知識(shí)產(chǎn)權(quán)代理有限公司 代理人 成都聚美優(yōu)品科技有限公司
地址 610000 四川省成都市高新區(qū)益州大道中段1800號(hào)天府軟件園G區(qū)3棟5層501
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種可控式大并發(fā)分布式消息隊(duì)列推送方法，包括FIFO列隊(duì)模型，所述FIFO列隊(duì)模型前端增設(shè)消息入列網(wǎng)關(guān)和消息分發(fā)模塊，所述消息分發(fā)模塊進(jìn)行統(tǒng)一可控的消息推送控制，所述消息入列網(wǎng)關(guān)進(jìn)行消息入列管理和容錯(cuò)處理/恢復(fù)，所述FIFO列隊(duì)模型末端設(shè)有調(diào)度程序模塊和消費(fèi)者消息處理器。與現(xiàn)有技術(shù)相比，本發(fā)明能主動(dòng)控制消息消費(fèi)者接入數(shù)量或請(qǐng)求頻率，節(jié)約隊(duì)列服務(wù)資源，最大可能地使其避免了宕機(jī)風(fēng)險(xiǎn)，具有消息容錯(cuò)延后處理的功能，避免進(jìn)程阻塞，消息隊(duì)列數(shù)據(jù)堆積，服務(wù)資源急劇消耗，具有無服務(wù)容錯(cuò)處理的功能，避免了在隊(duì)列依賴的存儲(chǔ)服務(wù)不可用時(shí)，導(dǎo)致消息生產(chǎn)者發(fā)送消息失敗的情況發(fā)生。