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

基本信息

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

摘要

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