[發明專利]一種用于集群系統的任務處理方法及裝置

有效

• 申請號: 201610274108.9
• 申請日: 2016-04-28
• 公開（公告）號: CN107329820B
• 公開（公告）日: 2019-12-20
• 發明（設計）人: 薛成剛;陳廣
• 申請（專利權）人: 杭州海康威視數字技術股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 11413 北京柏杉松知識產權代理事務所(普通合伙)
• 代理人: 杜晶;項京

本發明實施例提供了一種用于集群系統的任務處理方法及裝置，所述方法包括：根據自身保存的當前管理節點的標識信息，判斷自身是否為所述集群系統的管理節點；如果是，根據在集群系統中預先構建的集群子系統的地址信息，查詢集群子系統中存儲的任務表；識別所述任務表中狀態信息為待處理狀態，且執行節點標識信息為空的待分配任務，在每個待分配任務對應的執行節點標識信息中添加對所述待分配任務處理的節點的標識信息；如果否，根據所述集群子系統的地址信息，查詢所述任務表，并識別所述任務表中狀態信息為待處理狀態，且執行節點標識信息為自身標識信息的目標任務，對所述目標任務進行處理。本發明實施例能夠提高集群系統任務處理的成功率。

技術領域

本發明涉及計算機技術領域，特別是涉及一種用于集群系統的任務處理方法及裝置。

背景技術

集群系統是一組相互獨立的、通過高速網絡互聯的計算機，它們構成了一個組，并以單一系統的模式加以管理。集群系統中的各個計算機可以稱為各個節點，各個節點是相互獨立的，任一個節點都可以對集群系統接收到的任務進行處理。

一個用戶與集群系統通信時，集群系統像是一個獨立的計算機。具體地，集群系統可以提供一個與外部通信的接口，用于接收任務，并且，該接口可以將接收到的任務轉發給集群內部的節點進行處理。任務處理是集群系統中的核心技術，要保證一個集群系統正常工作，就要既保證其接收到的各任務被節點成功地處理，又要保證各任務只被一個節點處理，不能被重復處理。

現有的用于集群系統的任務處理方法，可以在集群系統中確定一個節點為管理節點，進一步地，由集群系統的管理節點將接收到的任務分配給任一節點來處理。具體地，在該管理節點上構建有任務池、資源調度模塊等，當接口接收到任務時，將任務添加到管理節點的任務池中，進一步地，資源調度模塊可以將任務池中的任務調度到指定的節點處理。

但是，上述方法中，將任務池和資源調度模塊部署在管理節點上，容易產生單點故障。即當管理節點出現故障時，將導致集群系統的任務分配出錯，進一步地，將導致集群系統不能成功地處理其接收到的任務。

發明內容

本發明實施例的目的在于提供一種用于集群系統的任務處理方法及裝置，以提高集群系統任務處理的成功率。具體技術方案如下：

第一方面，本發明實施例提供了一種用于集群系統的任務處理方法，應用于所述集群系統中的任一節點，所述集群系統包括預先選取的一個管理節點，所述方法包括：

根據自身保存的當前管理節點的標識信息，判斷自身是否為所述集群系統的管理節點；

如果是，根據在所述集群系統中預先構建的集群子系統的地址信息，查詢所述集群子系統中存儲的任務表，其中，所述集群子系統包括至少兩個節點，各節點中均保存有所述任務表；根據所述任務表中各標識信息的任務對應的狀態信息和執行節點標識信息，識別所述任務表中狀態信息為待處理狀態，且執行節點標識信息為空的待分配任務，在每個待分配任務對應的執行節點標識信息中添加對所述待分配任務處理的節點的標識信息；

如果否，根據所述集群子系統的地址信息，查詢所述任務表，并識別所述任務表中狀態信息為待處理狀態，且執行節點標識信息為自身標識信息的目標任務，對所述目標任務進行處理。

進一步地，所述任務表中的任務是所述集群系統中的任一節點接收到接口發送的任務，并根據所述集群子系統的地址信息，將所述任務添加到所述任務表中的。

進一步地，當自身為所述集群子系統中的節點，且當前自身處于激活狀態時，所述任務表中的任務是所述集群系統中的任一節點接收到接口發送的任務，并根據所述集群子系統的地址信息，將所述任務添加到自身存儲的任務表中的；

所述集群子系統中其他節點中保存的任務表是將自身存儲的任務表中的內容同步到所述其他節點中的。