[發(fā)明專利]基于MariaDB的跨機(jī)房數(shù)據(jù)庫(kù)同步設(shè)備及方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201510323288.0
• 申請(qǐng)日: 2015-06-12
• 公開(kāi)（公告）號(hào): CN104933127A
• 公開(kāi)（公告）日: 2015-09-23
• 發(fā)明（設(shè)計(jì)）人: 沈陳樂(lè);閆國(guó)旗
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 任巖

1.一種基于MariaDB的跨機(jī)房數(shù)據(jù)庫(kù)同步設(shè)備，其特征在于，該設(shè)備包括：

源數(shù)據(jù)庫(kù)監(jiān)聽(tīng)捕捉裝置，用于對(duì)源數(shù)據(jù)庫(kù)進(jìn)行監(jiān)聽(tīng)，獲取數(shù)據(jù)事件記錄隊(duì)列；

數(shù)據(jù)事件處理裝置，用于對(duì)獲取的數(shù)據(jù)事件記錄隊(duì)列進(jìn)行合并和壓縮，生成數(shù)據(jù)事件更新記錄包；

數(shù)據(jù)事件分發(fā)裝置，用于將所述數(shù)據(jù)事件更新記錄包分發(fā)到各個(gè)目標(biāo)數(shù)據(jù)庫(kù)；以及

目標(biāo)數(shù)據(jù)庫(kù)同步執(zhí)行裝置，用于根據(jù)收到的數(shù)據(jù)事件更新記錄包，對(duì)目標(biāo)數(shù)據(jù)庫(kù)進(jìn)行同步操作。

2.根據(jù)權(quán)利要求1所述的設(shè)備，其特征在于，所述源數(shù)據(jù)庫(kù)監(jiān)聽(tīng)捕捉裝置采用socket服務(wù)對(duì)所述源數(shù)據(jù)庫(kù)進(jìn)行監(jiān)聽(tīng)，獲取涉及到數(shù)據(jù)變化的數(shù)據(jù)事件記錄隊(duì)列。

3.根據(jù)權(quán)利要求1所述的設(shè)備，在所述數(shù)據(jù)事件分發(fā)裝置遇到網(wǎng)絡(luò)阻塞時(shí)，執(zhí)行重新分發(fā)的操作。

4.根據(jù)權(quán)利要求1所述的設(shè)備，其特征在于，所述數(shù)據(jù)事件記錄隊(duì)列包括多個(gè)按時(shí)間順序排列的數(shù)據(jù)事件，每個(gè)數(shù)據(jù)事件至少包括數(shù)據(jù)事件類型、數(shù)據(jù)事件主鍵信息及數(shù)據(jù)事件變更信息。

5.根據(jù)權(quán)利要求4所述的設(shè)備，其特征在于，所述數(shù)據(jù)事件處理裝置按照所述數(shù)據(jù)事件主鍵信息，將所述數(shù)據(jù)事件記錄隊(duì)列分為一個(gè)或多個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列，其中，每個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列中數(shù)據(jù)事件的數(shù)據(jù)事件主鍵信息相同，將每個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列中的數(shù)據(jù)事件進(jìn)行合并，獲得相應(yīng)的主鍵數(shù)據(jù)事件更新記錄，將所有主鍵數(shù)據(jù)事件更新記錄進(jìn)行合并，獲得數(shù)據(jù)事件更新記錄，對(duì)所述數(shù)據(jù)事件更新記錄進(jìn)行壓縮，生成數(shù)據(jù)事件更新記錄包。

6.根據(jù)權(quán)利要求5所述的設(shè)備，其特征在于，按照所述時(shí)間順序，對(duì)所述數(shù)據(jù)事件進(jìn)行合并。

7.根據(jù)權(quán)利要求5所述的設(shè)備，其特征在于，采用數(shù)據(jù)操作語(yǔ)言DML中的插入語(yǔ)句Insert、刪除語(yǔ)句Delete和/或更新語(yǔ)句Update進(jìn)行數(shù)據(jù)事件合并。

8.根據(jù)權(quán)利要求5所述的設(shè)備，其特征在于，在對(duì)所述數(shù)據(jù)事件進(jìn)行合并時(shí)，將所述數(shù)據(jù)事件類型相同的數(shù)據(jù)事件進(jìn)行合并。

9.根據(jù)權(quán)利要求5所述的設(shè)備，其特征在于，所述目標(biāo)數(shù)據(jù)庫(kù)同步執(zhí)行裝置對(duì)所述數(shù)據(jù)事件更新記錄包進(jìn)行解壓縮，獲取所述數(shù)據(jù)事件更新記錄，根據(jù)所述數(shù)據(jù)事件更新記錄，完成所述目標(biāo)數(shù)據(jù)庫(kù)的同步操作。

10.一種基于MariaDB的跨機(jī)房數(shù)據(jù)庫(kù)同步方法，其特征在于，該方法包括：

S1，對(duì)源數(shù)據(jù)庫(kù)進(jìn)行監(jiān)聽(tīng)，獲取數(shù)據(jù)事件記錄隊(duì)列；

S2，對(duì)獲取的數(shù)據(jù)事件記錄隊(duì)列進(jìn)行合并和壓縮，生成數(shù)據(jù)事件更新記錄包；

S3，將所述數(shù)據(jù)事件更新記錄包分發(fā)到各個(gè)目標(biāo)數(shù)據(jù)庫(kù)；

S4，根據(jù)收到的數(shù)據(jù)事件更新記錄包，對(duì)目標(biāo)數(shù)據(jù)庫(kù)進(jìn)行同步操作。

11.根據(jù)權(quán)利要求10所述的方法，其特征在于，在所述S1中，采用socket服務(wù)對(duì)所述源數(shù)據(jù)庫(kù)進(jìn)行監(jiān)聽(tīng)，獲取涉及到數(shù)據(jù)變化的數(shù)據(jù)事件記錄隊(duì)列。

12.根據(jù)權(quán)利要求10所述的方法，其特征在于，在所述S3中，在遇到網(wǎng)絡(luò)阻塞時(shí)，執(zhí)行重新分發(fā)的操作。

13.根據(jù)權(quán)利要求10所述的方法，其特征在于，所述數(shù)據(jù)事件記錄隊(duì)列包括多個(gè)按時(shí)間順序排列的數(shù)據(jù)事件，每個(gè)數(shù)據(jù)事件至少包括數(shù)據(jù)事件類型、數(shù)據(jù)事件主鍵信息及數(shù)據(jù)事件變更信息。

14.根據(jù)權(quán)利要求13所述的方法，其特征在于，在所述S2中，按照所述數(shù)據(jù)事件主鍵信息，將所述數(shù)據(jù)事件記錄隊(duì)列分為一個(gè)或多個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列，其中，每個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列中數(shù)據(jù)事件的數(shù)據(jù)事件主鍵信息相同，將每個(gè)主鍵數(shù)據(jù)事件記錄隊(duì)列中的數(shù)據(jù)事件進(jìn)行合并，獲得相應(yīng)的主鍵數(shù)據(jù)事件更新記錄，將所有主鍵數(shù)據(jù)事件更新記錄進(jìn)行合并，獲得數(shù)據(jù)事件更新記錄，對(duì)所述數(shù)據(jù)事件更新記錄進(jìn)行壓縮，生成數(shù)據(jù)事件更新記錄包。

15.根據(jù)權(quán)利要求14所述的方法，其特征在于，按照所述時(shí)間順序，對(duì)所述數(shù)據(jù)事件進(jìn)行合并。

16.根據(jù)權(quán)利要求14所述的方法，其特征在于，采用數(shù)據(jù)操作語(yǔ)言DML中的插入語(yǔ)句Insert、刪除語(yǔ)句Delete和/或更新語(yǔ)句Update進(jìn)行數(shù)據(jù)事件合并。

17.根據(jù)權(quán)利要求14所述的方法，其特征在于，在對(duì)所述數(shù)據(jù)事件進(jìn)行合并時(shí)，將所述數(shù)據(jù)事件類型相同的數(shù)據(jù)事件進(jìn)行合并。

18.根據(jù)權(quán)利要求14所述的方法，其特征在于，在所述S4中，對(duì)所述數(shù)據(jù)事件更新記錄包進(jìn)行解壓縮，獲取所述數(shù)據(jù)事件更新記錄，根據(jù)所述數(shù)據(jù)事件更新記錄，完成所述目標(biāo)數(shù)據(jù)庫(kù)的同步操作。