[發(fā)明專利]基于消息路由方式的數(shù)據(jù)同步方法和系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201610180027.2
• 申請日: 2016-03-25
• 公開（公告）號(hào): CN107231313A
• 公開（公告）日: 2017-10-03
• 發(fā)明（設(shè)計(jì)）人: 黃亮
• 申請（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): H04L12/775
• 分類號(hào): H04L12/775;H04L12/863;H04L29/08;H04L12/721;G06Q10/08;G06Q50/28
• 代理公司: 北京成創(chuàng)同維知識(shí)產(chǎn)權(quán)代理有限公司11449
• 代理人: 蔡純,張靖琳

1.一種基于消息路由方式的數(shù)據(jù)同步方法，其中，包括如下步驟：

將目標(biāo)數(shù)據(jù)經(jīng)過數(shù)據(jù)路由系統(tǒng)從數(shù)據(jù)源系統(tǒng)轉(zhuǎn)發(fā)到與遠(yuǎn)程目標(biāo)系統(tǒng)對應(yīng)的消息隊(duì)列中；

所述消息隊(duì)列將所述目標(biāo)數(shù)據(jù)推送到對應(yīng)的遠(yuǎn)程目標(biāo)系統(tǒng)；和

所述遠(yuǎn)程目標(biāo)系統(tǒng)接收所述消息隊(duì)列推送的所述目標(biāo)數(shù)據(jù)，并寫入本地?cái)?shù)據(jù)庫中。

2.如權(quán)利要求1所述的基于消息路由方式的數(shù)據(jù)同步方法，其中，將目標(biāo)數(shù)據(jù)經(jīng)過數(shù)據(jù)路由系統(tǒng)從數(shù)據(jù)源系統(tǒng)轉(zhuǎn)發(fā)到與遠(yuǎn)程目標(biāo)系統(tǒng)對應(yīng)的消息隊(duì)列中之前還包括：

在消息中間件中建立與目標(biāo)系統(tǒng)匹配的消息隊(duì)列，并為每個(gè)消息隊(duì)列設(shè)置數(shù)據(jù)接口。

3.如權(quán)利要求2所述的基于消息路由方式的數(shù)據(jù)同步方法，其中，將目標(biāo)數(shù)據(jù)經(jīng)過數(shù)據(jù)路由系統(tǒng)從數(shù)據(jù)源系統(tǒng)轉(zhuǎn)發(fā)到與遠(yuǎn)程目標(biāo)系統(tǒng)對應(yīng)的消息隊(duì)列中，具體包括：

將目標(biāo)數(shù)據(jù)寫入與遠(yuǎn)程目標(biāo)系統(tǒng)對應(yīng)的消息隊(duì)列中；和

根據(jù)目標(biāo)系統(tǒng)和對應(yīng)的消息隊(duì)列，配置與其對應(yīng)的數(shù)據(jù)接口。

4.如權(quán)利要求3所述的基于消息路由方式的數(shù)據(jù)同步方法，其中，所述消息隊(duì)列將所述目標(biāo)數(shù)據(jù)推送到對應(yīng)的遠(yuǎn)程目標(biāo)系統(tǒng)，具體包括：

檢測所述消息隊(duì)列中是否有目標(biāo)數(shù)據(jù)，如果有需要推送的目標(biāo)數(shù)據(jù)，通過所述消息隊(duì)列的數(shù)據(jù)接口向?qū)?yīng)的目標(biāo)系統(tǒng)輸出所述的目標(biāo)數(shù)據(jù)。

5.如權(quán)利要求1所述的基于消息路由方式的數(shù)據(jù)同步方法，其中，所述目標(biāo)數(shù)據(jù)包括運(yùn)單數(shù)據(jù)，或所述遠(yuǎn)程目標(biāo)系統(tǒng)包括遠(yuǎn)程分揀中心。

6.如權(quán)利要求5所述的基于消息路由方式的數(shù)據(jù)同步方法，其中，所述運(yùn)單數(shù)據(jù)包括運(yùn)單號(hào)和至少一個(gè)目標(biāo)系統(tǒng)的標(biāo)識(shí)。

7.一種基于消息路由方式的數(shù)據(jù)同步系統(tǒng)，其中，包括：

消息中間件集群，用于為不同的目標(biāo)系統(tǒng)建立相應(yīng)的消息隊(duì)列，并將隊(duì)列中的目標(biāo)數(shù)據(jù)推送到相應(yīng)的目標(biāo)系統(tǒng)；

數(shù)據(jù)路由系統(tǒng)，與所述消息中間件集群相連接，用于將需要同步到 目標(biāo)系統(tǒng)的目標(biāo)數(shù)據(jù)從數(shù)據(jù)源系統(tǒng)轉(zhuǎn)發(fā)到所述消息中間件集群中對應(yīng)的消息隊(duì)列中；和

目標(biāo)系統(tǒng)，用于接收所述消息中間件集群推送的、與其對應(yīng)的消息隊(duì)列中的目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)寫入相應(yīng)的數(shù)據(jù)庫。

8.如權(quán)利要求7所述的基于消息路由方式的數(shù)據(jù)同步系統(tǒng)，其中，所述消息中間件集群包括：

多個(gè)消息隊(duì)列，分別與對應(yīng)的目標(biāo)系統(tǒng)連接，用于存放從數(shù)據(jù)源系統(tǒng)轉(zhuǎn)發(fā)的目標(biāo)數(shù)據(jù)；

消息中間件接口，與所述數(shù)據(jù)路由系統(tǒng)相連接，用于將數(shù)據(jù)路由系統(tǒng)轉(zhuǎn)發(fā)來的目標(biāo)數(shù)據(jù)寫入相應(yīng)的消息隊(duì)列；和

多個(gè)消息隊(duì)列數(shù)據(jù)接口，分別與對應(yīng)的消息隊(duì)列相連接，用于從對應(yīng)的消息隊(duì)列中取出目標(biāo)數(shù)據(jù)，并推送給相應(yīng)的目標(biāo)系統(tǒng)。

9.如權(quán)利要求7所述的基于消息路由方式的數(shù)據(jù)同步系統(tǒng)，其中，所述目標(biāo)系統(tǒng)至少為一個(gè)，且包括：

數(shù)據(jù)庫，用于存儲(chǔ)從數(shù)據(jù)源系統(tǒng)下發(fā)的目標(biāo)數(shù)據(jù)；和

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

10.如權(quán)利要求7所述的基于消息路由方式的數(shù)據(jù)同步系統(tǒng)，其中，還包括：

數(shù)據(jù)源系統(tǒng)，用于產(chǎn)生需要同步到目標(biāo)系統(tǒng)的目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)發(fā)送給數(shù)據(jù)路由系統(tǒng)。