[發(fā)明專利]一種基于節(jié)點(diǎn)特征推舉主節(jié)點(diǎn)的方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201810983227.0
• 申請(qǐng)日: 2018-08-27
• 公開（公告）號(hào): CN109040290B
• 公開（公告）日: 2021-03-09
• 發(fā)明（設(shè)計(jì)）人: 鐘嘉杰;范淵;吳永越;鄭學(xué)新;劉韜
• 申請(qǐng)（專利權(quán)）人: 成都安恒信息技術(shù)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L12/24
• 代理公司: 成都君合集專利代理事務(wù)所(普通合伙) 51228
• 代理人: 張鳴潔

本發(fā)明公開了一種基于節(jié)點(diǎn)特征推舉主節(jié)點(diǎn)的方法，新加入集群的節(jié)點(diǎn)廣播“更新節(jié)點(diǎn)”的報(bào)文A，使集群中其他節(jié)點(diǎn)更新自身的節(jié)點(diǎn)列表；集群中的節(jié)點(diǎn)廣播“查找主節(jié)點(diǎn)”的報(bào)文B和“設(shè)置主節(jié)點(diǎn)”的報(bào)文C推舉設(shè)置本節(jié)點(diǎn)的主節(jié)點(diǎn)。本發(fā)明通過(guò)節(jié)點(diǎn)列表信息的強(qiáng)制更新和節(jié)點(diǎn)間的信息交換，可以讓集群快速進(jìn)入統(tǒng)一的狀態(tài)，確保集群中節(jié)點(diǎn)間的信息共享，增強(qiáng)集群內(nèi)節(jié)點(diǎn)的統(tǒng)一性和工作穩(wěn)定性；通過(guò)設(shè)置節(jié)點(diǎn)的權(quán)重值，可以記錄節(jié)點(diǎn)的可靠性，為判斷節(jié)點(diǎn)的穩(wěn)定性提供依據(jù)。

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

本發(fā)明涉及分布式系統(tǒng)管理技術(shù)領(lǐng)域，具體的說(shuō)，是一種基于節(jié)點(diǎn)特征推舉主節(jié)點(diǎn)的方法。

背景技術(shù)

隨著信息處理的數(shù)據(jù)化和電子化發(fā)展，各大公司在電子平臺(tái)上需要處理的業(yè)務(wù)數(shù)量不斷增加，擁有了高速處理能力的計(jì)算機(jī)等電子處理系統(tǒng)，承擔(dān)了業(yè)務(wù)處理數(shù)量增長(zhǎng)所帶來(lái)的壓力。與此同時(shí)，對(duì)計(jì)算機(jī)系統(tǒng)可靠性的需求也不斷增大。分布式的系統(tǒng)可以將計(jì)算、傳輸、存儲(chǔ)等壓力分布于各個(gè)節(jié)點(diǎn)上。相比與傳統(tǒng)單一設(shè)備的部署特性，分布式的部署方式給整個(gè)業(yè)務(wù)平臺(tái)帶來(lái)更高效、更可靠、魯棒性很強(qiáng)和可伸縮的特性。

但分布式的部署方式也更容易引入集群節(jié)點(diǎn)間數(shù)據(jù)不一致的問(wèn)題。特別是在集群被分割后重新組合的過(guò)程中，重新推舉合適的主節(jié)點(diǎn)成為了維護(hù)集群中數(shù)據(jù)統(tǒng)一性的重要問(wèn)題。

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

本發(fā)明的目的在于提供一種基于節(jié)點(diǎn)特征推舉主節(jié)點(diǎn)的方法，通過(guò)設(shè)定權(quán)重的方式，根據(jù)節(jié)點(diǎn)的特征來(lái)判斷節(jié)點(diǎn)的穩(wěn)定性和重要性，推舉出更合適的主節(jié)點(diǎn)。

本發(fā)明通過(guò)下述技術(shù)方案實(shí)現(xiàn)：一種基于節(jié)點(diǎn)特征推舉主節(jié)點(diǎn)的方法，新加入集群的節(jié)點(diǎn)廣播“更新節(jié)點(diǎn)”的報(bào)文A，使集群中其他節(jié)點(diǎn)更新自身的節(jié)點(diǎn)列表；集群中的節(jié)點(diǎn)廣播“查找主節(jié)點(diǎn)”的報(bào)文B和“設(shè)置主節(jié)點(diǎn)”的報(bào)文C推舉設(shè)置本節(jié)點(diǎn)的主節(jié)點(diǎn)。

進(jìn)一步地，為了更好的實(shí)現(xiàn)本發(fā)明，具體包括以下步驟：

步驟F1：新加入集群的節(jié)點(diǎn)隨機(jī)生成ID，并維護(hù)一份本節(jié)點(diǎn)的節(jié)點(diǎn)列表；

步驟F2：新加入集群的節(jié)點(diǎn)在集群中廣播“更新節(jié)點(diǎn)”的報(bào)文A，并將該新節(jié)點(diǎn)的ID放置在報(bào)文A中；

步驟F3：集群中的節(jié)點(diǎn)收到報(bào)文A時(shí)，檢查自身的節(jié)點(diǎn)列表的信息；

步驟F4：更新集群中所有節(jié)點(diǎn)所維護(hù)的節(jié)點(diǎn)列表；

步驟F5：集群中某個(gè)從節(jié)點(diǎn)的節(jié)點(diǎn)列表中若不存在主節(jié)點(diǎn)或主節(jié)點(diǎn)不存活時(shí)，該從節(jié)點(diǎn)向集群中廣播“查找主節(jié)點(diǎn)”的報(bào)文B，并收集其他節(jié)點(diǎn)的節(jié)點(diǎn)列表；若存在存活的主節(jié)點(diǎn)時(shí)，則不進(jìn)行廣播；

步驟F6：該從節(jié)點(diǎn)將收集到的節(jié)點(diǎn)列表合并，并選出其中的主節(jié)點(diǎn)設(shè)置為自身的主節(jié)點(diǎn)，然后廣播“設(shè)置主節(jié)點(diǎn)”的報(bào)文C；

步驟F7：集群中的節(jié)點(diǎn)接收到報(bào)文C后，將報(bào)文C中的主節(jié)點(diǎn)設(shè)置為自身的主節(jié)點(diǎn)。

進(jìn)一步地，為了更好的實(shí)現(xiàn)本發(fā)明，所述步驟F3具體包括以下步驟：

步驟F31：集群中的節(jié)點(diǎn)收到報(bào)文A時(shí)，檢查自身的節(jié)點(diǎn)列表中是否已存在發(fā)送報(bào)文A的節(jié)點(diǎn)的ID；

步驟F32：若存在，則不做任何更新或更改；若不存在，則在自身的節(jié)點(diǎn)列表中接入發(fā)送報(bào)文A的節(jié)點(diǎn)的ID；

步驟F33：該節(jié)點(diǎn)將發(fā)送報(bào)文A的節(jié)點(diǎn)的權(quán)重值設(shè)置為零；

步驟F34：該節(jié)點(diǎn)再將自身的ID傳送給發(fā)送報(bào)文A的節(jié)點(diǎn)。

進(jìn)一步地，為了更好的實(shí)現(xiàn)本發(fā)明，所述步驟F5具體包括以下步驟：

步驟F51：集群中某個(gè)從節(jié)點(diǎn)通過(guò)檢查自身的節(jié)點(diǎn)列表，查找是否存在角色為主節(jié)點(diǎn)的節(jié)點(diǎn)；

步驟F52：若存在主節(jié)點(diǎn)，但該主節(jié)點(diǎn)不存活時(shí)，從節(jié)點(diǎn)將該不存活的主節(jié)點(diǎn)的權(quán)重值提高，并清除該主節(jié)點(diǎn)的角色，從節(jié)點(diǎn)向集群中廣播報(bào)文B；