[發(fā)明專利]一種任務(wù)調(diào)度系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201410239514.2
• 申請(qǐng)日: 2014-05-30
• 公開（公告）號(hào): CN104050029B
• 公開（公告）日: 2018-02-16
• 發(fā)明（設(shè)計(jì)）人: 滕一勤;朱大勇;張濤
• 申請(qǐng)（專利權(quán)）人: 北京先進(jìn)數(shù)通信息技術(shù)股份公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06F17/30
• 代理公司: 北京潤(rùn)澤恒知識(shí)產(chǎn)權(quán)代理有限公司11319
• 代理人: 劉祥景

1.一種任務(wù)調(diào)度系統(tǒng)，其特征在于，包括：數(shù)據(jù)庫(kù)和運(yùn)行在計(jì)算機(jī)集群的各節(jié)點(diǎn)之上的嵌入式框架；

其中，所述數(shù)據(jù)庫(kù)中存儲(chǔ)有任務(wù)文件、任務(wù)配置參數(shù)和任務(wù)狀態(tài)，其中，該任務(wù)配置參數(shù)包括最大處理節(jié)點(diǎn)數(shù)目，在該任務(wù)的實(shí)際處理節(jié)點(diǎn)數(shù)目未超過所述最大處理節(jié)點(diǎn)數(shù)目時(shí)允許獲取該任務(wù)的任務(wù)文件；

所述嵌入式框架包括：任務(wù)流程模塊、任務(wù)處理模塊和任務(wù)過程接口；其中，所述任務(wù)過程接口中封裝有預(yù)置任務(wù)過程的處理功能；所述任務(wù)流程模塊提供流程接口；

所述任務(wù)處理模塊，用于掃描所述數(shù)據(jù)庫(kù)，在發(fā)現(xiàn)預(yù)置任務(wù)狀態(tài)的任務(wù)時(shí)，鎖定并獲取該任務(wù)的任務(wù)文件，并在獲取成功后調(diào)用所述流程接口執(zhí)行相應(yīng)的任務(wù)處理；其中，所述預(yù)置任務(wù)狀態(tài)包括待處理狀態(tài)；

所述任務(wù)流程模塊，用于在所述流程接口被所述任務(wù)處理模塊調(diào)用時(shí)，解析該任務(wù)涉及的任務(wù)過程，依據(jù)解析結(jié)果調(diào)用對(duì)應(yīng)的任務(wù)過程接口以執(zhí)行相應(yīng)任務(wù)過程的處理，并在相應(yīng)任務(wù)過程的處理成功后進(jìn)行任務(wù)狀態(tài)的轉(zhuǎn)換。

2.如權(quán)利要求1所述的系統(tǒng)，其特征在于，所述嵌入式框架還包括節(jié)點(diǎn)管理模塊；

所述節(jié)點(diǎn)管理模塊，用于向所述數(shù)據(jù)庫(kù)登記所處節(jié)點(diǎn)的存活聲明，以及，從所述數(shù)據(jù)庫(kù)獲取失效節(jié)點(diǎn)，并接手所述失效節(jié)點(diǎn)的任務(wù)。

3.如權(quán)利要求1所述的系統(tǒng)，其特征在于，所述流程接口包括流程執(zhí)行接口，所述任務(wù)過程接口包括過程業(yè)務(wù)處理接口，所述過程業(yè)務(wù)處理接口中封裝有業(yè)務(wù)邏輯過程的處理功能；

則所述任務(wù)處理模塊包括：

任務(wù)執(zhí)行子模塊，用于掃描所述數(shù)據(jù)庫(kù)，在發(fā)現(xiàn)待處理狀態(tài)的任務(wù)時(shí)，鎖定并獲取該任務(wù)的任務(wù)文件，并在獲取成功后調(diào)用所述流程執(zhí)行接口執(zhí)行相應(yīng)的任務(wù)處理；

則所述任務(wù)流程模塊，具體用于在所述流程執(zhí)行接口被所述任務(wù)執(zhí)行子模塊調(diào)用時(shí)，解析該任務(wù)涉及的任務(wù)過程，依據(jù)解析結(jié)果調(diào)用所述過程業(yè)務(wù)處理接口以進(jìn)行業(yè)務(wù)邏輯過程的處理，并在業(yè)務(wù)邏輯過程的處理成功后將任務(wù)狀態(tài)從待處理狀態(tài)轉(zhuǎn)換為處理成功狀態(tài)。

4.如權(quán)利要求3所述的系統(tǒng)，其特征在于，所述任務(wù)過程接口還包括最終環(huán)境清理接口，所述最終環(huán)境清理接口中封裝有任務(wù)終結(jié)時(shí)運(yùn)行環(huán)境的清理功能；

則所述任務(wù)流程模塊，還用于在業(yè)務(wù)邏輯過程的處理成功后調(diào)用所述最終環(huán)境清理接口以進(jìn)行任務(wù)終結(jié)時(shí)運(yùn)行環(huán)境的清理，并在任務(wù)終結(jié)時(shí)運(yùn)行環(huán)境的清理成功后將任務(wù)狀態(tài)從待處理狀態(tài)轉(zhuǎn)換為處理成功狀態(tài)。

5.如權(quán)利要求3所述的系統(tǒng)，其特征在于，所述預(yù)置任務(wù)狀態(tài)還包括斷點(diǎn)重做狀態(tài)，所述任務(wù)過程接口還包括過程斷點(diǎn)重做環(huán)境清理接口，所述過程斷點(diǎn)重做環(huán)境清理接口封裝有業(yè)務(wù)邏輯過程文件的清理功能；

則所述任務(wù)執(zhí)行子模塊，還用于掃描所述數(shù)據(jù)庫(kù)，在發(fā)現(xiàn)斷點(diǎn)重做狀態(tài)的任務(wù)時(shí)，鎖定并獲取該任務(wù)的任務(wù)文件，并在獲取成功后調(diào)用所述流程執(zhí)行接口執(zhí)行相應(yīng)的任務(wù)處理；

則所述任務(wù)流程模塊，還用于在所述流程執(zhí)行接口被所述任務(wù)執(zhí)行子模塊調(diào)用時(shí)，解析該任務(wù)涉及的任務(wù)過程，依據(jù)解析結(jié)果調(diào)用所述過程斷點(diǎn)重做環(huán)境清理接口以進(jìn)行業(yè)務(wù)邏輯過程文件的清理，并在業(yè)務(wù)邏輯過程文件的清理成功后將任務(wù)狀態(tài)從斷點(diǎn)重做狀態(tài)轉(zhuǎn)換為待處理狀態(tài)。

6.如權(quán)利要求3所述的系統(tǒng)，其特征在于，所述預(yù)置任務(wù)狀態(tài)還包括待檢查狀態(tài)，所述流程接口還包括流程檢查接口，所述任務(wù)過程接口包括過程環(huán)境檢查接口，所述過程運(yùn)行前環(huán)境檢查接中封裝有運(yùn)行前環(huán)境檢查的功能；

則所述任務(wù)處理模塊還包括：

任務(wù)檢查子模塊，用于掃描所述數(shù)據(jù)庫(kù)，在發(fā)現(xiàn)待檢查狀態(tài)的任務(wù)時(shí)，鎖定并獲取該任務(wù)的任務(wù)文件，并在獲取成功后調(diào)用所述流程檢查接口執(zhí)行相應(yīng)的任務(wù)處理；

則所述任務(wù)流程模塊，還用于在所述流程檢查接口被所述任務(wù)檢查子模塊調(diào)用時(shí)，解析該任務(wù)涉及的任務(wù)過程，依據(jù)解析結(jié)果調(diào)用所述過程環(huán)境檢查接口以進(jìn)行運(yùn)行前環(huán)境檢查，并在運(yùn)行前環(huán)境檢查成功后將任務(wù)狀態(tài)從待檢查狀態(tài)轉(zhuǎn)換為待處理狀態(tài)。