基于消息隊(duì)列及微服務(wù)的數(shù)據(jù)同步方法、模塊及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN202011068767.X 申請(qǐng)日 -
公開(公告)號(hào) CN111930529A 公開(公告)日 2020-11-13
申請(qǐng)公布號(hào) CN111930529A 申請(qǐng)公布日 2020-11-13
分類號(hào) G06F9/52(2006.01)I;G06F9/54(2006.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 黃菲;吳建英;吳建平;劉冬;李陽(yáng);楊士宏;謝鵬;施海娟;宋文君;谷西波;孫筱曄 申請(qǐng)(專利權(quán))人 上海富友支付服務(wù)股份有限公司
代理機(jī)構(gòu) 上海專利商標(biāo)事務(wù)所有限公司 代理人 上海富友支付服務(wù)股份有限公司
地址 201206上海市浦東新區(qū)中國(guó)(上海)自由貿(mào)易試驗(yàn)區(qū)金藏路351號(hào)6號(hào)房三層
法律狀態(tài) -

摘要

摘要 本申請(qǐng)公開了一種基于消息隊(duì)列及微服務(wù)的數(shù)據(jù)同步方案,包括:注冊(cè)并加載數(shù)據(jù)同步服務(wù)以創(chuàng)建數(shù)據(jù)同步模塊;創(chuàng)建消息隊(duì)列服務(wù)的長(zhǎng)連接,創(chuàng)建微服務(wù)的長(zhǎng)連接;接收或收集待同步數(shù)據(jù);以消息隊(duì)列協(xié)議方式將所接收到的待同步數(shù)據(jù)以消息內(nèi)容形式發(fā)送給數(shù)據(jù)同步處理服務(wù)模塊;通過在監(jiān)測(cè)期間捕捉發(fā)送異常信息來(lái)判斷在利用消息隊(duì)列協(xié)議進(jìn)行數(shù)據(jù)同步期間是否發(fā)生了數(shù)據(jù)同步失敗的情況:如果確定發(fā)生了數(shù)據(jù)同步失敗的情況,則啟動(dòng)數(shù)據(jù)同步補(bǔ)償機(jī)制以微服務(wù)的方式再次將所述消息內(nèi)容發(fā)送給所述數(shù)據(jù)同步處理服務(wù)模塊;以及所述數(shù)據(jù)同步處理服務(wù)模塊接收從所述數(shù)據(jù)同步模塊發(fā)送的消息內(nèi)容并對(duì)所述消息內(nèi)容進(jìn)行數(shù)據(jù)同步處理。??