[發明專利]一種向外部系統推送數據并實現數據同步的方法和系統

在審

• 申請號: 202011506437.4
• 申請日: 2020-12-18
• 公開（公告）號: CN112416633A
• 公開（公告）日: 2021-02-26
• 發明（設計）人: 楊興榮;潘昌貴;楊興海;李建州;吳秀峰
• 申請（專利權）人: 世紀恒通科技股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50;G06F16/2457;G06F16/27;G06F16/23;G06F16/9535
• 代理公司: 貴州啟辰知識產權代理有限公司 52108
• 代理人: 趙彥棟;周廉鳳

1.一種向外部系統推送數據并實現數據同步的方法，其特征在于：包括如下步驟：

（1）在推送數據接收及存儲模塊中，當有業務服務系統中的推送數據寫入數據接收隊列MQ1時，從此隊列取出推送數據并存儲到本地的數據庫中形成推送任務，把推送任務唯一標識ID送入推送任務排隊隊列MQ2進行排隊；

（2）在推送數據分析及執行模塊中，當有推送任務唯一標識ID寫入推送任務排隊隊列MQ2時，根據推送任務唯一標識ID查詢數據庫獲取推送數據以及相關的配置，經分析和處理后，匹配出該推送數據需要推送到的目標客戶系統，根據與目標客戶系統的對接協議把推送數據轉換成對應的格式并發起一個HTTP請求，最后把推送數據推送給目標客戶系統，在發起HTTP請求時會啟用一個短時間多次即時重試機制；

（3）由推送延時重試模塊監測推送數據分析及執行模塊的推送執行結果，當發起的HTTP請求返回成功，則更新本地的數據庫的數據并把此推送任務的狀態設為成功狀態，如果HTTP請求返回失敗或者請求響應超時，則更新本地的數據庫的數據并把此推送任務的狀態設為失敗狀態，同時把該推送任務進行長時間多次間隔的延時處理；

（4）由推送預警模塊監測推送延時重試模塊是否有長時間多次間隔延時推送失敗的推送任務，若有則根據相關的配置，把該事件通過通訊方式發送給相關的處理人員。

2.根據權利要求1所述的一種向外部系統推送數據并實現數據同步的方法，其特征在于：長時間多次間隔的延時處理中的多次間隔時間依次加長。

3.一種向外部系統推送數據并實現數據同步的系統，其特征在于：包括

推送數據接收及存儲模塊：當有業務服務系統中的推送數據寫入該模塊中的數據接收隊列MQ1時，從此隊列取出推送數據并存儲到本地的數據庫中形成推送任務，把推送任務唯一標識ID送入該模塊中的推送任務排隊隊列MQ2進行排隊；

推送數據分析及執行模塊：當有推送任務唯一標識ID寫入推送任務排隊隊列MQ2時，推送數據分析及執行模塊根據推送任務唯一標識ID查詢數據庫獲取推送數據以及相關的配置，并經分析和處理后，匹配出該推送數據需要推送到的目標客戶系統，根據與目標客戶系統的對接協議把推送數據轉換成對應的格式并發起一個HTTP請求，最后把推送數據推送給目標客戶系統，在發起HTTP請求時會啟用一個短時間多次即時重試機制；

推送延時重試模塊：用于監測推送數據分析及執行模塊的推送執行結果，當發起的HTTP請求返回成功，則更新本地的數據庫的數據并把此推送任務的狀態設為成功狀態，如果HTTP請求返回失敗或者請求響應超時，則更新本地的數據庫的數據并把此推送任務的狀態設為失敗狀態，同時把該推送任務進行長時間多次間隔的延時處理；

推送預警模塊：用于監測推送延時重試模塊是否有長時間多次間隔延時推送失敗的推送任務，若有則根據相關的配置，把該事件通過通訊方式發送給相關的處理人員。