分布式消息異步通知中間件實現(xiàn)方法及系統(tǒng)
基本信息
申請?zhí)?/td> | CN202110450975.4 | 申請日 | - |
公開(公告)號 | CN112988428A | 公開(公告)日 | 2021-06-18 |
申請公布號 | CN112988428A | 申請公布日 | 2021-06-18 |
分類號 | G06F9/54 | 分類 | 計算;推算;計數(shù); |
發(fā)明人 | 沈浩 | 申請(專利權(quán))人 | 南京蜂泰互聯(lián)網(wǎng)科技有限公司 |
代理機構(gòu) | 南京常青藤知識產(chǎn)權(quán)代理有限公司 | 代理人 | 高遠 |
地址 | 210012 江蘇省南京市雨花臺區(qū)花神大道17號 | ||
法律狀態(tài) | - |
摘要
摘要 | 本發(fā)明提供分布式消息異步通知中間件實現(xiàn)方法及系統(tǒng),接收HTTP請求并將其持久化至數(shù)據(jù)庫中,并根據(jù)優(yōu)先級別進行分類;對于優(yōu)先級別高的請求實時處理;將優(yōu)先級別正常的數(shù)據(jù)推送至延遲隊列池中等待固定時間后進行處理;判斷處理后的響應報文是否包含設(shè)置的期望內(nèi)容;若響應報文包含期望內(nèi)容,則將信息狀態(tài)更新為成功,該任務結(jié)束;若響應報文不包含期望內(nèi)容,則計算失敗次數(shù)并判斷其是否已達配置設(shè)定的最大重試次數(shù);若失敗次數(shù)小于最大重試次數(shù),將對應的請求消息推送至延遲隊列池,重復等待處理;若失敗次數(shù)大于最大重試次數(shù),則調(diào)用通信軟件進行異常告警通知,任務結(jié)束。實現(xiàn)了分布式系統(tǒng)異步通知消息可追溯與異常告警,保證業(yè)務閉環(huán)。 |
