基于消息隊(duì)列及微服務(wù)的數(shù)據(jù)同步方法、裝置及系統(tǒng)
基本信息
| 申請?zhí)?/td> | CN202011068767.X | 申請日 | - |
| 公開（公告）號 | CN111930529B | 公開（公告）日 | 2020-11-13 |
| 申請公布號 | CN111930529B | 申請公布日 | 2020-11-13 |
| 分類號 | G06F9/52(2006.01)I;G06F9/54(2006.01)I | 分類 | 計(jì)算；推算；計(jì)數(shù); |
| 發(fā)明人 | 黃菲;吳建英;吳建平;劉冬;李陽;楊士宏;謝鵬;施海娟;宋文君;谷西波;孫筱曄 | 申請（專利權(quán)）人 | 上海富友支付服務(wù)股份有限公司 |
| 代理機(jī)構(gòu) | 上海專利商標(biāo)事務(wù)所有限公司 | 代理人 | 顧嘉運(yùn) |
| 地址 | 201206上海市浦東新區(qū)中國（上海）自由貿(mào)易試驗(yàn)區(qū)金藏路351號6號房三層 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本申請公開了一種基于消息隊(duì)列及微服務(wù)的數(shù)據(jù)同步方案，包括：注冊并加載數(shù)據(jù)同步服務(wù)以創(chuàng)建數(shù)據(jù)同步模塊；創(chuàng)建消息隊(duì)列服務(wù)的長連接，創(chuàng)建微服務(wù)的長連接；接收或收集待同步數(shù)據(jù)；以消息隊(duì)列協(xié)議方式將所接收到的待同步數(shù)據(jù)以消息內(nèi)容形式發(fā)送給數(shù)據(jù)同步處理服務(wù)模塊；通過在監(jiān)測期間捕捉發(fā)送異常信息來判斷在利用消息隊(duì)列協(xié)議進(jìn)行數(shù)據(jù)同步期間是否發(fā)生了數(shù)據(jù)同步失敗的情況：如果確定發(fā)生了數(shù)據(jù)同步失敗的情況，則啟動數(shù)據(jù)同步補(bǔ)償機(jī)制以微服務(wù)的方式再次將所述消息內(nèi)容發(fā)送給所述數(shù)據(jù)同步處理服務(wù)模塊；以及所述數(shù)據(jù)同步處理服務(wù)模塊接收從所述數(shù)據(jù)同步模塊發(fā)送的消息內(nèi)容并對所述消息內(nèi)容進(jìn)行數(shù)據(jù)同步處理。?? |
