[發(fā)明專利]應(yīng)用系統(tǒng)多服務(wù)集群下定時(shí)任務(wù)調(diào)度方法

有效

• 申請(qǐng)?zhí)枺?/td>: 202211682914.1
• 申請(qǐng)日: 2022-12-27
• 公開(kāi)（公告）號(hào): CN115934287B
• 公開(kāi)（公告）日: 2023-09-12
• 發(fā)明（設(shè)計(jì)）人: 裴俊楓;王宗
• 申請(qǐng)（專利權(quán)）人: 無(wú)錫錫銀金科信息技術(shù)有限責(zé)任公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/52;G06F16/2455;G06F16/23;G06F16/27
• 代理公司: 無(wú)錫市匯誠(chéng)永信專利代理事務(wù)所(普通合伙) 32260
• 代理人: 朱曉林

1.一種應(yīng)用系統(tǒng)多服務(wù)集群下定時(shí)任務(wù)調(diào)度方法，其特征在于，所述方法包括：

接收指令創(chuàng)建任務(wù)，將任務(wù)對(duì)應(yīng)數(shù)據(jù)存入數(shù)據(jù)庫(kù)并同步到redis緩存中；

任務(wù)核心線程啟動(dòng)并完成數(shù)據(jù)同步后，查詢所述redis緩存的任務(wù)列表，根據(jù)任務(wù)列表中各任務(wù)的狀態(tài)信息更新可執(zhí)行任務(wù)列表；其中，任務(wù)列表中包含有所有創(chuàng)建且未執(zhí)行完畢的任務(wù)和對(duì)應(yīng)狀態(tài)信息，所述可執(zhí)行任務(wù)列表中包含有任務(wù)核心線程確定的具備執(zhí)行條件的任務(wù)；所述redis緩存還包含有任務(wù)列表對(duì)應(yīng)的爭(zhēng)搶鎖列表，所述爭(zhēng)搶鎖列表包括所有服務(wù)對(duì)任務(wù)的爭(zhēng)搶狀態(tài)；所述狀態(tài)信息至少包括每個(gè)任務(wù)的爭(zhēng)搶鎖id、任務(wù)id、任務(wù)參數(shù)、定時(shí)信息、執(zhí)行類名、任務(wù)重試次數(shù)及最大重試次數(shù)、任務(wù)當(dāng)前狀態(tài)、前序任務(wù)列表和后續(xù)任務(wù)列表；所述前序任務(wù)列表和所述后續(xù)任務(wù)列表中包含有執(zhí)行該任務(wù)需要的前序任務(wù)和后續(xù)任務(wù)；所述定時(shí)信息為觸發(fā)該任務(wù)爭(zhēng)搶機(jī)制的時(shí)間；更新所述可執(zhí)行任務(wù)列表具體包括：

輪詢所述redis緩存的任務(wù)列表，根據(jù)所述定時(shí)信息確定新觸發(fā)任務(wù)，根據(jù)任務(wù)當(dāng)前狀態(tài)、爭(zhēng)搶鎖id及爭(zhēng)搶狀態(tài)、任務(wù)重試次數(shù)及最大重試次數(shù)確定可執(zhí)行任務(wù)；

基于可執(zhí)行任務(wù)和新觸發(fā)任務(wù)更新所述可執(zhí)行任務(wù)列表；其中，可執(zhí)行任務(wù)為歷史執(zhí)行失敗的任務(wù)，且執(zhí)行次數(shù)小于最大重試次數(shù)，集群服務(wù)器包含若干服務(wù)，所述可執(zhí)行任務(wù)列表中的任務(wù)對(duì)應(yīng)爭(zhēng)搶鎖狀態(tài)為未占用狀態(tài)，任務(wù)當(dāng)前狀態(tài)為未執(zhí)行狀態(tài)；

更新所述可執(zhí)行任務(wù)列表后，基于任務(wù)類型和任務(wù)參數(shù)對(duì)所述可執(zhí)行任務(wù)列表中的所有任務(wù)進(jìn)行歸類，將存在關(guān)聯(lián)條件的任務(wù)建立各自的所述前序任務(wù)列表及所述后續(xù)任務(wù)列表；

基于redis分布式機(jī)制獲取所述可執(zhí)行任務(wù)列表對(duì)應(yīng)的任務(wù)鎖爭(zhēng)搶列表，通過(guò)爭(zhēng)搶鎖機(jī)制和任務(wù)的前序條件完成情況確定目標(biāo)任務(wù)；具體包括：

核對(duì)所述可執(zhí)行任務(wù)列表中各個(gè)候選任務(wù)對(duì)應(yīng)前序任務(wù)的完成狀態(tài)，并將前序任務(wù)未完成的候選任務(wù)濾除，獲得中間任務(wù)列表；

基于redis分布式機(jī)制對(duì)所有中間任務(wù)執(zhí)行多任務(wù)爭(zhēng)搶，將爭(zhēng)搶到的所述中間任務(wù)作為所述目標(biāo)任務(wù)，同步更新所述目標(biāo)任務(wù)的任務(wù)重試次數(shù)、執(zhí)行信息時(shí)間、以及最晚完成時(shí)間；

當(dāng)所述目標(biāo)任務(wù)在最晚完成時(shí)間內(nèi)未完成執(zhí)行任務(wù)時(shí)，爭(zhēng)搶鎖自動(dòng)失效；所述執(zhí)行信息時(shí)間為目標(biāo)服務(wù)爭(zhēng)搶到鎖的時(shí)間，且搶到鎖后的爭(zhēng)搶鎖更新為已占用狀態(tài)；其中，任務(wù)核心線程移交任務(wù)到本地線程池中執(zhí)行后進(jìn)入休眠狀態(tài)，休眠完成后繼續(xù)獲取當(dāng)前的所述中間任務(wù)列表；當(dāng)所述中間任務(wù)列表不存在滿足執(zhí)行條件的任務(wù)時(shí)結(jié)束線程，否則繼續(xù)根據(jù)所述中間任務(wù)列表執(zhí)行爭(zhēng)搶任務(wù)；

對(duì)所述目標(biāo)任務(wù)創(chuàng)建子任務(wù)線程，并放到本地線程池中異步執(zhí)行和同步所述redis緩存，子任務(wù)線程和任務(wù)核心線程分屬不同線程池，任務(wù)核心線程是常駐線程池，用于調(diào)度和承擔(dān)各個(gè)任務(wù)的實(shí)現(xiàn)，全局線程池用于子任務(wù)線程的創(chuàng)建和調(diào)度，具體包括：

對(duì)所述目標(biāo)任務(wù)創(chuàng)建子任務(wù)線程，并在本地線程池中執(zhí)行；

根據(jù)任務(wù)參數(shù)執(zhí)行內(nèi)容，并記錄日志信息；

執(zhí)行完成后根據(jù)結(jié)果更新所述redis緩存中的任務(wù)列表，用于任務(wù)核銷(xiāo)；

當(dāng)所述目標(biāo)任務(wù)包含有所述后續(xù)任務(wù)列表時(shí)，讀取并更新所述redis緩存中任務(wù)列表和所述可執(zhí)行任務(wù)列表，繼續(xù)通過(guò)爭(zhēng)搶鎖執(zhí)行后續(xù)任務(wù)。