[發(fā)明專利]數(shù)據(jù)同步方法及裝置、分布式系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201810290331.1
• 申請日: 2018-03-30
• 公開（公告）號: CN110324385A
• 公開（公告）日: 2019-10-11
• 發(fā)明（設(shè)計）人: 王俊松;浦世亮;周明耀
• 申請（專利權(quán)）人: 杭州海康威視數(shù)字技術(shù)股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/24
• 代理公司: 北京三高永信知識產(chǎn)權(quán)代理有限責(zé)任公司 11138
• 代理人: 韓東艷

本發(fā)明公開了一種數(shù)據(jù)同步方法及裝置、分布式系統(tǒng)，屬于安防監(jiān)控領(lǐng)域。所述方法包括：接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的當(dāng)前版本號；當(dāng)所述版本號高于所述第一計算節(jié)點存儲的第一版本號時，向所述數(shù)據(jù)存儲節(jié)點發(fā)送數(shù)據(jù)更新請求；接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的數(shù)據(jù)更新響應(yīng)；基于所述數(shù)據(jù)更新響應(yīng)，同步所述第一計算節(jié)點與所述數(shù)據(jù)存儲節(jié)點中的數(shù)據(jù)；當(dāng)同步成功時，將所述第一版本號更新為所述當(dāng)前版本號；當(dāng)同步失敗時，禁止所述第一版本號進(jìn)行更新。本發(fā)明通過第一版本號與當(dāng)前版本號，同步第一計算節(jié)點與數(shù)據(jù)存儲節(jié)點中的數(shù)據(jù)，使得各個計算節(jié)點中的數(shù)據(jù)保持一致。

技術(shù)領(lǐng)域

本發(fā)明涉及安防監(jiān)控領(lǐng)域，特別涉及一種數(shù)據(jù)同步方法及裝置、分布式系統(tǒng)。

背景技術(shù)

目前，在安防監(jiān)控領(lǐng)域中，可以采用人臉識別技術(shù)判斷視頻監(jiān)控區(qū)域中采集的目標(biāo)人臉信息是否與黑名單中的人臉信息匹配，該黑名單中的人臉信息可以為逃犯的人臉信息或偷盜者的人臉信息等，在判斷出目標(biāo)人臉信與黑名單中的人臉信息匹配后，對目標(biāo)人臉信息進(jìn)行報警，進(jìn)而可以由警察等人員對該目標(biāo)人臉信息對應(yīng)的人進(jìn)行抓捕。為了提高人臉識別技術(shù)的運算速度，上述人臉識別技術(shù)可以采用分布式系統(tǒng)實現(xiàn)。

例如，該分布式系統(tǒng)可以包括：數(shù)據(jù)存儲節(jié)點、服務(wù)管理節(jié)點和多個計算節(jié)點。其中，數(shù)據(jù)存儲節(jié)點中存儲有大量的經(jīng)過建模處理得到的人臉模型數(shù)據(jù)，可以將該人臉模型數(shù)據(jù)中的某些數(shù)據(jù)標(biāo)記在黑名單中。該數(shù)據(jù)存儲節(jié)點可以將人臉模型數(shù)據(jù)同步到每個計算節(jié)點，每個計算節(jié)點可以將這些人臉模型數(shù)據(jù)作為基礎(chǔ)數(shù)據(jù)使用。服務(wù)管理節(jié)點可以將人臉比對任務(wù)下發(fā)到多個計算節(jié)點中的空閑的計算節(jié)點中，該計算節(jié)點可以將人臉比對任務(wù)中的人臉信息分析后與計算節(jié)點中存儲的人臉模型數(shù)據(jù)進(jìn)行比對，進(jìn)而可以判斷出人臉分析任務(wù)中的人臉信息是否與黑面單中的數(shù)據(jù)對應(yīng)。

但是，若數(shù)據(jù)存儲節(jié)點中的某些數(shù)據(jù)進(jìn)行了更新，數(shù)據(jù)存儲節(jié)點會將更新的數(shù)據(jù)同步到每個計算節(jié)點中，若在同步的過程中，某個計算節(jié)點的數(shù)據(jù)同步失敗，該計算節(jié)點會丟失未同步的數(shù)據(jù)，最終會導(dǎo)致各個計算節(jié)點中的數(shù)據(jù)不一致。

發(fā)明內(nèi)容

本申請?zhí)峁┝艘环N數(shù)據(jù)同步方法及裝置、分布式系統(tǒng)，可以解決分布式系統(tǒng)中各個計算節(jié)點中的數(shù)據(jù)不一致問題。所述技術(shù)方案如下：

第一方面，提供了一種數(shù)據(jù)同步方法，應(yīng)用于分布式系統(tǒng)中的第一計算節(jié)點，所述分布式系統(tǒng)包括：數(shù)據(jù)存儲節(jié)點和多個計算節(jié)點，所述第一計算節(jié)點為所述多個計算節(jié)點中的任一計算節(jié)點，所述方法包括：

接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的當(dāng)前版本號，所述當(dāng)前版本號為所述數(shù)據(jù)存儲節(jié)點中存儲的數(shù)據(jù)更新后，所述數(shù)據(jù)存儲節(jié)點生成的版本號；

當(dāng)所述版本號高于所述第一計算節(jié)點存儲的第一版本號時，向所述數(shù)據(jù)存儲節(jié)點發(fā)送數(shù)據(jù)更新請求，所述數(shù)據(jù)更新請求中攜帶有所述第一版本號，所述數(shù)據(jù)更新請求用于請求所述第一版本號指示的數(shù)據(jù)與所述當(dāng)前版本號指示的數(shù)據(jù)同步；

接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的數(shù)據(jù)更新響應(yīng)，所述數(shù)據(jù)更新響應(yīng)基于所述第一版本號指示的數(shù)據(jù)與所述當(dāng)前版本號指示的數(shù)據(jù)中的區(qū)別數(shù)據(jù)生成；

基于所述數(shù)據(jù)更新響應(yīng)，同步所述第一計算節(jié)點與所述數(shù)據(jù)存儲節(jié)點中的數(shù)據(jù)；

當(dāng)同步成功時，將所述第一版本號更新為所述當(dāng)前版本號；

當(dāng)同步失敗時，禁止所述第一版本號進(jìn)行更新。

可選的，所述分布式系統(tǒng)還包括：服務(wù)管理節(jié)點，

所述接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的當(dāng)前版本號，包括：

接收所述服務(wù)管理節(jié)點從所述數(shù)據(jù)存儲節(jié)點獲取的所述當(dāng)前版本號；

和/或，

所述接收所述數(shù)據(jù)存儲節(jié)點發(fā)送的當(dāng)前版本號，包括：

周期性的向所述數(shù)據(jù)存儲節(jié)點發(fā)送版本號獲取請求；