[發(fā)明專利]一種延時(shí)任務(wù)調(diào)度的方法、設(shè)備及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011565491.6
• 申請(qǐng)日: 2020-12-25
• 公開(kāi)（公告）號(hào): CN112596882A
• 公開(kāi)（公告）日: 2021-04-02
• 發(fā)明（設(shè)計(jì)）人: 襲望
• 申請(qǐng)（專利權(quán)）人: 上海悅易網(wǎng)絡(luò)信息技術(shù)有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/54
• 代理公司: 上海百一領(lǐng)御專利代理事務(wù)所(普通合伙) 31243
• 代理人: 汪祖樂(lè);朱永海

1.一種延時(shí)任務(wù)調(diào)度的方法，其特征在于，所述方法包括：

基于第一預(yù)設(shè)掃描周期，對(duì)延時(shí)任務(wù)隊(duì)列進(jìn)行掃描，以獲取所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，其中，所述延時(shí)任務(wù)由一個(gè)或者多個(gè)業(yè)務(wù)系統(tǒng)基于各自創(chuàng)建的延時(shí)業(yè)務(wù)而生成，并發(fā)布至所述延時(shí)任務(wù)隊(duì)列；

基于所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，將執(zhí)行時(shí)間符合第一預(yù)設(shè)閾值的延時(shí)任務(wù)發(fā)送至延時(shí)任務(wù)緩存隊(duì)列；

基于第二預(yù)設(shè)掃描周期，對(duì)延時(shí)任務(wù)緩存隊(duì)列進(jìn)行掃描，以獲取所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間；

基于所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，若執(zhí)行時(shí)間符合第二預(yù)設(shè)閾值，則將對(duì)應(yīng)的延時(shí)任務(wù)發(fā)送至相應(yīng)的業(yè)務(wù)系統(tǒng)，以執(zhí)行所述延時(shí)任務(wù)對(duì)應(yīng)的延時(shí)業(yè)務(wù)，并從所述延時(shí)任務(wù)緩存隊(duì)列中刪除所述延時(shí)任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，將執(zhí)行時(shí)間符合第一預(yù)設(shè)閾值的延時(shí)任務(wù)發(fā)送至延時(shí)任務(wù)緩存隊(duì)列包括：

基于所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，將執(zhí)行時(shí)間符合第一預(yù)設(shè)閾值的延時(shí)任務(wù)復(fù)制并發(fā)送至延時(shí)任務(wù)緩存隊(duì)列，并將所述延時(shí)任務(wù)隊(duì)列中所述延時(shí)任務(wù)的狀態(tài)設(shè)置為處理中。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述延時(shí)任務(wù)還包含：

發(fā)布所述延時(shí)任務(wù)對(duì)應(yīng)的延時(shí)業(yè)務(wù)的業(yè)務(wù)系統(tǒng)編號(hào)；

所述延時(shí)任務(wù)對(duì)應(yīng)的延時(shí)業(yè)務(wù)類型及編號(hào)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述基于所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，若執(zhí)行時(shí)間符合第二預(yù)設(shè)閾值，則將對(duì)應(yīng)的延時(shí)任務(wù)發(fā)送至相應(yīng)的業(yè)務(wù)系統(tǒng)，以執(zhí)行所述延時(shí)任務(wù)對(duì)應(yīng)的延時(shí)業(yè)務(wù)，并從所述延時(shí)任務(wù)緩存隊(duì)列中刪除所述延時(shí)任務(wù)包括：

基于所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，若執(zhí)行時(shí)間符合第二預(yù)設(shè)閾值，則基于對(duì)應(yīng)的延時(shí)任務(wù)包含的業(yè)務(wù)系統(tǒng)編號(hào)，將所述延時(shí)任務(wù)發(fā)送至相應(yīng)的業(yè)務(wù)系統(tǒng)，以執(zhí)行與所述延時(shí)任務(wù)包含的延時(shí)業(yè)務(wù)類型及編號(hào)對(duì)應(yīng)的延時(shí)業(yè)務(wù)，并從所述延時(shí)任務(wù)緩存隊(duì)列中刪除所述延時(shí)任務(wù)。

5.根據(jù)權(quán)利要求1至4中任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

接收業(yè)務(wù)系統(tǒng)反饋的與延時(shí)任務(wù)相應(yīng)的延時(shí)業(yè)務(wù)執(zhí)行成功的響應(yīng)；

調(diào)整所述延時(shí)任務(wù)隊(duì)列中相應(yīng)延時(shí)任務(wù)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述調(diào)整所述延時(shí)任務(wù)隊(duì)列中相應(yīng)延時(shí)任務(wù)包括：

將所述延時(shí)任務(wù)隊(duì)列中相應(yīng)延時(shí)任務(wù)的狀態(tài)調(diào)整為已完成，并從所述延時(shí)任務(wù)隊(duì)列中移出及存檔。

7.根據(jù)權(quán)利要求1至6任一項(xiàng)所述的方法，其特征在于，所述延時(shí)任務(wù)由業(yè)務(wù)系統(tǒng)根據(jù)創(chuàng)建的延時(shí)業(yè)務(wù)發(fā)布至所述延時(shí)任務(wù)隊(duì)列和/或所述將對(duì)應(yīng)的延時(shí)任務(wù)發(fā)送至相應(yīng)的業(yè)務(wù)系統(tǒng)的方式包括：

通過(guò)MQ內(nèi)部通訊中間件；

通過(guò)http通訊；

通過(guò)客戶端長(zhǎng)連接。

8.一種延時(shí)任務(wù)調(diào)度的設(shè)備，其特征在于，所述設(shè)備包括：

第一裝置，用于基于第一預(yù)設(shè)掃描周期，對(duì)延時(shí)任務(wù)隊(duì)列進(jìn)行掃描，以獲取所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，其中，所述延時(shí)任務(wù)由一個(gè)或者多個(gè)業(yè)務(wù)系統(tǒng)將各自創(chuàng)建的延時(shí)業(yè)務(wù)發(fā)布至所述延時(shí)任務(wù)隊(duì)列；

第二裝置，用于基于所述延時(shí)任務(wù)隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，將執(zhí)行時(shí)間符合第一預(yù)設(shè)閾值的延時(shí)任務(wù)發(fā)送至延時(shí)任務(wù)緩存隊(duì)列；

第三裝置，用于基于第二預(yù)設(shè)掃描周期，對(duì)延時(shí)任務(wù)緩存隊(duì)列進(jìn)行掃描，以獲取所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間；

第四裝置，用于基于所述延時(shí)任務(wù)緩存隊(duì)列中每個(gè)延時(shí)任務(wù)包含的執(zhí)行時(shí)間，若執(zhí)行時(shí)間符合第二預(yù)設(shè)閾值，則將對(duì)應(yīng)的延時(shí)任務(wù)發(fā)送至相應(yīng)的業(yè)務(wù)系統(tǒng)，以執(zhí)行所述延時(shí)任務(wù)對(duì)應(yīng)的延時(shí)業(yè)務(wù)，并從所述延時(shí)任務(wù)緩存隊(duì)列中刪除所述延時(shí)任務(wù)。