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

在審

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

1.一種分布式集群數(shù)據(jù)同步方法，其特征在于，應用于主節(jié)點，包括：

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

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

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

2.根據(jù)權利要求1所述方法，其特征在于，在將所述更新信息分發(fā)至各從節(jié)點之前，還包括：

將所述更新信息按通用信息傳輸協(xié)議進行封裝，得到通用更新信息。

3.根據(jù)權利要求2所述方法，其特征在于，將所述更新信息按通用信息傳輸協(xié)議進行封裝，包括：

將所述更新信息按套接字協(xié)議的標準格式進行封裝。

4.一種主節(jié)點，其特征在于，包括：

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

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

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

5.一種分布式集群數(shù)據(jù)同步方法，應用于從節(jié)點，包括：

接收主節(jié)點發(fā)來的更新消息；

判斷自身數(shù)據(jù)庫對應的更新消息表中是否包含與接收到的更新消息相同的更新消息；

若包含與接收到的更新消息相同的更新消息，則將本次接收到的更新消息做無效處理；

若不包含與接收到的更新消息相同的更新消息，則根據(jù)接收到的更新消息中包含的具體更新操作步驟執(zhí)行數(shù)據(jù)同步操作。

6.根據(jù)權利要求5所述方法，其特征在于，還包括：

當從節(jié)點自身數(shù)據(jù)庫對應的更新消息表中不包含與接收到的更新消息相同的更新消息時，根據(jù)接收到的更新消息確定與主節(jié)點的差異數(shù)據(jù)，并根據(jù)所述差異數(shù)據(jù)向所述主節(jié)點發(fā)送增量更新請求。

7.根據(jù)權利要求5或6所述方法，其特征在于，還包括：

當所述從節(jié)點為新上線的空白節(jié)點時，向所述主節(jié)點發(fā)送全量數(shù)據(jù)同步請求。

8.根據(jù)權利要求5或6所述方法，其特征在于，還包括：

當所述從節(jié)點為異常掉線節(jié)點時，向所述主節(jié)點發(fā)送自身數(shù)據(jù)庫對應的更新消息表中最新的更新消息，以使所述主節(jié)點根據(jù)接收到的最新的更新消息與所述主更新消息表中包含的更新信息進行比對，并根據(jù)得到的比對結果向所述異常掉線節(jié)點返回相應數(shù)量的更新消息。

9.一種從節(jié)點，其特征在于，包括：

更新消息接收單元，用于接收主節(jié)點發(fā)來的更新消息；

更新消息相同判斷單元，用于判斷自身數(shù)據(jù)庫對應的更新消息表中是否包含與接收到的更新消息相同的更新消息；

無效處理單元，用于當包含與接收到的更新消息相同的更新消息時，將本次接收到的更新消息做無效處理；

同步操作執(zhí)行單元，用于當不包含與接收到的更新消息相同的更新消息時，根據(jù)接收到的更新消息中包含的具體更新操作步驟執(zhí)行數(shù)據(jù)同步操作。