基于ActiveMQ的大批量數(shù)據(jù)同步方法
基本信息
| 申請(qǐng)?zhí)?/td> | CN201711202922.0 | 申請(qǐng)日 | - |
| 公開(kāi)（公告）號(hào) | CN107911462A | 公開(kāi)（公告）日 | 2018-04-13 |
| 申請(qǐng)公布號(hào) | CN107911462A | 申請(qǐng)公布日 | 2018-04-13 |
| 分類(lèi)號(hào) | H04L29/08 | 分類(lèi) | 電通信技術(shù); |
| 發(fā)明人 | 季超;趙文軍;劉本中;吳迎春;胡明慧;宋煒偉 | 申請(qǐng)（專利權(quán)）人 | 南京聯(lián)創(chuàng)信息科技有限公司 |
| 代理機(jī)構(gòu) | 南京鐘山專利代理有限公司 | 代理人 | 南京信通科技有限責(zé)任公司;南京聯(lián)創(chuàng)信息科技有限公司 |
| 地址 | 210036 江蘇省南京市鼓樓區(qū)集慧路18號(hào)聯(lián)創(chuàng)科技大廈16層 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開(kāi)了一種基于ActiveMQ的大批量數(shù)據(jù)同步方法，包含以下步驟：通過(guò)NetworkConnector配置ActiveMQ服務(wù)端與服務(wù)端之間的通信，把大量的消息生產(chǎn)者和消息的消費(fèi)者客戶端以及被NetworkConnector連接的多個(gè)互相透?jìng)飨⒌姆?wù)器整合；生產(chǎn)者客戶端讀取本地?cái)?shù)據(jù)，發(fā)送給本地MQ服務(wù)器S1，本地MQ消息服務(wù)器通過(guò)NetworkConnector透?jìng)飨⒅料M(fèi)平臺(tái)MQ服務(wù)器SP1，將隊(duì)列數(shù)據(jù)通過(guò)配置策略交由各自連接的消費(fèi)者處理，完成數(shù)據(jù)同步；同步過(guò)程中，如果出現(xiàn)數(shù)據(jù)錯(cuò)誤或者同步失敗的情況，將錯(cuò)誤消息通過(guò)雙向MQ服務(wù)器發(fā)回省側(cè)，省側(cè)監(jiān)聽(tīng)錯(cuò)誤或失敗數(shù)據(jù)進(jìn)行再次發(fā)送或者數(shù)據(jù)修復(fù)。本發(fā)明解決了多個(gè)消息供應(yīng)商高并發(fā)調(diào)用為服務(wù)同步數(shù)據(jù)時(shí)對(duì)為服務(wù)造成過(guò)大壓力，影響其他微服務(wù)的正常運(yùn)轉(zhuǎn)的問(wèn)題。 |
