[發(fā)明專利]一種任務(wù)調(diào)度方法、系統(tǒng)、設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110609946.8
• 申請日: 2021-06-01
• 公開（公告）號: CN113157426A
• 公開（公告）日: 2021-07-23
• 發(fā)明（設(shè)計）人: 陳新浩;張飛;余智平
• 申請（專利權(quán)）人: 微醫(yī)云（杭州）控股有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

本發(fā)明實施例公開了一種任務(wù)調(diào)度方法、系統(tǒng)、設(shè)備及存儲介質(zhì)。獲取定時任務(wù)的觸發(fā)請求，每個服務(wù)器設(shè)置多個節(jié)點，將至少兩個服務(wù)器中唯一節(jié)點組成一個單元，每個單元包括一個主節(jié)點和至少一個從節(jié)點，通過至少一個單元的主節(jié)點對定時任務(wù)進(jìn)行分布式調(diào)度。因此，如果一個單元無法進(jìn)行任務(wù)調(diào)度，即定時任務(wù)不影響其他單元進(jìn)行任務(wù)調(diào)度，并且，當(dāng)一個服務(wù)器掛掉，不會影響其他服務(wù)器的節(jié)點組成的單元進(jìn)行任務(wù)調(diào)度，可以避免定時任務(wù)的調(diào)度過程產(chǎn)生影響，進(jìn)一步通過任務(wù)執(zhí)行線程調(diào)用遠(yuǎn)程調(diào)用線程，以觸發(fā)業(yè)務(wù)方接口，以使業(yè)務(wù)方根據(jù)業(yè)務(wù)方接口的觸發(fā)信息執(zhí)行對應(yīng)的定時任務(wù)。實現(xiàn)了節(jié)約人工成本并保證定時任務(wù)正常調(diào)度和執(zhí)行的效果。

技術(shù)領(lǐng)域

本發(fā)明實施例涉及計算機技術(shù)，尤其涉及一種任務(wù)調(diào)度方法、系統(tǒng)、設(shè)備及存儲介質(zhì)。

背景技術(shù)

在大型軟件系統(tǒng)構(gòu)建過程中經(jīng)常涉及異步任務(wù)處理，異步任務(wù)通過定時器定時調(diào)度執(zhí)行。在Java平臺下，現(xiàn)有的定時任務(wù)調(diào)度模塊包括Spring框架支持的Quartz調(diào)度器。

在復(fù)雜的環(huán)境中，Quartz的調(diào)度進(jìn)程容易死掉，使任務(wù)中斷，并且由于單節(jié)點部署，倘若機器故障或服務(wù)掛掉，定時任務(wù)就無法執(zhí)行。

發(fā)明內(nèi)容

本發(fā)明實施例提供了一種任務(wù)調(diào)度方法、系統(tǒng)、設(shè)備及存儲介質(zhì)，以對服務(wù)器多點部署，實現(xiàn)保證定時任務(wù)正常調(diào)度和執(zhí)行的效果。

第一方面，本發(fā)明實施例提供了種任務(wù)調(diào)度方法，應(yīng)用于任務(wù)調(diào)度系統(tǒng)，包括：

獲取業(yè)務(wù)方發(fā)送的定時任務(wù)的觸發(fā)請求；

基于至少一個單元的主節(jié)點并行調(diào)度所述觸發(fā)請求對應(yīng)的定時任務(wù)，其中，每個所述單元包括一個主節(jié)點和至少一個從節(jié)點，每個所述單元由至少兩個服務(wù)器中的唯一節(jié)點構(gòu)成；

基于所述至少一個單元的主節(jié)點對應(yīng)的定時任務(wù)的執(zhí)行信息，生成至少一個任務(wù)執(zhí)行日志。

第二方面，本發(fā)明實施例還提供了一種任務(wù)調(diào)度系統(tǒng)，包括：接口層、業(yè)務(wù)邏輯層、功能模塊層和數(shù)據(jù)存儲層；所述接口層包括；所述任務(wù)配置接口；所述功能模塊層包括至少一個功能模塊；

其中，所述任務(wù)配置接口，用于獲取定時任務(wù)的觸發(fā)請求，并將所述定時任務(wù)的觸發(fā)請求發(fā)送至所述業(yè)務(wù)邏輯層；

所述業(yè)務(wù)邏輯層執(zhí)行第一方面中任一項所述的任務(wù)調(diào)度方法；

所述功能模塊層，用于根據(jù)所述業(yè)務(wù)邏輯層的業(yè)務(wù)邏輯，調(diào)用至少一個功能模塊對應(yīng)的執(zhí)行邏輯；

所述數(shù)據(jù)存儲層，用于存儲每個單元對應(yīng)的定時任務(wù)。

第三方面，本發(fā)明實施例還提供了一種任務(wù)調(diào)度設(shè)備，包括：包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執(zhí)行所述計算機程序時實現(xiàn)如第一方面中任一項所述的任務(wù)調(diào)度方法。

第四方面，本發(fā)明實施例還提供了一種包含計算機可執(zhí)行指令的存儲介質(zhì)，所述計算機可執(zhí)行指令在由計算機處理器執(zhí)行時實現(xiàn)如第一方面中任一項所述的任務(wù)調(diào)度方法。

本實施例提供的技術(shù)方案，獲取定時任務(wù)的觸發(fā)請求，每個服務(wù)器設(shè)置多個節(jié)點，將至少兩個服務(wù)器中唯一節(jié)點組成一個單元，每個單元包括一個主節(jié)點和至少一個從節(jié)點，通過至少一個單元的主節(jié)點對定時任務(wù)進(jìn)行分布式調(diào)度。因此，如果一個單元無法進(jìn)行任務(wù)調(diào)度，即定時任務(wù)不影響其他單元進(jìn)行任務(wù)調(diào)度，并且，當(dāng)一個服務(wù)器掛掉，不會影響其他服務(wù)器的節(jié)點組成的單元進(jìn)行任務(wù)調(diào)度，可以避免定時任務(wù)的調(diào)度過程產(chǎn)生影響，進(jìn)一步通過任務(wù)執(zhí)行線程調(diào)用遠(yuǎn)程調(diào)用線程，以觸發(fā)業(yè)務(wù)方接口，以使業(yè)務(wù)方根據(jù)業(yè)務(wù)方接口的觸發(fā)信息執(zhí)行對應(yīng)的定時任務(wù)。解決了現(xiàn)有技術(shù)中如果服務(wù)器故障或定時任務(wù)掛掉，需要人工處理才能繼續(xù)調(diào)度的問題，實現(xiàn)了節(jié)約人工成本并保證定時任務(wù)正常調(diào)度和執(zhí)行的效果。

附圖說明

圖1為本發(fā)明實施例一提供的一種任務(wù)調(diào)度方法的流程示意圖；