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

在審

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

1.一種延時任務調度的方法，其特征在于，所述方法包括：

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

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

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

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

2.根據權利要求1所述的方法，其特征在于，所述基于所述延時任務隊列中每個延時任務包含的執行時間，將執行時間符合第一預設閾值的延時任務發送至延時任務緩存隊列包括：

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

3.根據權利要求1或2所述的方法，其特征在于，所述延時任務還包含：

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

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

4.根據權利要求3所述的方法，其特征在于，所述基于所述延時任務緩存隊列中每個延時任務包含的執行時間，若執行時間符合第二預設閾值，則將對應的延時任務發送至相應的業務系統，以執行所述延時任務對應的延時業務，并從所述延時任務緩存隊列中刪除所述延時任務包括：

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

5.根據權利要求1至4中任一項所述的方法，其特征在于，所述方法還包括：

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

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

6.根據權利要求5所述的方法，其特征在于，所述調整所述延時任務隊列中相應延時任務包括：

將所述延時任務隊列中相應延時任務的狀態調整為已完成，并從所述延時任務隊列中移出及存檔。

7.根據權利要求1至6任一項所述的方法，其特征在于，所述延時任務由業務系統根據創建的延時業務發布至所述延時任務隊列和/或所述將對應的延時任務發送至相應的業務系統的方式包括：

通過MQ內部通訊中間件；

通過http通訊；

通過客戶端長連接。

8.一種延時任務調度的設備，其特征在于，所述設備包括：

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

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

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

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