[發(fā)明專利]分布式集群數(shù)據(jù)同步方法、主節(jié)點、從節(jié)點、系統(tǒng)及介質(zhì)

在審

• 申請?zhí)枺?/td>: 201810523414.0
• 申請日: 2018-05-28
• 公開（公告）號: CN108696595A
• 公開（公告）日: 2018-10-23
• 發(fā)明（設(shè)計）人: 李昂
• 申請（專利權(quán)）人: 鄭州云海信息技術(shù)有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 羅滿

本申請公開了一種分布式集群數(shù)據(jù)同步方法，將傳統(tǒng)從節(jié)點向主節(jié)點發(fā)送查詢請求、由主節(jié)點完成更新差異判斷的方式變更為每當(dāng)主節(jié)點執(zhí)行了更新操作就通過相應(yīng)的端口即時的向所有從節(jié)點推送本次更新對應(yīng)的更新操作，以使各從節(jié)點在判斷接收到的更新操作是自身未同步過的后完成與主節(jié)點的數(shù)據(jù)同步，由于采用主動推送方式，消除了傳統(tǒng)方式下存在的更新查詢延遲，同時將更新差異判斷交由每個從節(jié)點自己去判斷，主節(jié)點只需在后續(xù)根據(jù)從節(jié)點所要的信息發(fā)送增量更新即可，將原有全部由主節(jié)點承擔(dān)的負(fù)載平攤至各從節(jié)點，更加合理，使用效果更佳。本申請還同時公開了一種主節(jié)點、從節(jié)點、分布式集群數(shù)據(jù)同步系統(tǒng)以及計算機可讀存儲介質(zhì)，具有上述有益效果。

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

本申請涉及數(shù)據(jù)同步技術(shù)領(lǐng)域，特別涉及一種分布式集群數(shù)據(jù)同步方法、主節(jié)點、從節(jié)點、分布式集群數(shù)據(jù)同步系統(tǒng)以及計算機可讀存儲介質(zhì)。

背景技術(shù)

隨著數(shù)據(jù)量和服務(wù)人員的急速增加，采用傳統(tǒng)單一節(jié)點的方式已經(jīng)無法滿足當(dāng)前的要求，由多個節(jié)點組成但對外表現(xiàn)為一個整體的分布式集群技術(shù)開始嶄露頭角。

分布式集群一般包含多個節(jié)點，這些節(jié)點組成一個集群統(tǒng)一的對外提供服務(wù)，通常還會在眾多組成節(jié)點中選取一個節(jié)點作為管理節(jié)點(主節(jié)點)，通過在其上部署上層管理軟件實現(xiàn)對其它組成節(jié)點(從節(jié)點)的管理。在用戶通過集群管理軟件對集群進(jìn)行參數(shù)配置時，通常會將本次參數(shù)配置得到配置更新信息保存在主節(jié)點的本地數(shù)據(jù)庫中，而基于冗余原則還需要實現(xiàn)主節(jié)點與從節(jié)點中數(shù)據(jù)的實時同步，這也是實現(xiàn)災(zāi)備、主備切換的重要前提條件。

現(xiàn)有主從節(jié)點數(shù)據(jù)同步機制通常是在主節(jié)點的本地數(shù)據(jù)庫更新時，將每次進(jìn)行的具體更新操作以某種形式保存下來，以便根據(jù)保存下來的文件確定進(jìn)行了何種更新操作，而實現(xiàn)主從同步則是由各從節(jié)點向主節(jié)點發(fā)起更新查詢請求，即主節(jié)點去對比從節(jié)點數(shù)據(jù)庫與自身的差異，當(dāng)確實存在差異時將對應(yīng)的更新操作發(fā)給從節(jié)點，以使從節(jié)點根據(jù)接收到的更新操作完成同步。

此種方式由于每個從節(jié)點都會向主節(jié)點發(fā)起查詢請求，主節(jié)點會在自身完成差異判斷的操作并發(fā)送相應(yīng)更新操作給從節(jié)點才算完成該查詢請求，當(dāng)從節(jié)點數(shù)量眾多時，會顯著加重主節(jié)點的負(fù)載；同時，由于從節(jié)點并不確定主節(jié)點是否進(jìn)行了更新，因此即使頻繁發(fā)送查詢請求還是會存在一定的延遲，實際使用效果不好。

因此，如何克服現(xiàn)有分布式集群數(shù)據(jù)同步機制存在的缺陷，提供一種主節(jié)點負(fù)載更小、延遲更小的數(shù)據(jù)同步機制是本領(lǐng)域技術(shù)人員亟待解決的問題。

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

本申請的目的是提供一種分布式集群數(shù)據(jù)同步方法，將從節(jié)點向主節(jié)點發(fā)送查詢請求，并由主節(jié)點完成更新差異的判斷的傳統(tǒng)方式變更為每當(dāng)主節(jié)點執(zhí)行了更新操作就通過相應(yīng)的端口即時的向所有從節(jié)點推送本次更新對應(yīng)的更新操作，以使各從節(jié)點在判斷接收到的更新操作是自身未同步過的后利用其完成與主節(jié)點的數(shù)據(jù)同步，由于采用即時主動推送方式，基本消除了傳統(tǒng)方式下存在的更新查詢延遲，同時將更新差異判斷交由每個從節(jié)點自己去判斷，主節(jié)點只需在后續(xù)根據(jù)從節(jié)點所要的信息發(fā)送增量更新即可，將原有全部由主節(jié)點承擔(dān)的負(fù)載平攤至各從節(jié)點，更加合理，使用效果更佳。

本申請的另一目的在于提供了一種主節(jié)點、從節(jié)點、包括主節(jié)點和從節(jié)點的分布式集群數(shù)據(jù)同步系統(tǒng)以及計算機可讀存儲介質(zhì)。

為實現(xiàn)上述目的，本申請?zhí)峁┮环N應(yīng)用于主節(jié)點的分布式集群數(shù)據(jù)同步方法，包括：

根據(jù)接收到的更新指令執(zhí)行數(shù)據(jù)更新操作，并對應(yīng)生成包含具體更新操作步驟的更新消息；

將所述更新消息排列保存于主節(jié)點數(shù)據(jù)庫對應(yīng)的主更新消息表；

當(dāng)所述主更新消息表中新增所述更新消息時，將所述更新信息分發(fā)至各從節(jié)點，以使各所述從節(jié)點根據(jù)自身數(shù)據(jù)庫對應(yīng)的更新消息表中是否包含接收到的更新信息相應(yīng)的選擇是否向利用所述更新信息完成數(shù)據(jù)同步。

可選的，在將所述更新信息分發(fā)至各從節(jié)點之前，還包括：