[發明專利]一種任務處理方法、裝置、設備及存儲介質

在審

• 申請號: 202211048285.7
• 申請日: 2022-08-30
• 公開（公告）號: CN115421886A
• 公開（公告）日: 2022-12-02
• 發明（設計）人: 慶隆陽
• 申請（專利權）人: 濟南浪潮數據技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 史翠

本申請公開了一種任務處理方法、裝置、設備及存儲介質，涉及計算機技術領域，包括：在非管理節點上基于定時搜集到的節點信息，通過預設節點負載評分公式進行計算，得到當前節點負載評分；判斷與主節點之間的心跳連接是否正常，若正常則將當前節點負載評分上報至主節點，主節點比較接收到的全部當前節點負載評分，得到對應的比較結果；當比較結果為當前節點負載評分為最低評分時，接收主節點分發的任務，啟動對應的相關服務。本申請在主節點與非管理節點之間引入心跳上報機制，在心跳連接正常時非管理節點將自身計算得到的當前節點負載評分傳至主節點，并根據評分選擇接收任務的節點，實現了資源均衡，降低了主節點壓力并提升了系統的流暢性。

技術領域

本發明涉及計算機技術領域，特別涉及一種任務處理方法、裝置、設備及存儲介質。

背景技術

目前通過管理界面或者第三方管理平臺對接存儲集群界面管理系統下發的請求任務，均會發送到主節點上，然后在主節點上起線程進行任務的執行。當選舉的主節點出現故障時，此時界面管理系統會在備節點中重新選舉一個節點作為主節點，后續的請求任務仍然會下發到新主節點上。界面管理系統中還有兩個特殊模塊：存儲集群信息緩存模塊與告警模塊，這兩個模塊也是依賴界面管理系統中的主節點，且上述兩個模塊是間隔一定的時間起線程進行告警信息(集群級告警)、緩存信息(集群級信息)收集。當大量界面請求同時下發時或者第三方平臺對接存儲集群界面管理系統時批量下發并行請求時，會出現主節點的資源占用過高、消息堆積處理不及時等問題，表現在存儲集群界面管理系統上會出現界面反應緩慢、請求相應超時、存儲集群卡頓等，影響用戶的產品體驗感和產品的競爭力。

發明內容

有鑒于此，本發明的目的在于提供一種任務處理方法、裝置、設備和存儲介質，能夠實現資源均衡，降低主節點壓力并提升系統的流暢性。其具體方案如下：

第一方面，本申請公開了一種任務處理方法，應用于非管理節點，包括：

在非管理節點上，基于定時搜集到的節點信息，并通過預設節點負載評分公式進行計算，以得到當前節點負載評分；

判斷與主節點之間的心跳連接是否正常，若正常則將所述當前節點負載評分上報至所述主節點，以便所述主節點對接收到的全部所述當前節點負載評分進行比較，得到對應的比較結果；

當所述比較結果為所述當前節點負載評分為最低評分時，接收所述主節點分發的任務，并啟動對應的相關服務。

可選的，所述基于定時搜集到的節點信息，并通過預設節點負載評分公式進行計算，以得到當前節點負載評分，包括：

通過資源占用評分模塊定時搜集內存使用信息、寬帶使用信息、中央處理器使用信息，以得到所述節點信息；

定義所述節點信息中每個信息對應的權重值；

基于所述權重值并通過預設節點負載評分公式進行計算，以得到當前節點負載評分。

可選的，所述當所述比較結果為所述當前節點負載評分為最低評分時，接收所述主節點分發的任務，并啟動對應的相關服務之后，包括：

得到對應的任務執行結果之后，將所述任務執行結果反饋至所述主節點，并停止所述相關服務。

可選的，所述在非管理節點上，基于定時搜集到的節點信息，并通過預設節點負載評分公式進行計算，以得到當前節點負載評分之前，還包括：

當所述主節點接收到預設數量的界面請求或存在累計處理不及時的請求任務時，確定待分發任務；所述預設數量大于所述主節點的當前最高任務處理數量閾值；

將接收到的全部所述當前節點負載評分的分值按照大小順序排序；

將所述待分發任務分發至所述分值最小的所述當前節點負載評分對應的所述非管理節點。