[發(fā)明專利]數(shù)據(jù)同步方法及裝置

有效

• 申請?zhí)枺?/td>: 201310032868.5
• 申請日: 2013-01-28
• 公開（公告）號: CN103973727B
• 公開（公告）日: 2019-03-19
• 發(fā)明（設(shè)計）人: 彭勇;羅皓;郭振宇
• 申請（專利權(quán)）人: 深圳市騰訊計算機(jī)系統(tǒng)有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L1/00
• 代理公司: 北京三高永信知識產(chǎn)權(quán)代理有限責(zé)任公司 11138
• 代理人: 關(guān)文魁

1.一種數(shù)據(jù)同步方法，其特征在于，所述方法包括：

將源數(shù)據(jù)中的一數(shù)據(jù)塊同步至副本數(shù)據(jù)；檢測所述數(shù)據(jù)塊是否同步失?。?/p>

若檢測出所述數(shù)據(jù)塊同步失敗，則根據(jù)所述數(shù)據(jù)塊對應(yīng)的數(shù)據(jù)標(biāo)識生成一條失敗記錄；將生成的所述失敗記錄添加至同步失敗流水；繼續(xù)將所述源數(shù)據(jù)中的下一未同步的數(shù)據(jù)塊同步至所述副本數(shù)據(jù)；

所述失敗記錄中包含有記錄時間；在對同步失敗的數(shù)據(jù)塊進(jìn)行重新同步之前，提取數(shù)據(jù)標(biāo)識相同的失敗記錄中，所述記錄時間與當(dāng)前時間最接近的一條失敗記錄；

將提取的所述失敗記錄中的數(shù)據(jù)標(biāo)識添加入失敗數(shù)據(jù)標(biāo)識列表；在后續(xù)的一預(yù)定時間點(diǎn)提取所述失敗數(shù)據(jù)標(biāo)識列表，所述預(yù)定時間點(diǎn)為預(yù)先設(shè)定的具體時間點(diǎn)、根據(jù)預(yù)定周期確定的時間點(diǎn)或者根據(jù)網(wǎng)絡(luò)條件確定的時間點(diǎn)；

根據(jù)所述失敗數(shù)據(jù)標(biāo)識列表中的數(shù)據(jù)標(biāo)識判斷所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中是否存在；

若判斷出所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中存在，則將所述源數(shù)據(jù)中存在的所述同步失敗的數(shù)據(jù)塊重新同步至所述副本數(shù)據(jù)；若判斷出所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中不存在，則將所述副本數(shù)據(jù)中的所述同步失敗的數(shù)據(jù)塊刪除；

在將所述源數(shù)據(jù)中存在的所述同步失敗的數(shù)據(jù)塊重新同步至所述副本數(shù)據(jù)后，刪除所述同步失敗流水；

所述方法還包括：

當(dāng)開始對所述數(shù)據(jù)塊進(jìn)行同步時，將所述副本數(shù)據(jù)的狀態(tài)標(biāo)記設(shè)置為不可用狀態(tài)；

當(dāng)同步完成，且檢測到所述源數(shù)據(jù)中所有數(shù)據(jù)塊都與所述副本數(shù)據(jù)同步成功時，將所述副本數(shù)據(jù)的狀態(tài)標(biāo)記設(shè)置為可用狀態(tài)。

2.一種數(shù)據(jù)同步裝置，其特征在于，所述裝置包括：

第一同步模塊，用于將源數(shù)據(jù)中的一數(shù)據(jù)塊同步至副本數(shù)據(jù)；

檢測模塊，用于檢測所述第一同步模塊同步的數(shù)據(jù)塊是否同步失?。?/p>

流水記錄模塊，包括：

記錄生成單元，用于根據(jù)所述數(shù)據(jù)塊對應(yīng)的數(shù)據(jù)標(biāo)識生成一條失敗記錄；

記錄添加單元，用于將所述記錄生成單元生成的失敗記錄添加至同步失敗流水；

所述第一同步模塊，用于在將源數(shù)據(jù)中的一數(shù)據(jù)塊同步至副本數(shù)據(jù)之后，繼續(xù)將所述源數(shù)據(jù)中的下一未同步的數(shù)據(jù)塊同步至所述副本數(shù)據(jù)；

用于在對同步失敗的數(shù)據(jù)塊進(jìn)行重新同步之前，對所述同步失敗流水中數(shù)據(jù)標(biāo)識相同的失敗記錄進(jìn)行合并，得到失敗數(shù)據(jù)標(biāo)識列表的模塊；

第二同步模塊，用于在后續(xù)的一預(yù)定時間點(diǎn)根據(jù)所述失敗數(shù)據(jù)標(biāo)識列表對所述數(shù)據(jù)塊進(jìn)行重新同步；

所述失敗記錄中還包含有記錄時間；所述用于在對同步失敗的數(shù)據(jù)塊進(jìn)行重新同步之前，對所述同步失敗流水中數(shù)據(jù)標(biāo)識相同的失敗記錄進(jìn)行合并，得到失敗數(shù)據(jù)標(biāo)識列表的模塊，包括：

記錄提取單元，用于提取數(shù)據(jù)標(biāo)識相同的失敗記錄中，所述記錄時間與當(dāng)前時間最接近的一條失敗記錄；

列表添加單元，用于將所述記錄提取單元提取的所述失敗記錄中的數(shù)據(jù)標(biāo)識添加入所述失敗數(shù)據(jù)標(biāo)識列表；

所述第二同步模塊包括：

流水提取單元，用于在后續(xù)的一預(yù)定時間點(diǎn)提取所述失敗數(shù)據(jù)標(biāo)識列表，所述預(yù)定時間點(diǎn)為預(yù)先設(shè)定的具體時間點(diǎn)、根據(jù)預(yù)定周期確定的時間點(diǎn)或者根據(jù)網(wǎng)絡(luò)條件確定的時間點(diǎn)；

同步單元，用于根據(jù)所述失敗數(shù)據(jù)標(biāo)識列表中的數(shù)據(jù)標(biāo)識，對所述同步失敗的數(shù)據(jù)塊進(jìn)行重新同步；

所述同步單元包括：

判斷子單元，用于根據(jù)所述失敗數(shù)據(jù)標(biāo)識列表中的數(shù)據(jù)標(biāo)識判斷所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中是否存在；

同步子單元，用于若所述判斷子單元判斷出所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中存在，則將所述源數(shù)據(jù)中存在的所述同步失敗的數(shù)據(jù)塊重新同步至所述副本數(shù)據(jù)；

刪除子單元，用于若所述判斷子單元判斷出所述同步失敗的數(shù)據(jù)塊在所述源數(shù)據(jù)中不存在，則將所述副本數(shù)據(jù)中的所述同步失敗的數(shù)據(jù)塊刪除；

所述同步單元還包括用于在將所述源數(shù)據(jù)中存在的所述同步失敗的數(shù)據(jù)塊重新同步至所述副本數(shù)據(jù)后，刪除所述同步失敗流水的子單元；

所述裝置還包括用于執(zhí)行以下操作的模塊：

當(dāng)開始對所述數(shù)據(jù)塊進(jìn)行同步時，將所述副本數(shù)據(jù)的狀態(tài)標(biāo)記設(shè)置為不可用狀態(tài)；

當(dāng)同步完成，且檢測到所述源數(shù)據(jù)中所有數(shù)據(jù)塊都與所述副本數(shù)據(jù)同步成功時，將所述副本數(shù)據(jù)的狀態(tài)標(biāo)記設(shè)置為可用狀態(tài)。

3.一種計算機(jī)可讀存儲介質(zhì)，其特征在于，所述計算機(jī)可讀存儲介質(zhì)中存儲有程序，所述程序用于實(shí)現(xiàn)如權(quán)利要求1所述的數(shù)據(jù)同步方法。