[發(fā)明專利]一種分布式系統(tǒng)中心節(jié)點(diǎn)構(gòu)建、提交、監(jiān)控方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201210371063.9
• 申請(qǐng)日: 2012-09-28
• 公開（公告）號(hào): CN102929696A
• 公開（公告）日: 2013-02-13
• 發(fā)明（設(shè)計(jì)）人: 宋鵬
• 申請(qǐng)（專利權(quán)）人: 北京搜狐新媒體信息技術(shù)有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 黃熊;王寶筠

1.一種分布式系統(tǒng)中心節(jié)點(diǎn)的構(gòu)建方法，其特征在于，該方法包括：

節(jié)點(diǎn)向分布式系統(tǒng)發(fā)送選舉消息，所述選舉消息包含選舉輪次和消息請(qǐng)求號(hào)；

判斷接收到選舉消息的節(jié)點(diǎn)的選舉輪次與選舉消息中的選舉輪次之間的大小關(guān)系，如果選舉消息的選舉輪次大，則使用選舉消息的選舉輪次更新接收到選舉消息的節(jié)點(diǎn)的選舉輪次；如果接收到選舉消息的節(jié)點(diǎn)的選舉輪次與選舉消息的選舉輪次相等，則判斷接收到選舉消息的節(jié)點(diǎn)的消息請(qǐng)求號(hào)與選舉消息中的消息請(qǐng)求號(hào)之間的大小關(guān)系，如果選舉消息的消息請(qǐng)求號(hào)大，則使用選舉消息的消息請(qǐng)求號(hào)更新接收到選舉消息的節(jié)點(diǎn)的消息請(qǐng)求號(hào)；根據(jù)更新后的選舉輪次和消息請(qǐng)求號(hào)形成對(duì)中心節(jié)點(diǎn)的推薦消息，并向分布式系統(tǒng)發(fā)送推薦消息；

節(jié)點(diǎn)統(tǒng)計(jì)推薦消息中對(duì)中心節(jié)點(diǎn)的推薦，并將被推薦數(shù)達(dá)到預(yù)設(shè)閾值的節(jié)點(diǎn)確定為中心節(jié)點(diǎn)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述節(jié)點(diǎn)統(tǒng)計(jì)推薦消息中對(duì)中心節(jié)點(diǎn)的推薦，并將被推薦數(shù)達(dá)到預(yù)設(shè)閾值的節(jié)點(diǎn)確定為中心節(jié)點(diǎn)包括：

將發(fā)送推薦消息的節(jié)點(diǎn)的地址和發(fā)送推薦消息的節(jié)點(diǎn)推薦的中心節(jié)點(diǎn)的地址放入統(tǒng)計(jì)表，統(tǒng)計(jì)各被推薦作為中心節(jié)點(diǎn)的節(jié)點(diǎn)的被推薦數(shù)，將被推薦數(shù)達(dá)到預(yù)設(shè)閾值的節(jié)點(diǎn)確定中心節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，選舉消息通過節(jié)點(diǎn)的選舉線程發(fā)送；接收選舉消息的節(jié)點(diǎn)通過接收線程接收選舉消息，發(fā)送推薦消息的節(jié)點(diǎn)通過發(fā)送線程發(fā)送推薦消息。

4.一種基于分布式系統(tǒng)中心節(jié)點(diǎn)的數(shù)據(jù)請(qǐng)求提交方法，其特征在于，該方法包括：

將非中心節(jié)點(diǎn)接收到的數(shù)據(jù)請(qǐng)求消息轉(zhuǎn)發(fā)給中心節(jié)點(diǎn)，所述中心節(jié)點(diǎn)按照權(quán)利要求1至3中任何一種方法構(gòu)建得到；

將中心節(jié)點(diǎn)接收到的數(shù)據(jù)請(qǐng)求消息發(fā)送給分布式系統(tǒng)中的非中心節(jié)點(diǎn)；

比較非中心節(jié)點(diǎn)接收到的數(shù)據(jù)請(qǐng)求消息的ID號(hào)與非中心節(jié)點(diǎn)自身的ID號(hào)之間的大小，如果數(shù)據(jù)請(qǐng)求消息的ID號(hào)大，則向中心節(jié)點(diǎn)返回確認(rèn)消息；

如果中心節(jié)點(diǎn)接收到的確認(rèn)消息達(dá)到預(yù)設(shè)閾值，則將數(shù)據(jù)請(qǐng)求消息的數(shù)據(jù)同步到分布式系統(tǒng)的所有非中心節(jié)點(diǎn)。

5.一種基于分布式系統(tǒng)中心節(jié)點(diǎn)的監(jiān)控方法，其特征在于，該方法包括：

在分布式系統(tǒng)中注冊(cè)監(jiān)控節(jié)點(diǎn)，所述監(jiān)控節(jié)點(diǎn)包含配置目錄和狀態(tài)目錄；

在分布式系統(tǒng)中心節(jié)點(diǎn)接收到分布式系統(tǒng)中的節(jié)點(diǎn)發(fā)生變化的消息后，比較監(jiān)控節(jié)點(diǎn)的配置目錄和狀態(tài)目錄下的節(jié)點(diǎn)，如果節(jié)點(diǎn)存在于配置目錄且不存在于狀態(tài)目錄，則發(fā)送監(jiān)控報(bào)警，所述中心節(jié)點(diǎn)按照權(quán)利要求1至3中任何一種方法構(gòu)建得到。

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

在分布式系統(tǒng)中注冊(cè)上報(bào)數(shù)據(jù)目錄，以便節(jié)點(diǎn)發(fā)生變化后在該上報(bào)數(shù)據(jù)目錄下建立新的報(bào)警節(jié)點(diǎn)；

在分布式系統(tǒng)中心節(jié)點(diǎn)接收到分布式系統(tǒng)中的節(jié)點(diǎn)發(fā)生變化的消息后，獲取上報(bào)數(shù)據(jù)目錄下的節(jié)點(diǎn)，根據(jù)獲取的上報(bào)目錄下的節(jié)點(diǎn)發(fā)送監(jiān)控報(bào)警。

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

在分布式系統(tǒng)中注冊(cè)分布式鎖節(jié)點(diǎn)目錄；

獲取分布式鎖節(jié)點(diǎn)目錄下的節(jié)點(diǎn)；

判斷分布式節(jié)點(diǎn)目錄下的節(jié)點(diǎn)中節(jié)點(diǎn)號(hào)最小的節(jié)點(diǎn)，向節(jié)點(diǎn)號(hào)最小的節(jié)點(diǎn)分配分布式鎖。