[發明專利]一種分布式計算方法、主控節點和計算系統

有效

• 申請號: 201611145180.8
• 申請日: 2016-12-13
• 公開（公告）號: CN106598735B
• 公開（公告）日: 2019-08-09
• 發明（設計）人: 張政躍;劉丹
• 申請（專利權）人: 廣東金賦科技股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京易捷勝知識產權代理事務所(普通合伙) 11613
• 代理人: 齊勝杰

本發明涉及一種分布式計算方法、主控節點、計算節點和系統。該方法：主控節點將計算任務分解成計算子任務，將計算子任務放入計算任務隊列。計算節點從實際資源需求量小于可用資源量的計算子任務中獲取一個計算子任務；執行獲取的計算子任務，并返回執行結果。本發明主控節點將計算任務分解成計算子任務后，將計算子任務放入計算任務隊列中，計算節點根據其自身可用資源量，主動從計算任務隊列中獲取相應的計算子任務，并執行，使得本發明計算子任務由計算節點主動獲取，使得部分計算節點是否在線不影響本發明提供的方法的運行，避免了計算任務的執行穩定性對計算節點穩定性的依賴。

技術領域

本發明涉及分布式計算應用領域，尤其涉及一種分布式計算方法、主控節點、計算節點和系統。

背景技術

隨著大數據時代的到來，分布式計算被廣泛應用。

目前，傳統的分布式計算方法是建立在計算機服務集群上的。具體的，將待計算數據分發給計算機服務集群中各個計算節點，匯總計算節點完成的計算結果。

上述方法中，計算數據的計算穩定性依賴于計算機服務集群的穩定性。要保證上述方法的運行穩定性，需要保證計算機服務集群的穩定性。而建立穩定的計算機服務集群需要大量的專用計算機的投入。

發明內容

(一)要解決的技術問題

為了避免計算任務的執行穩定性對計算節點穩定性的依賴，本發明提供一種分布式計算方法、主控節點、計算節點和系統，主控節點將計算任務分解成計算子任務后，將計算子任務放入計算任務隊列中，計算節點根據其自身可用資源量，主動從計算任務隊列中獲取相應的計算子任務，并執行，使得本發明計算子任務由計算節點主動獲取，使得部分計算節點是否在線不影響本發明提供的方法的運行，避免了計算任務的執行穩定性對計算節點穩定性的依賴。

(二)技術方案

為了達到上述目的，本發明采用的主要技術方案包括：

一種分布式計算方法，該方法包括：

101，接收計算任務；

102，將所述計算任務分解成計算子任務；

103，將所述計算子任務放入計算任務隊列，以使所述計算子任務被計算節點主動獲取并執行；

104，確認計算子任務全部執行完成后，匯總計算子任務的執行結果。

可選地，步驟102具體包括：

102-1，將計算任務分解為單元任務；

102-2，將具有同一位置屬性的單元任務進行聚類，每一類單元任務為一個計算子任務；或者，

根據如下公式確定各單元任務之間的關聯度，根據所述關聯度對單元任務進行聚類，每一類單元任務為一個計算子任務，

其中，C(a1,a2)為a1與a2之間的關聯度，R_a1為a1的資源需求用量，∑R為所述計算任務資源需求用總量，W(a1,a2)為a1與a2之間的邏輯關系影響因子，n(a1,a2)為a1與a2之間共用資源需求用量。

除此之外，本發明采用的主要技術方案還包括：

一種主控節點，該主控節點包括：

接收模塊，用于接收計算任務；

分解模塊，用于將所述計算任務分解成計算子任務；

放入模塊，用于將所述計算子任務放入計算任務隊列，以使所述計算子任務被計算節點主動獲取并執行；