[發明專利]Hadoop集群內部節點通信方法、設備及系統

有效

• 申請號: 201210572531.9
• 申請日: 2012-12-25
• 公開（公告）號: CN103051720A
• 公開（公告）日: 2013-04-17
• 發明（設計）人: 馬勺布;孫靈峰
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 深圳市威世博知識產權代理事務所(普通合伙) 44280
• 代理人: 何青瓦

1.一種Hadoop集群內部節點通信方法，其特征在于，包括如下步驟：

接收第一網段內的第一節點所發送的請求命令，其中，所述請求命令用于向具有所述第一節點所需數據的節點請求數據；

給所述第一節點分配第一公網地址，以供所述第一節點根據所述第一公網地址接入公網；

向第二網段內的控制服務器發送所述請求命令，以供所述第二網段內的控制服務器向第二網段內的所有節點廣播所述請求命令，從而查找到具有所述第一節點所需數據的第二節點，并給所述第二節點分配第二公網地址，使所述第二節點根據所述第二公網地址接入公網，利用所述公網與所述第一節點建立數據通信鏈路進行通信。

2.根據權利要求1所述的方法，其特征在于，所述接收第一網段內的第一節點所發送的請求命令的步驟之后，包括如下步驟：

根據排隊情況判斷是否處理所述第一節點所發送的請求命令；

如果輪到處理所述第一節點所發送的請求命令，則執行所述給所述第一節點分配第一公網地址的步驟。

3.根據權利要求1所述的方法，其特征在于，所述向第二網段內的控制服務器發送所述請求命令的步驟包括：

將所述第一公網地址封裝到所述請求命令中，以向所述第二網段內的控制服務器發送所述請求命令。

4.根據權利要求1所述的方法，其特征在于，所述方法還包括：

在所述第一節點與所述第二節點通信完畢后，接收所述第一節點所發送的報告完成消息，從而釋放所述第一公網地址。

5.一種Hadoop集群內部節點通信方法，其特征在于，包括如下步驟：

接收第一網段內的控制服務器所發送的請求命令，其中，所述請求命令包含所述第一網段內的控制服務器向第一網段內的第一節點分配的第一公網地址；所述第一節點根據所述第一公網地址接入公網；

向第二網段內的所有節點廣播所述請求命令，從而查找到具有所述第一節點所需數據的第二節點；

給所述第二節點分配第二公網地址，使所述第二節點根據所述第二公網地址接入公網，并利用所述公網與所述第一節點建立數據通信鏈路進行通信。

6.根據權利要求5所述的方法，其特征在于，所述接收第一網段內的控制服務器所發送的請求命令的步驟之后，包括如下步驟：

根據排隊情況判斷是否處理所述第一網段內的控制服務器所發送的所述請求命令；

如果輪到處理所述第一網段內的控制服務器所發送的所述請求命令，則向第二網段內的所有節點廣播所述請求命令。

7.根據權利要求5所述的方法，其特征在于，所述方法還包括：

在所述第一節點與所述第二節點通信完畢后，接收所述第二節點所發送的報告完成消息，從而釋放所述第二公網地址。

8.一種控制服務器，其特征在于，設置于發送請求命令以請求數據的網段，包括：接收模塊、分配模塊以及發送模塊，

所述接收模塊用于接收第一網段內的第一節點所發送的請求命令，其中，所述請求命令用于向具有所述第一節點所需數據的節點請求數據，所述接收模塊將所述請求命令向所述發送模塊發送；

所述分配模塊用于給所述第一節點分配第一公網地址，以供所述第一節點根據所述第一公網地址接入公網；

所述發送模塊用于接收所述請求命令，向第二網段內的控制服務器發送所述請求命令，以供所述第二網段內的控制服務器向第二網段內的所有節點廣播所述請求命令，從而查找到具有所述第一節點所需數據的第二節點，并給所述第二節點分配第二公網地址，使所述第二節點根據所述第二公網地址接入公網，利用所述公網與所述第一節點建立數據通信鏈路進行通信。

9.根據權利要求8所述的控制服務器，其特征在于，所述控制服務器還包括判斷模塊，所述判斷模塊用于根據排隊情況判斷是否處理所述第一節點所發送的請求命令，使得在輪到處理所述第一節點所發送的請求命令時，給所述第一節點分配第一公網地址。

10.根據權利要求8所述的控制服務器，其特征在于，所述控制服務器還包括封裝模塊，所述封裝模塊用于將所述第一公網地址封裝到所述請求命令中，以向所述第二網段內的控制服務器發送所述請求命令。