[發明專利]基于消息路由方式的數據同步方法和系統

在審

• 申請號: 201610180027.2
• 申請日: 2016-03-25
• 公開（公告）號: CN107231313A
• 公開（公告）日: 2017-10-03
• 發明（設計）人: 黃亮
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L12/775
• 分類號: H04L12/775;H04L12/863;H04L29/08;H04L12/721;G06Q10/08;G06Q50/28
• 代理公司: 北京成創同維知識產權代理有限公司11449
• 代理人: 蔡純,張靖琳

技術領域

本發明涉及數據處理技術領域，具體地說，涉及一種基于消息路由方式的數據同步方法和系統。

背景技術

在電商配送訂單包裹過程中，需要由中心交易平臺將此訂單的運單信息下發到包裹經過的分揀中心。這樣每個分揀中心才能知道包裹的去向，從而快速分揀。因而，分揀中心的系統及時、快速地獲得運單數據成為了準確分揀包裹的關鍵。

發明內容

本發明要解決的技術問題在于，針對現有技術的不足，提供一種基于消息路由方式的數據同步方法和系統，用于解決現有技術中不同系統間的數據同步成本高、可靠性差的問題。

為了解決上述技術問題，根據本發明的一個方面，本發明提供了一種基于消息路由方式的數據同步方法，其中，包括如下步驟：

將目標數據經過數據路由系統從數據源系統轉發到與遠程目標系統對應的消息隊列中；

所述消息隊列將所述目標數據推送到對應的遠程目標系統；和

所述遠程目標系統接收所述消息隊列推送的所述目標數據，并寫入本地數據庫中。

優選地，將目標數據經過數據路由系統從數據源系統轉發到與遠程目標系統對應的消息隊列中之前還包括：

在消息中間件中建立與目標系統匹配的消息隊列，并為每個消息隊列設置數據接口。

優選地，將目標數據經過數據路由系統從數據源系統轉發到與遠程目標系統對應的消息隊列中，具體包括：

將目標數據寫入與遠程目標系統對應的消息隊列中；和

根據目標系統和對應的消息隊列，配置與其對應的數據接口。

優選地，所述消息隊列將所述目標數據推送到對應的遠程目標系統，具體包括：

檢測所述消息隊列中是否有目標數據，如果有需要推送的目標數據，通過所述消息隊列的數據接口向對應的目標系統輸出所述的目標數據。

優選地，所述目標數據包括運單數據，或所述遠程目標系統包括遠程分揀中心。

優選地，所述運單數據包括運單號和至少一個目標系統的數據。

為了解決上述技術問題，根據本發明的另一個方面，本發明提供了一種基于消息路由方式的數據同步系統，其中，包括：

消息中間件集群，用于為不同的目標系統建立相應的消息隊列，并將隊列中的目標數據推送到相應的目標系統；

數據路由系統，與所述消息中間件集群相連接，用于將需要同步到目標系統的目標數據從數據源系統轉發到所述消息中間件集群中對應的消息隊列中；和

目標系統，用于接收所述消息中間件集群推送的、與其對應的消息隊列中的目標數據，并將所述目標數據寫入相應的數據庫。

優選地，所述消息中間件集群包括：

多個消息隊列，分別與對應的目標系統連接，用于存放從數據源系統轉發的目標數據；

消息中間件接口，與所述數據路由系統相連接，用于將數據路由系統轉發來的目標數據寫入相應的消息隊列；和

多個消息隊列數據接口，分別與對應的消息隊列相連接，用于從對應的消息隊列中取出目標數據，并推送給相應的目標系統。

優選地，所述目標系統至少為一個，且包括：

數據庫，用于存儲從數據源系統下發的目標數據；和

數據接口，與所述數據庫相連接，用于接收所述消息中間件集群推 送的目標數據，并將其寫入到所述數據庫中。

優選地，基于消息路由方式的數據同步系統還包括：

數據源系統，用于產生需要同步到目標系統的目標數據，并將所述目標數據發送給數據路由系統。

本發明通過消息中間件自身所具有的消息消費失敗重試功能，可以在網絡波動后繼續從中斷點傳輸運單數據，保證數據不丟失。即使出現數據庫物理機損壞的情況下，也能在新機數據庫啟動后從斷點續傳數據，提高了數據同步的可靠性。

通過消息中間件集群上的多個區域的消息隊列代替進行數據庫復制的機器，有效降低系統部署成本。

附圖說明

通過參照以下附圖對本發明實施例的描述，本發明的上述以及其它目的、特征和優點將更為清楚，在附圖中：

圖1為現有技術中數據同步的原理結構示意圖；

圖2為本發明所述基于消息路由方式的數據同步系統的原理結構示意圖；

圖3為本發明所述基于消息路由方式的數據同步方法的流程圖；

圖4為本發明所述基于消息路由方式的數據同步系統一實施例的原理結構示意圖；

圖5為本發明所述基于消息路由方式的數據同步方法的實施例的流程圖；和