[發明專利]任務分布式處理方法、裝置、存儲介質和服務器

有效

• 申請號: 201710608537.X
• 申請日: 2017-07-24
• 公開（公告）號: CN107688496B
• 公開（公告）日: 2020-12-04
• 發明（設計）人: 嚴月強;伍瓊珂
• 申請（專利權）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;H04L29/08
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 謝曲曲

1.一種任務分布式處理方法，應用于分布式任務調度系統中，其特征在于，所述分布式任務調度系統包括服務器和多個終端，所述服務器為所述分布式任務調度系統中的主控節點，每個所述終端為所述分布式任務調度系統中的執行節點；所述方法包括：

所述服務器接收所述終端發送的任務處理請求；所述任務處理請求中攜帶所述終端的互聯網協議地址；

選取至少一個待分配狀態的任務標識；

從主數據庫中讀取每個任務標識對應的任務，當從所述主數據庫讀取失敗時，從備用數據庫中讀取每個任務標識對應的任務；

根據所述互聯網協議地址，將選取的任務分配給所述終端進行處理；

檢測是否在預設時長之內接收到任務處理結果，若否，則將所述選取的任務重新分配給其它發送任務處理請求的終端進行處理；

接收所述終端反饋的任務處理結果；

根據所述任務處理結果修改對應任務的任務狀態；

還包括：

計算所述選取的任務的分配次數；當所述分配次數達到預設次數時，若在預設時長之內未接收到任務處理結果，或者接收到任務處理失敗的任務處理結果，則將所述選取的任務的任務狀態修改為處理異常狀態。

2.根據權利要求1所述的方法，其特征在于，在所述將選取的任務分配給所述終端進行處理之后，包括：

接收所述終端發送的心跳包，以根據所述心跳包確定所述終端正在處理所述選取的任務。

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

統計每個終端完成的任務數量，根據完成的任務數量對終端進行排序。

4.一種應用于分布式任務調度系統中的任務分布式處理裝置，其特征在于，所述裝置包括：

請求接收模塊，用于接收終端發送的任務處理請求，所述終端為所述分布式任務調度系統中的執行節點；所述任務處理請求中攜帶所述終端的互聯網協議地址；

任務分配模塊，用于選取至少一個待分配狀態的任務標識；從主數據庫中讀取每個任務標識對應的任務，當從所述主數據庫讀取失敗時，從備用數據庫中讀取每個任務標識對應的任務，根據所述互聯網協議地址，將選取的任務分配給所述終端進行處理；還用于檢測是否在預設時長之內接收到任務處理結果，若否，則將所述選取的任務重新分配給其它發送任務處理請求的終端進行處理

任務狀態修改模塊，用于接收所述終端反饋的任務處理結果；根據所述任務處理結果修改對應任務的任務狀態；還用于計算所述選取的任務的分配次數；當所述分配次數達到預設次數時，若在預設時長之內未接收到任務處理結果，或者接收到任務處理失敗的任務處理結果，則將所述選取的任務的任務狀態修改為處理異常狀態。

5.根據權利要求4所述的裝置，其特征在于，

所述任務狀態修改模塊，還用于接收所述終端發送的心跳包，以根據所述心跳包確定所述終端正在處理所述選取的任務。

6.根據權利要求4所述的裝置，其特征在于，所述裝置還包括：

排序模塊，用于統計每個終端完成的任務數量，根據完成的任務數量對終端進行排序。

7.一種計算機可讀存儲介質，其上存儲有計算機指令，其特征在于，該指令被處理器執行時實現一種任務分布式處理方法，所述方法應用于分布式任務調度系統中，其特征在于，所述分布式任務調度系統包括服務器和多個終端，所述服務器為所述分布式任務調度系統中的主控節點，每個所述終端為所述分布式任務調度系統中的執行節點；所述處理器執行所述指令時實現所述權利要求1至3中任一項的所述方法的步驟。

8.一種應用于分布式任務調度系統中的服務器，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述分布式任務調度系統包括所述服務器和多個終端，所述服務器為所述分布式任務調度系統中的主控節點，每個所述終端為所述分布式任務調度系統中的執行節點；所述處理器執行所述程序時實現權利要求1至3中任一項所述方法的步驟。