[發明專利]一種延時任務調度的方法、設備及系統

在審

• 申請號: 202011565491.6
• 申請日: 2020-12-25
• 公開（公告）號: CN112596882A
• 公開（公告）日: 2021-04-02
• 發明（設計）人: 襲望
• 申請（專利權）人: 上海悅易網絡信息技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 上海百一領御專利代理事務所(普通合伙) 31243
• 代理人: 汪祖樂;朱永海

與現有技術相比，本申請提供一種延時任務調度的方法、設備及系統，定時掃描延時任務隊列，以獲取所述延時任務隊列中每個延時任務包含的執行時間；將執行時間符合第一預設閾值的延時任務發送至延時任務緩存隊列；定時掃描延時任務緩存隊列，以獲取所述延時任務緩存隊列中每個延時任務包含的執行時間；將執行時間符合第二預設閾值的延時任務發送至相應的業務系統，以執行所述延時任務對應的延時業務，并從所述延時任務緩存隊列中刪除所述延時任務。通過該方法將延時任務調度與延時業務執行分布式部署，支持業務系統的延時任務輕量級接入，即插即用，便于統一維護，并可以有效降低多個業務系統各自部署延時任務時存在開發工作量重復的問題。

技術領域

本申請涉及計算機軟件技術領域，尤其涉及一種延時任務調度的技術。

背景技術

現有技術中，業務系統的延時任務是在業務系統部署延時任務，通過調度延時任務，對需延時執行的延時業務進行業務級別的掃描，掃描到到期的延時業務后，再執行該延時業務。

對于多業務系統來說，每個不同的業務系統都需要單獨開發、部署延時任務，一方面造成開發、部署的重復工作量，另一方面不易于統一維護、管理，而且，若業務系統因故重啟，延時任務不能完成，會造成無法按時執行延時業務的后果。

發明內容

本申請的目的是提供一種延時任務調度的方法、設備及系統，用以解決現有技術中延時任務調度不便于統一管理、維護的技術問題。

根據本申請的一個方面，提供了一種延時任務調度的方法，其中，所述方法包括：

基于第一預設掃描周期，對延時任務隊列進行掃描，以獲取所述延時任務隊列中每個延時任務包含的執行時間，其中，所述延時任務由一個或者多個業務系統基于各自創建的延時業務而生成，并發布至所述延時任務隊列；

基于所述延時任務隊列中每個延時任務包含的執行時間，將執行時間符合第一預設閾值的延時任務發送至延時任務緩存隊列；

基于第二預設掃描周期，對延時任務緩存隊列進行掃描，以獲取所述延時任務緩存隊列中每個延時任務包含的執行時間；

基于所述延時任務緩存隊列中每個延時任務包含的執行時間，若執行時間符合第二預設閾值，則將對應的延時任務發送至相應的業務系統，以執行所述延時任務對應的延時業務，并從所述延時任務緩存隊列中刪除所述延時任務。

可選地，其中，所述基于所述延時任務隊列中每個延時任務包含的執行時間，將執行時間符合第一預設閾值的延時任務發送至延時任務緩存隊列包括：

基于所述延時任務隊列中每個延時任務包含的執行時間，將執行時間符合第一預設閾值的延時任務復制并發送至延時任務緩存隊列，并將所述延時任務隊列中所述延時任務的狀態設置為處理中。

可選地，其中，所述延時任務還包含：

發布所述延時任務對應的延時業務的業務系統編號；

所述延時任務對應的延時業務類型及編號。

可選地，其中，所述基于所述延時任務緩存隊列中每個延時任務包含的執行時間，若執行時間符合第二預設閾值，則將對應的延時任務發送至相應的業務系統，以執行所述延時任務對應的延時業務，并從所述延時任務緩存隊列中刪除所述延時任務包括：

基于所述延時任務緩存隊列中每個延時任務包含的執行時間，若執行時間符合第二預設閾值，則基于對應的延時任務包含的業務系統編號，將所述延時任務發送至相應的業務系統，以執行與所述延時任務包含的延時業務類型及編號對應的延時業務，并從所述延時任務緩存隊列中刪除所述延時任務。

可選地，所述一種延時任務調度的方法還包括：

接收業務系統反饋的與延時任務相應的延時業務執行成功的響應；

調整所述延時任務隊列中相應延時任務。