基于ActiveMQ的大批量數據同步方法

基本信息

申請?zhí)?/td> CN201711202922.0 申請日 -
公開（公告）號 CN107911462A 公開（公告）日 2018-04-13
申請公布號 CN107911462A 申請公布日 2018-04-13
分類號 H04L29/08 分類 電通信技術;
發(fā)明人 季超;趙文軍;劉本中;吳迎春;胡明慧;宋煒偉 申請（專利權）人 南京信通科技有限責任公司
代理機構 南京鐘山專利代理有限公司 代理人 南京信通科技有限責任公司;南京聯創(chuàng)信息科技有限公司
地址 210036 江蘇省南京市鼓樓區(qū)集慧路18號聯創(chuàng)科技大廈16層
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種基于ActiveMQ的大批量數據同步方法，包含以下步驟：通過NetworkConnector配置ActiveMQ服務端與服務端之間的通信，把大量的消息生產者和消息的消費者客戶端以及被NetworkConnector連接的多個互相透傳消息的服務器整合；生產者客戶端讀取本地數據，發(fā)送給本地MQ服務器S1，本地MQ消息服務器通過NetworkConnector透傳消息至消費平臺MQ服務器SP1，將隊列數據通過配置策略交由各自連接的消費者處理，完成數據同步；同步過程中，如果出現數據錯誤或者同步失敗的情況，將錯誤消息通過雙向MQ服務器發(fā)回省側，省側監(jiān)聽錯誤或失敗數據進行再次發(fā)送或者數據修復。本發(fā)明解決了多個消息供應商高并發(fā)調用為服務同步數據時對為服務造成過大壓力，影響其他微服務的正常運轉的問題。