[發明專利]分布式系統及該分布式系統的擴容方法

在審

• 申請號: 201610753112.3
• 申請日: 2016-08-29
• 公開（公告）號: CN107786358A
• 公開（公告）日: 2018-03-09
• 發明（設計）人: 郭華
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08
• 代理公司: 北京清亦華知識產權代理事務所(普通合伙)11201
• 代理人: 張大威

1.一種分布式系統的擴容方法，所述分布式系統包括主節點，多個計算節點，所述主節點負責接收和分配任務，所述計算節點執行所述主節點分配的對應的任務，其特征在于，進一步包括緩存節點及觀測者，所述擴容方法包括：

所述緩存節點記錄分配給每個所述計算節點的隊列阻塞信息，并傳送給所述觀測者；

所述主節點接收每個所述計算節點定期上報的自身的資源利用率信息，并傳送給所述觀測者；

所述觀測者收集所述隊列阻塞信息、所述資源利用率信息，并判斷每個所述計算節點是否超過自身預設的吞吐量閥值，若未超過，則以增加線程的方式對每個所述計算節點的內部進行第一次擴容。

2.根據權利要求1所述的擴容方法，其特征在于，所述分布式系統還包括資源管理系統，若每個所述計算節點都超過自身預設的吞吐量閥值，則判斷所述計算節點是否超過預設的資源利用率閥值，若超過，則所述資源管理系統分配所需的硬件資源和軟件鏡像，以增加新的計算節點的方式進行第二次擴容。

3.根據權利要求1所述的擴容方法，其特征在于，所述第一次擴容包括：

所述觀測者接收所述主節點主動發出的擴容申請，并發出第一次擴容命令；

所述計算節點接收所述第一次擴容命令，計算所需增加的線程數量并傳送給所述主節點；

所述觀測者接收所述主節點傳送的所述線程數量，并判斷所述線程數量是否超過預設的上限值，若未超過，則所述計算節點根據所需增加的所述線程數量進行擴容，若超過，則對另外的所述計算節點以增加線程的方式進行擴容。

4.根據權利要求2所述的擴容方法，其特征在于，所述第二次擴容包括：

所述觀測者計算需增加的新的計算節點的數量及所述新的計算節點所需的硬件資源和加載運行軟件映像，并發送第二次擴容命令給所述資源分配系統；

所述資源分配系統接收所述第二次擴容命令，分配所需的硬件資源和加載運行軟件映像，并通過容器方式啟動所述新的計算節點；

所述新的計算節點完成啟動后，向所述緩存節點申請消息緩存并接收所述緩存節點完成的分配結果，同時向所述主節點發出加入請求；

所述主節點接收加入請求后發布新的計算任務，完成第二次擴容。

5.根據權利要求2所述的擴容方法，其特征在于，

當所述資源分配系統包括基礎設施服務系統和容器集群管理系統時，所述觀測者需先向所述基礎設施服務系統申請新的計算節點所需的硬件資源，再向所述容器集群管理系統申請新的計算節點所需的軟件鏡像，所述容器集群管理系統通過容器方式啟動新的計算節點；

當所述資源分配系統為平臺服務系統時，所述觀測者向所述平臺服務系統申請新的計算節點所需的硬件資源及軟件鏡像，所述平臺服務系統通過容器方式啟動新的計算節點。

6.一種分布式系統，包括主節點，多個計算節點，所述主節點負責接收和分配任務，所述計算節點執行所述主節點分配的對應的任務，其特征在于，進一步包括緩存節點及觀測者；

所述緩存節點位于所述主節點和所述計算節點之間，用于記錄分配給每個所述計算節點的隊列阻塞信息，并傳送給所述觀測者；

所述主節點用于接收每個所述計算節點定期上報的自身的資源利用率信息，并傳送給所述觀測者；

所述觀測者用于收集所述隊列阻塞信息、所述資源利用率信息，并判斷每個所述計算節點是否超過自身預設的吞吐量閥值，若未超過，則以增加線程的方式對每個所述計算節點的內部進行第一次擴容。

7.根據權利要求6所述的分布式系統，其特征在于，所述分布式系統還包括資源管理系統，所述資源分配系統用于分配所需的硬件資源和軟件鏡像，若每個所述計算節點都超過自身預設的吞吐量閥值，則判斷所述計算節點是否超過預設的資源利用率閥值，若超過，則以增加新的計算節點的方式進行第二次擴容。

8.根據權利要求6所述的分布式系統，其特征在于，所述第一次擴容包括：

所述觀測者用于接收所述主節點主動發出的擴容申請，并發出第一次擴容命令；

所述計算節點用于接收所述第一次擴容命令，計算所需增加的線程數量并傳送給所述主節點；

所述觀測者用于接收所述主節點傳送的所述線程數量，并判斷所述線程數量是否超過預設的上限值，若未超過，則所述計算節點根據所需增加的所述線程數量進行擴容，若超過，則對另外的所述計算節點以增加線程的方式進行擴容。