[發明專利]一種跨機房數據庫同步方法及系統

在審

• 申請號: 201210400979.2
• 申請日: 2012-10-19
• 公開（公告）號: CN103778136A
• 公開（公告）日: 2014-05-07
• 發明（設計）人: 樓江航
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F11/14
• 代理公司: 杭州天勤知識產權代理有限公司 33224
• 代理人: 楊天嬌

1.一種跨機房數據庫同步方法，用于目標數據庫跨機房的從源數據庫同步數據，其特征在于，包括如下步驟：

步驟100、在源數據庫端監聽源數據庫的變更；

步驟110、利用多個順序編號的并行進程依次提取源數據庫的變更數據；

步驟120、各個并行進程將提取到的數據經合并、壓縮后進行發送；

步驟130、在目標數據庫端接收各個并行進程發送的數據，按照各并行進程的次序進行加載得到待同步數據，利用該待同步數據更新目標數據庫。

2.如權利要求1所述的跨機房數據庫同步方法，其特征在于，步驟100中，所述源數據庫的變更為Insert、Update、Delete至少一種事件的觸發。

3.如權利要求1所述的跨機房數據庫同步方法，其特征在于，步驟110具體包括：

步驟111、開啟多個并行進程并對每個并行進程賦以編號；

步驟112、各個并行進程按照編號依次提取源數據庫的變更數據，且在提取的同時進行解析得到若干內部對象，即步驟120所述的提取到的數據。

4.如權利要求3所述的跨機房數據庫同步方法，其特征在于，步驟112中，通過與源數據庫相匹配的協議格式解析得到所述內部對象，該內部對象的數據結構包括事件類型、主鍵信息和變更字段。

5.如權利要求4所述的跨機房數據庫同步方法，其特征在于，步驟120中，所述的合并包括：

步驟121、同一并行進程中，將主鍵信息相同的內部對象構建為子鏈表；

步驟122、將同屬一個子鏈表的所有內部對象按照對應的變更字段依次進行運算，處理得到合并后的內部對象。

6.一種跨機房數據庫同步系統，用于目標數據庫跨機房的從源數據庫同步數據，其特征在于，包括：

監聽模塊，用于在源數據庫端監聽源數據庫的變更；

提取模塊，用于利用多個順序編號的并行進程依次提取源數據庫的變更數據；

數據處理模塊，用于各個并行進程將提取到的數據經合并、壓縮后進行發送；

接收模塊，用于在目標數據庫端接收各個并行進程發送的數據，按照各并行進程的次序進行加載得到待同步數據，利用該待同步數據更新目標數據庫。

7.如權利要求6所述的跨機房數據庫同步系統，其特征在于，所述監聽模塊中，源數據庫的變更為Insert、Update、Delete至少一種事件的觸發。

8.如權利要求6所述的跨機房數據庫同步系統，其特征在于，所述提取模塊包括：

進程啟動模塊，用于開啟多個并行進程并對每個并行進程賦以編號；

解析模塊，用于各個并行進程按照編號依次提取源數據庫的變更數據，且在提取的同時進行解析得到若干內部對象，即數據處理模塊中所述的提取到的數據。

9.如權利要求8所述的跨機房數據庫同步系統，其特征在于，所述解析模塊，通過與源數據庫相匹配的協議格式解析得到所述內部對象，該內部對象的數據結構包括事件類型、主鍵信息和變更字段。

10.如權利要求9所述的跨機房數據庫同步系統，其特征在于，所述數據處理模塊包括依次對提取到的數據進行相應處理的合并模塊、壓縮模塊和發送模塊，其中所述合并模塊包括：

建子鏈表模塊，用于同一并行進程中，將主鍵信息相同的內部對象構建為子鏈表；

運算合并模塊，用于將同屬一個子鏈表的所有內部對象按照對應的變更字段依次進行運算，處理得到合并后的內部對象。