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

在審

• 申請號: 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.如權利要求1所述的基于消息路由方式的數據同步方法，其中，將目標數據經過數據路由系統從數據源系統轉發到與遠程目標系統對應的消息隊列中之前還包括：

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

3.如權利要求2所述的基于消息路由方式的數據同步方法，其中，將目標數據經過數據路由系統從數據源系統轉發到與遠程目標系統對應的消息隊列中，具體包括：

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

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

4.如權利要求3所述的基于消息路由方式的數據同步方法，其中，所述消息隊列將所述目標數據推送到對應的遠程目標系統，具體包括：

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

5.如權利要求1所述的基于消息路由方式的數據同步方法，其中，所述目標數據包括運單數據，或所述遠程目標系統包括遠程分揀中心。

6.如權利要求5所述的基于消息路由方式的數據同步方法，其中，所述運單數據包括運單號和至少一個目標系統的標識。

7.一種基于消息路由方式的數據同步系統，其中，包括：

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

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

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

8.如權利要求7所述的基于消息路由方式的數據同步系統，其中，所述消息中間件集群包括：

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

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

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

9.如權利要求7所述的基于消息路由方式的數據同步系統，其中，所述目標系統至少為一個，且包括：

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

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

10.如權利要求7所述的基于消息路由方式的數據同步系統，其中，還包括：

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