[發明專利]任務處理方法、裝置、系統及電子設備

在審

• 申請號: 201710506427.2
• 申請日: 2017-06-28
• 公開（公告）號: CN109144683A
• 公開（公告）日: 2019-01-04
• 發明（設計）人: 謝艷東
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54;G06Q40/00
• 代理公司: 北京律智知識產權代理有限公司 11438
• 代理人: 姜怡;黃玉霞

本申請涉及任務處理方法、裝置、系統及電子設備,方法包括：獲取阻塞隊列中的任務消息，所述任務消息至少包括任務內容和任務策略；根據當前系統時間和所述任務策略計算所述任務消息的待執行時間；根據所述任務內容和所述待執行時間生成待執行任務；在所述待執行時間執行所述待執行任務。本申請的技術方案能夠為業務系統提供定制化的履約規則，能減少人工介入以降低人為出錯的風險，并提高處理效率，進一步地還能支持任務處理單元的平行擴展。

技術領域

本申請涉及計算機應用技術領域，具體而言，涉及任務處理方法、裝置、系統及電子設備。

背景技術

在當前生產環境下，很多業務條線都存在如下的應用場景：比如網絡不通導致接口不能訪問，需要進行重試保障業務正常；定時發送MQ消息，在指定時間點關閉生產環境的定時任務worker等業務場景。很多場景都需要人工介入，存在人為出錯的風險，且處理效率低。

相關技術中，對接JMQ或任務引擎等消息組件的應用，在業務異常時會支持指定次數的重試，但達到最大次數后該任務失敗。需要人工介入進行拉回處理。

上述相關技術存在如下問題：首先，不能滿足遞增重試機制，好多業務系統在達到最大重試次數后，希望在2小時后，4小時后，8小時后再次重試，以保證業務的正常運行，而當前重試機制不能滿足上述要求。其次，不能定時執行某項任務，比如定時關閉生產環境的任務worker，定時批量調用指定接口等場景，但是上述技術沒有對應的解決方案，而需要人工介入，效率低下。

發明內容

本申請公開任務處理方法，以提高處理效率。

本發明的其他特性和優點將通過下面的詳細描述變得顯然，或部分地通過本發明的實踐而習得。

根據本發明的第一方面，提供一種任務處理方法，包括：

獲取阻塞隊列中的任務消息，所述任務消息至少包括任務內容和任務策略；

根據當前系統時間和所述任務策略計算所述任務消息的待執行時間；

根據所述任務內容和所述待執行時間生成待執行任務；

在所述待執行時間執行所述待執行任務。

根據本發明的一些實施例，在生成所述待執行任務之后還包括：將所述待執行任務添加到設定的任務有序隊列中；在所述待執行時間執行所述待執行任務包括：通過任務執行線程從所述任務有序隊列中取出所述待執行任務，在所述待執行時間執行所述待執行任務。

根據本發明的一些實施例，將所述待執行任務添加到設定的任務有序隊列中包括：將所述待執行任務添加到設定的Redis中。

根據本發明的一些實施例，在生成所述待執行任務之后還包括：將所述待執行任務的信息存儲到數據庫中；通過任務執行線程從所述任務有序隊列中取出所述待執行任務包括：當所述任務執行線程從所述設定的Redis中輪詢到所述待執行任務時，從所述數據庫的取出所述待執行任務的信息。

根據本發明的一些實施例，將所述待執行任務添加到設定的任務有序隊列中包括：根據所述待執行任務的所述執行時間確定所述待執行任務在所述設定的任務有序隊列的位置，將所述待執行任務添加到所述設定的任務有序隊列的所述位置。

根據本發明的一些實施例，所述方法還包括：當在所述待執行時間執行所述待執行任務失敗，獲取所述任務消息的已重試次數和最大可重試次數，將所述已重試次數更新為所述已重試次數加一，當更新后的所述重試次數小于所述最大可重試次數時，向所述阻塞隊列發送所述任務消息。

根據本發明的一些實施例，獲取阻塞隊列中的任務消息包括：通過任務創建線程從MQ消息隊列的阻塞隊列中取出所述任務消息。