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

在審

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

本發明公開了一種向外部系統推送數據并實現數據同步的方法，包括如下步驟：在推送數據接收及存儲模塊中，將推送數據存儲到本地的數據庫中形成推送任務，把推送任務ID送入推送任務排隊隊列MQ2；在推送數據分析及執行模塊中，根據推送任務ID查詢數據庫獲取推送數據以及相關的配置，經分析和處理后得到需要推送到的目標客戶系統，把推送數據轉換成對應的格式并發起一個HTTP請求，把推送數據推送給目標客戶系統；由推送延時重試模塊監測，如果HTTP請求返回失敗或者請求響應超時，把該推送任務進行長時間多次間隔的延時處理；由推送預警模塊監測是否有長時間多次間隔延時推送失敗的推送任務則發送給處理人員；本發明還公開了一種向外部系統推送數據并實現數據同步的系統。

技術領域

本發明涉及數據處理與數據通信領域，特別涉及一種向外部系統推送數據并實現數據同步的方法和系統。

背景技術

隨著互聯網+技術的發展，越來越多的行業已經互聯網化，越來越多的業務處理由線下轉為線上，這也就自然而然的產生了很多的線上業務系統。基本上來說，不管是企業、政府機構、社會組織等都會有和自己行業相關的應用系統，隨著市場需求或者自身發展的需要，企業與企業之間、企業與政府機構之間等會有大量業務的交互，這樣雙方的應用系統間也會有大量的數據交互。

雙方系統的數據交互不僅僅只涉及到系統之間相互的數據查詢調用，也會涉及到系統之間數據同步和回調通知；在業務合作的過程中，可能我方系統的某些業務數據需要同步給對方系統，也可能是對方系統的某些業務數據需要同步到我方系統，以實現雙方系統業務數據的一致性。

通常來說，雙方系統數據同步是通過HTTP接口調用的方式實現；傳統的處理方法中，我方系統和外部系統進行數據推送時，往往采用在業務系統內部直接調用外部系統接口的方式，即：業務系統在需要推送數據給外部系統時，直接在自身系統里發起HTTP請求，調用外部系統的接口，把數據直接推送給對方系統；而這種傳統的方法雖然比較直接，但是也有較大的風險，因為網絡請求和外部系統穩定性不可控的原因，業務系統向外部系統發起的HTTP請求不可能保證百分之百成功，這就涉及到請求失敗的這種異常情況的處理問題，如果此類問題不處理好，在后續業務合作進行中，將會產生很多雙方系統數據不一致的問題，也將增加雙方大量的后期維護成本。

但是這個問題對于業務系統來說還是比較麻煩，如果是業務系統直接發起HTTP請求調用外部系統的接口，很多的處理方式是若HTTP請求失敗都不會再進行重試，即使做了重試處理一般只會做到短時間內的即時重試幾次（比如2秒后重試一次，再失敗的話5秒后重試一次，還失敗的話10秒再重試一次，仍然失敗的話就只能打印失敗日志記錄了）。那這就因為推送未到達而造成雙方系統數據的不一致。

為解決上述技術問題，本發明旨在這一理念的基礎之上，提供了一種基于數據處理的向外部系統推送數據以實現雙方系統數據同步的方法和系統。

發明內容

有鑒于此，本發明的目的之一是提供一種向外部系統推送數據并實現數據同步的方法，其獨立于業務系統及客戶系統之外，在多次推送處理后能實現推送數據在業務系統和客戶系統間同步，本發明的目的之二是提供一種向外部系統推送數據并實現數據同步的系統。

本發明的目的之一是通過以下技術方案實現的：

一種向外部系統推送數據并實現數據同步的方法，包括如下步驟：

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