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

有效

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

1.一種用于集群系統的任務處理方法，其特征在于，應用于所述集群系統中的任一節點，所述集群系統包括預先選取的一個管理節點，所述方法包括：

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

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

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

2.根據權利要求1所述的方法，其特征在于，所述任務表中的任務是所述集群系統中的任一節點接收到接口發送的任務，并根據所述集群子系統的地址信息，將所述任務添加到所述任務表中的。

3.根據權利要求2所述的方法，其特征在于，當自身為所述集群子系統中的節點，且當前自身處于激活狀態時，所述任務表中的任務是所述集群系統中的任一節點接收到接口發送的任務，并根據所述集群子系統的地址信息，將所述任務添加到自身存儲的任務表中的；所述任務是所述集群系統的接口接收到的并發送給所述任一節點的新的任務；

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

4.根據權利要求1所述的方法，其特征在于，所述在每個待分配任務對應的執行節點標識信息中添加對所述待分配任務處理的節點的標識信息包括：

當自身為所述集群子系統中的節點，且當前自身處于激活狀態時，在自身存儲的任務表的每個待分配任務對應的執行節點標識信息中添加對所述待分配任務處理的節點的標識信息，并將自身的所述任務表中的內容同步到所述集群子系統中的其他節點。

5.根據權利要求1所述的方法，其特征在于，各任務表中還包括各標識信息的任務對應的失敗次數；所述對所述目標任務進行處理之后，所述方法還包括：

當所述目標任務的處理結果為處理成功時，將該任務對應的狀態信息修改為成功狀態；

當所述目標任務的處理結果為處理失敗時，將該任務對應的執行節點標識信息置空，將該任務對應的失敗次數加1，并判斷當前該任務對應的失敗次數是否大于預定閾值；如果是，將該任務對應的狀態信息修改為失敗狀態，如果否，將該任務對應的狀態信息修改為待處理狀態中的重做狀態。

6.根據權利要求5所述的方法，其特征在于，當自身是管理節點時，所述方法還包括：

識別所述任務表中是否存在狀態信息為失敗狀態的任務；

如果是，通知該任務失敗處理。

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

檢測所述集群系統中是否存在故障節點；

如果是，根據所述任務表中各任務對應的執行節點標識信息，識別是否存在執行節點標識信息為所述故障節點的標識信息的任務，如果是，將該任務對應的執行狀態修改為待處理狀態中的重做狀態，并將該任務對應的執行節點標識信息置空。

8.根據權利要求1-7任一所述的方法，其特征在于，所述在每個待分配任務對應的執行節點標識信息中添加對所述待分配任務處理的節點的標識信息包括：

確定各節點的當前負載量；

針對每個待分配任務，識別當前負載量最小的節點，并在該待分配任務對應的執行節點標識信息中添加所述負載量最小的節點的標識信息。

9.根據權利要求1-7任一所述的方法，其特征在于，所述管理節點是所述集群系統中的任一節點接收并保存其他各節點發送的其自身的服務序號后，根據自身的服務序號，以及其他各節點的服務序號，將服務序號最小的節點確定為管理節點的。