[發(fā)明專利]一種集群間跨機(jī)房同步的方法和裝置

在審

• 申請?zhí)枺?/td>: 201611200103.8
• 申請日: 2016-12-22
• 公開（公告）號: CN108228397A
• 公開（公告）日: 2018-06-29
• 發(fā)明（設(shè)計(jì)）人: 張宏濤
• 申請（專利權(quán)）人: 深圳市優(yōu)朋普樂傳媒發(fā)展有限公司
• 主分類號: G06F11/20
• 分類號: G06F11/20;G06F11/16;G06F9/44;G06F9/54
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種集群間跨機(jī)房同步的方法，其特征在于，包括：

位于第一機(jī)房的第一同步系統(tǒng)在實(shí)時(shí)同步狀態(tài)下，實(shí)時(shí)向位于第二機(jī)房的第二同步系統(tǒng)發(fā)送增量數(shù)據(jù)；

在發(fā)送所述增量數(shù)據(jù)失敗時(shí)，所述第一同步系統(tǒng)進(jìn)入延時(shí)同步狀態(tài)，以及將所述增量數(shù)據(jù)寫入到增量同步隊(duì)列中。

2.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

所述第一同步系統(tǒng)從所述增量同步隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)；

所述第一同步系統(tǒng)將所述增量數(shù)據(jù)寫入到增量同步隊(duì)列中，包括：

所述第一同步系統(tǒng)確定所述增量同步隊(duì)列所處的狀態(tài)；

所述第一同步系統(tǒng)基于所述增量同步隊(duì)列所處的狀態(tài)，將所述增量數(shù)據(jù)寫入到所述增量同步隊(duì)列中；

所述第一同步系統(tǒng)從所述增量同步隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)，包括：

所述第一同步系統(tǒng)確定所述增量同步隊(duì)列所處的狀態(tài)；

所述第一同步系統(tǒng)基于所述增量同步隊(duì)列所處的狀態(tài)，從所述增量同步隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)。

3.如權(quán)利要求2所述的方法，其特征在于，所述增量同步隊(duì)列包括普通隊(duì)列和后備隊(duì)列；

所述第一同步系統(tǒng)確定所述增量同步隊(duì)列所處的狀態(tài)，包括：

若所述后備隊(duì)列中沒有存儲任何數(shù)據(jù)且所述第一機(jī)房與所述第二機(jī)房間心跳失敗次數(shù)小于預(yù)設(shè)閾值時(shí)，確定所述增量同步隊(duì)列所處的狀態(tài)為正常狀態(tài)；

若所述第一機(jī)房與所述第二機(jī)房間心跳失敗次數(shù)達(dá)到所述預(yù)設(shè)閾值時(shí)，確定所述增量同步隊(duì)列所處的狀態(tài)為后備狀態(tài)；

所述第一同步系統(tǒng)基于所述增量同步隊(duì)列所處的狀態(tài)，將所述增量數(shù)據(jù)寫入到所述增量同步隊(duì)列中，包括：

在所述增量同步隊(duì)列所處的狀態(tài)為正常狀態(tài)時(shí)，將所述增量數(shù)據(jù)寫入到所述普通隊(duì)列中；

在所述增量同步隊(duì)列所處的狀態(tài)為后備狀態(tài)時(shí)，將所述增量數(shù)據(jù)寫入到所述后備隊(duì)列中。

4.如權(quán)利要求3所述的方法，其特征在于，所述增量同步隊(duì)列還包括前沿隊(duì)列；

所述第一同步系統(tǒng)確定所述增量同步隊(duì)列所處的狀態(tài)，還包括：

若從所述增量同步隊(duì)列中讀取數(shù)據(jù)發(fā)送到所述第二同步系統(tǒng)的操作失敗時(shí)，將同步的所述增量數(shù)據(jù)寫入到所述第一機(jī)房的前沿隊(duì)列中，確定所述增量同步隊(duì)列所處的狀態(tài)為前沿狀態(tài)；

若從所述前沿隊(duì)列中獲取數(shù)據(jù)發(fā)送到所述第二同步系統(tǒng)的操作成功且所述前沿隊(duì)列中無數(shù)據(jù)時(shí)，確定所述增量同步隊(duì)列所處的狀態(tài)為非前沿狀態(tài)；

所述第一同步系統(tǒng)基于所述增量同步隊(duì)列所處的狀態(tài)，從所述增量同步隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)，包括：

在所述增量同步隊(duì)列所處的狀態(tài)為前沿狀態(tài)時(shí)，從所述前沿隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)；

在所述增量同步隊(duì)列所處的狀態(tài)為非前沿狀態(tài)時(shí)，先從所述普通隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)，在所述普通隊(duì)列中無數(shù)據(jù)時(shí)，再從所述后備隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)。

5.如權(quán)利要求3或4所述的方法，其特征在于，在所述增量同步隊(duì)列所處的狀態(tài)為后備狀態(tài)時(shí)，所述方法還包括：

從所述后備隊(duì)列中讀取設(shè)定數(shù)量的數(shù)據(jù)執(zhí)行合并操作，并寫入所述普通隊(duì)列；和/或，

對所述普通隊(duì)列中設(shè)定數(shù)量的數(shù)據(jù)執(zhí)行合并操作。

6.如權(quán)利要求1所述的方法，其特征在于，所述第一同步系統(tǒng)將所述增量數(shù)據(jù)寫入到增量同步隊(duì)列中，包括：

所述第一同步系統(tǒng)將所述增量數(shù)據(jù)對應(yīng)的更改動作和對應(yīng)的索引鍵值和數(shù)據(jù)鍵值寫入到所述增量同步隊(duì)列中。

7.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

所述第一同步系統(tǒng)從所述增量同步隊(duì)列中讀取數(shù)據(jù)同步到所述第二同步系統(tǒng)；

在所述增量同步隊(duì)列中無數(shù)據(jù)時(shí)，所述第一同步系統(tǒng)進(jìn)入實(shí)時(shí)同步狀態(tài)。

8.如權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

從所述增量同步隊(duì)列中讀取數(shù)據(jù)并確定所述讀取的數(shù)據(jù)對應(yīng)的順序編號，按照順序編號的排列順序依次同步讀取的數(shù)據(jù)到所述第二同步系統(tǒng)。