分布式消息異步通知中間件實(shí)現(xiàn)方法及系統(tǒng)

基本信息

申請?zhí)?/td> CN202110450975.4 申請日 -
公開(公告)號 CN112988428A 公開(公告)日 2021-06-18
申請公布號 CN112988428A 申請公布日 2021-06-18
分類號 G06F9/54 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 沈浩 申請(專利權(quán))人 南京蜂泰互聯(lián)網(wǎng)科技有限公司
代理機(jī)構(gòu) 南京常青藤知識產(chǎn)權(quán)代理有限公司 代理人 高遠(yuǎn)
地址 210012 江蘇省南京市雨花臺區(qū)花神大道17號
法律狀態(tài) -

摘要

摘要 本發(fā)明提供分布式消息異步通知中間件實(shí)現(xiàn)方法及系統(tǒng),接收HTTP請求并將其持久化至數(shù)據(jù)庫中,并根據(jù)優(yōu)先級別進(jìn)行分類;對于優(yōu)先級別高的請求實(shí)時處理;將優(yōu)先級別正常的數(shù)據(jù)推送至延遲隊(duì)列池中等待固定時間后進(jìn)行處理;判斷處理后的響應(yīng)報(bào)文是否包含設(shè)置的期望內(nèi)容;若響應(yīng)報(bào)文包含期望內(nèi)容,則將信息狀態(tài)更新為成功,該任務(wù)結(jié)束;若響應(yīng)報(bào)文不包含期望內(nèi)容,則計(jì)算失敗次數(shù)并判斷其是否已達(dá)配置設(shè)定的最大重試次數(shù);若失敗次數(shù)小于最大重試次數(shù),將對應(yīng)的請求消息推送至延遲隊(duì)列池,重復(fù)等待處理;若失敗次數(shù)大于最大重試次數(shù),則調(diào)用通信軟件進(jìn)行異常告警通知,任務(wù)結(jié)束。實(shí)現(xiàn)了分布式系統(tǒng)異步通知消息可追溯與異常告警,保證業(yè)務(wù)閉環(huán)。