[發(fā)明專(zhuān)利]一種數(shù)據(jù)同步方法及服務(wù)節(jié)點(diǎn)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010973163.3
• 申請(qǐng)日: 2020-09-16
• 公開(kāi)（公告）號(hào): CN112069266A
• 公開(kāi)（公告）日: 2020-12-11
• 發(fā)明（設(shè)計(jì)）人: 嚴(yán)文;李先極;何國(guó)澤
• 申請(qǐng)（專(zhuān)利權(quán)）人: 青島海信智慧家居系統(tǒng)股份有限公司
• 主分類(lèi)號(hào): G06F16/27
• 分類(lèi)號(hào): G06F16/27;G06F16/23;G06F9/54
• 代理公司: 北京同達(dá)信恒知識(shí)產(chǎn)權(quán)代理有限公司 11291
• 代理人: 任嘉文

本申請(qǐng)?zhí)峁┮环N數(shù)據(jù)同步方法及服務(wù)節(jié)點(diǎn)，適用于包括多個(gè)服務(wù)節(jié)點(diǎn)的分布式系統(tǒng)，多個(gè)服務(wù)節(jié)點(diǎn)共享數(shù)據(jù)庫(kù)；第一服務(wù)節(jié)點(diǎn)在接收到數(shù)據(jù)同步指令后，確定分布式系統(tǒng)中是否加載有同步鎖；在確定無(wú)同步鎖時(shí)，將生成的同步鎖加載至分布式系統(tǒng)；從數(shù)據(jù)中心拉取待同步數(shù)據(jù)并對(duì)數(shù)據(jù)庫(kù)進(jìn)行更新。該方式當(dāng)分布式系統(tǒng)中確定有一服務(wù)節(jié)點(diǎn)已經(jīng)在執(zhí)行數(shù)據(jù)同步的行為時(shí)，通過(guò)為分布式系統(tǒng)設(shè)置同步鎖，從而在有其他的服務(wù)節(jié)點(diǎn)接收到數(shù)據(jù)同步的指令時(shí)，并確定分布式系統(tǒng)已經(jīng)存在有同步鎖后，則這些服務(wù)節(jié)點(diǎn)將跳過(guò)執(zhí)行數(shù)據(jù)同步的行為，直接進(jìn)入非數(shù)據(jù)同步的工作狀態(tài)，如此可避免在同一個(gè)分布式系統(tǒng)中，由于同時(shí)有至少兩個(gè)服務(wù)節(jié)點(diǎn)進(jìn)行數(shù)據(jù)同步時(shí)而帶來(lái)的資源浪費(fèi)現(xiàn)象。

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

本申請(qǐng)實(shí)施例涉及數(shù)據(jù)分析技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)同步方法及服務(wù)節(jié)點(diǎn)。

背景技術(shù)

分布式系統(tǒng)是一個(gè)硬件或軟件組件分布在不同的網(wǎng)絡(luò)計(jì)算機(jī)上，彼此之間通過(guò)消息傳遞進(jìn)行通信和協(xié)調(diào)的系統(tǒng)。分布式系統(tǒng)中包括多個(gè)地位平等，沒(méi)有主從之分的服務(wù)節(jié)點(diǎn)。各服務(wù)節(jié)點(diǎn)執(zhí)行相同或不同任務(wù)。通過(guò)采用分布式系統(tǒng)，可以有效避免單點(diǎn)故障的問(wèn)題。

在分布式系統(tǒng)中各服務(wù)節(jié)點(diǎn)共享數(shù)據(jù)庫(kù)時(shí)，存在數(shù)據(jù)庫(kù)重復(fù)寫(xiě)入的問(wèn)題。以監(jiān)控場(chǎng)景為例，由于分布式系統(tǒng)中存在執(zhí)行相同任務(wù)的多個(gè)服務(wù)節(jié)點(diǎn)，因而任一服務(wù)節(jié)點(diǎn)在設(shè)定條件下將從數(shù)據(jù)中心主動(dòng)獲取各設(shè)備的狀態(tài)數(shù)據(jù)，與此同時(shí)，該服務(wù)節(jié)點(diǎn)還會(huì)從與之連接的數(shù)據(jù)庫(kù)中獲取各設(shè)備的狀態(tài)數(shù)據(jù)，從而，該服務(wù)節(jié)點(diǎn)通過(guò)將從數(shù)據(jù)中心獲取的各設(shè)備的狀態(tài)數(shù)據(jù)與從數(shù)據(jù)庫(kù)中獲取的各設(shè)備的狀態(tài)數(shù)據(jù)做比較，將有變動(dòng)的狀態(tài)數(shù)據(jù)更新到數(shù)據(jù)庫(kù)中，如此便實(shí)現(xiàn)了數(shù)據(jù)庫(kù)中各設(shè)備的狀態(tài)數(shù)據(jù)與設(shè)備的真實(shí)狀態(tài)之間的數(shù)據(jù)一致性。然而，若存在多個(gè)服務(wù)節(jié)點(diǎn)同時(shí)或先后滿足設(shè)定條件，則各服務(wù)節(jié)點(diǎn)會(huì)執(zhí)行一樣的數(shù)據(jù)同步操作，即將分別從數(shù)據(jù)中心獲取的各設(shè)備的狀態(tài)數(shù)據(jù)與數(shù)據(jù)庫(kù)進(jìn)行同步。由于兩者從數(shù)據(jù)中心獲取的各設(shè)備的狀態(tài)數(shù)據(jù)大部分甚至完全相同，從數(shù)據(jù)庫(kù)中獲取的各設(shè)備的狀態(tài)數(shù)據(jù)大部分甚至完全相同，如此會(huì)存在重復(fù)將有變動(dòng)的數(shù)據(jù)更新到數(shù)據(jù)庫(kù)中，造成資源浪費(fèi)。

綜上，針對(duì)分布式系統(tǒng)，目前尚缺乏一種高效的數(shù)據(jù)同步方法。

申請(qǐng)內(nèi)容

本申請(qǐng)?zhí)峁┮环N數(shù)據(jù)同步方法及數(shù)據(jù)節(jié)點(diǎn)，用以解決分布式系統(tǒng)中，多個(gè)服務(wù)節(jié)點(diǎn)對(duì)數(shù)據(jù)庫(kù)進(jìn)行更新時(shí)造成資源浪費(fèi)的問(wèn)題。

第一方面，本申請(qǐng)實(shí)施例提供一種數(shù)據(jù)同步方法，適用于包括多個(gè)服務(wù)節(jié)點(diǎn)的分布式系統(tǒng)，所述多個(gè)服務(wù)節(jié)點(diǎn)共享數(shù)據(jù)庫(kù)；該方法包括：第一服務(wù)節(jié)點(diǎn)在接收到數(shù)據(jù)同步指令后，確定所述分布式系統(tǒng)中是否加載有同步鎖；所述第一服務(wù)節(jié)點(diǎn)在確定無(wú)同步鎖時(shí)，將所述第一服務(wù)節(jié)點(diǎn)生成的同步鎖加載至所述分布式系統(tǒng)；所述第一服務(wù)節(jié)點(diǎn)從數(shù)據(jù)中心拉取待同步數(shù)據(jù)并根據(jù)所述待同步數(shù)據(jù)更新所述數(shù)據(jù)庫(kù)。

基于該方案，對(duì)于分布式系統(tǒng)中的多個(gè)服務(wù)節(jié)點(diǎn)中的任一個(gè)服務(wù)節(jié)點(diǎn)，即第一服務(wù)節(jié)點(diǎn)，在它接收到數(shù)據(jù)同步指令時(shí)，它通過(guò)判斷它所在的分布式系統(tǒng)中是否存在有同步鎖，并在確定無(wú)同步鎖時(shí)，為它所在的分布式系統(tǒng)加上同步鎖，同時(shí)它可以從數(shù)據(jù)中心拉取待同步數(shù)據(jù)以對(duì)數(shù)據(jù)庫(kù)進(jìn)行更新。該方式，當(dāng)分布式系統(tǒng)中確定有一服務(wù)節(jié)點(diǎn)已經(jīng)在執(zhí)行數(shù)據(jù)同步的行為時(shí)，通過(guò)為分布式系統(tǒng)設(shè)置同步鎖，從而在有其他的服務(wù)節(jié)點(diǎn)接收到數(shù)據(jù)同步的指令時(shí)，并確定分布式系統(tǒng)已經(jīng)存在有同步鎖后，則這些服務(wù)節(jié)點(diǎn)將跳過(guò)執(zhí)行數(shù)據(jù)同步的行為，直接進(jìn)入非數(shù)據(jù)同步的工作狀態(tài)，如此可以避免在同一個(gè)分布式系統(tǒng)中，由于同時(shí)有至少兩個(gè)服務(wù)節(jié)點(diǎn)進(jìn)行數(shù)據(jù)同步時(shí)而帶來(lái)的資源浪費(fèi)現(xiàn)象。

在一種可能實(shí)現(xiàn)的方法中，所述根據(jù)所述待同步數(shù)據(jù)更新所述數(shù)據(jù)庫(kù)之前，還包括：所述第一服務(wù)節(jié)點(diǎn)生成消息鎖；所述消息鎖用于指示所述第一服務(wù)節(jié)點(diǎn)正在進(jìn)行數(shù)據(jù)同步；所述第一服務(wù)節(jié)點(diǎn)與所述數(shù)據(jù)中心建立長(zhǎng)連接；所述長(zhǎng)連接用于所述數(shù)據(jù)中心將發(fā)生變更的數(shù)據(jù)發(fā)送至所述第一服務(wù)器；所述第一服務(wù)節(jié)點(diǎn)在確定具有所述消息鎖時(shí)，將所述發(fā)生變更的數(shù)據(jù)存儲(chǔ)至消息隊(duì)列。