[發(fā)明專利]在對等分布式系統(tǒng)中新增節(jié)點(diǎn)的方法及對等分布式系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201710330471.2
• 申請日: 2017-05-11
• 公開（公告）號: CN107295063B
• 公開（公告）日: 2018-09-04
• 發(fā)明（設(shè)計）人: 洪利平
• 申請（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 郝傳鑫;賈允

1.一種在對等分布式系統(tǒng)中新增節(jié)點(diǎn)的方法，所述對等分布式系統(tǒng)包括客戶節(jié)點(diǎn)、多個分區(qū)和多個服務(wù)器節(jié)點(diǎn)；每個服務(wù)器節(jié)點(diǎn)都存儲不止一個分區(qū)的數(shù)據(jù)，允許被客戶節(jié)點(diǎn)訪問的分區(qū)為服務(wù)器節(jié)點(diǎn)的主分區(qū)，其它分區(qū)為服務(wù)器節(jié)點(diǎn)的備分區(qū)，其特征在于，所述方法包括：

響應(yīng)于新增節(jié)點(diǎn)指令，獲取待遷移至新增節(jié)點(diǎn)的數(shù)據(jù)的記錄；

根據(jù)所述記錄獲取用于向新增節(jié)點(diǎn)遷移數(shù)據(jù)的源服務(wù)器節(jié)點(diǎn)，所述源服務(wù)器節(jié)點(diǎn)的主分區(qū)存儲有待遷移至新增節(jié)點(diǎn)的數(shù)據(jù)；

配置新增節(jié)點(diǎn)并設(shè)置所述新增節(jié)點(diǎn)的所有分區(qū)為備分區(qū)；

控制源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移，并且并行將所述源服務(wù)器節(jié)點(diǎn)發(fā)生的寫操作同步至所述新增節(jié)點(diǎn)；

開啟所述對等分布式系統(tǒng)的路由變更操作，在所述路由變更操作執(zhí)行過程中，所述新增節(jié)點(diǎn)的部分備分區(qū)轉(zhuǎn)變?yōu)橹鞣謪^(qū)，所述源服務(wù)器節(jié)點(diǎn)和所述新增節(jié)點(diǎn)均能夠被客戶節(jié)點(diǎn)訪問。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述控制源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移，并且并行將所述源服務(wù)器節(jié)點(diǎn)發(fā)生的寫操作同步至所述新增節(jié)點(diǎn)包括：

在源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移的過程中，所述源服務(wù)器節(jié)點(diǎn)接收所述客戶節(jié)點(diǎn)對所述源服務(wù)器節(jié)點(diǎn)的主分區(qū)數(shù)據(jù)的寫操作請求；

根據(jù)所述寫操作請求變更所述主分區(qū)數(shù)據(jù)；

同步變更新增節(jié)點(diǎn)中的數(shù)據(jù)；

若所述源服務(wù)器節(jié)點(diǎn)和所述新增節(jié)點(diǎn)均成功變更數(shù)據(jù)，則向客戶節(jié)點(diǎn)返回寫操作成功響應(yīng)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述控制源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移，并且并行將所述源服務(wù)器節(jié)點(diǎn)發(fā)生的寫操作同步至所述新增節(jié)點(diǎn)包括：

在源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移的過程中，所述源服務(wù)器節(jié)點(diǎn)接收所述客戶節(jié)點(diǎn)對所述源服務(wù)器節(jié)點(diǎn)的主分區(qū)數(shù)據(jù)的寫操作請求；

根據(jù)所述寫操作請求變更所述主分區(qū)數(shù)據(jù)并向新增節(jié)點(diǎn)發(fā)送同步指令；

若對所述主分區(qū)數(shù)據(jù)的變更被成功執(zhí)行，則向客戶節(jié)點(diǎn)返回寫操作成功響應(yīng)。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述控制源服務(wù)器節(jié)點(diǎn)向所述新增節(jié)點(diǎn)進(jìn)行數(shù)據(jù)遷移，并且并行將所述源服務(wù)器節(jié)點(diǎn)發(fā)生的寫操作同步至所述新增節(jié)點(diǎn)還包括：

源服務(wù)器節(jié)點(diǎn)跟蹤新增節(jié)點(diǎn)對于所述寫操作請求的變更過程，直至所述變更執(zhí)行成功。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，客戶節(jié)點(diǎn)和每一個服務(wù)器節(jié)點(diǎn)均存儲有路由表，所述路由表用于標(biāo)識所述對等分布式系統(tǒng)的全部路由，在開啟所述對等分布式系統(tǒng)的路由變更操作之后，客戶節(jié)點(diǎn)和服務(wù)器節(jié)點(diǎn)中的路由表被改變。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述方法還包括在新增節(jié)點(diǎn)的過程中響應(yīng)客戶節(jié)點(diǎn)的非遍歷訪問的方法，包括：

客戶節(jié)點(diǎn)獲取并存儲待請求數(shù)據(jù)的記錄；

客戶節(jié)點(diǎn)獲取自身本地存儲的記錄并根據(jù)自身本地存儲的路由表獲取目標(biāo)服務(wù)器節(jié)點(diǎn)；

客戶節(jié)點(diǎn)根據(jù)記錄向所述目標(biāo)服務(wù)器節(jié)點(diǎn)發(fā)送訪問請求；

所述目標(biāo)服務(wù)器節(jié)點(diǎn)判斷自身本地是否存儲有所述記錄對應(yīng)的待請求數(shù)據(jù)；若是，則返回訪問成功響應(yīng)包；否則，返回重映射響應(yīng)包；

所述客戶節(jié)點(diǎn)判斷收到的響應(yīng)包是否為訪問成功響應(yīng)包：

若響應(yīng)包為訪問成功響應(yīng)包，則處理所述訪問成功響應(yīng)包；

若響應(yīng)包為重映射響應(yīng)包，則等待第一預(yù)設(shè)時間后重新執(zhí)行獲取自身本地存儲的記錄并根據(jù)自身存儲的路由表獲取目標(biāo)服務(wù)器節(jié)點(diǎn)的步驟。