一種支持更新的分布式延遲消息隊列處理系統(tǒng)

基本信息

申請?zhí)?/td> CN201910024757.7 申請日 -
公開（公告）號 CN109743137A 公開（公告）日 2019-05-10
申請公布號 CN109743137A 申請公布日 2019-05-10
分類號 H04L1/00（2006.01）I; H04L12/875（2013.01）I 分類 電通信技術(shù);
發(fā)明人 蔣震宇; 葛佳興; 付銀海; 賈立鋒; 李正先; 呂寶林; 彭勇軍; 王樹輝 申請（專利權(quán)）人 浙江小泰科技有限公司
代理機構(gòu) - 代理人 -
地址 310000 浙江省杭州市濱江區(qū)長河街道江虹路611號2幢301室
法律狀態(tài) -

摘要

摘要 本發(fā)明涉及消息隊列的技術(shù)領域，公開了一種支持更新的分布式延遲消息隊列處理系統(tǒng)，包括消息隊列、消息生產(chǎn)端、消息消費端，延遲消息包括隊列名稱、消息體、延遲發(fā)送的時間戳；消息生產(chǎn)端用于執(zhí)行以下模塊，判斷模塊，用于獲取當前的延遲消息并判斷消息隊列中是否存在延遲消息；若是，則刪除消息隊列中延遲發(fā)送的時間戳并向消息隊列中添加當前延遲消息中攜帶的延遲發(fā)送的時間戳；若否，則向消息隊列中添加延遲消息。通過采用上述技術(shù)方案，在判斷模塊判斷是時，只需更新延遲發(fā)送的時間戳即可完成延遲消息的延遲時間的更新，在中/高并發(fā)、分布式環(huán)境中實現(xiàn)了延遲消息的更新。