[發(fā)明專利]任務(wù)調(diào)度方法、裝置及計(jì)算機(jī)設(shè)備

在審

• 申請?zhí)枺?/td>: 202010360051.0
• 申請日: 2020-04-30
• 公開（公告）號(hào): CN111580948A
• 公開（公告）日: 2020-08-25
• 發(fā)明（設(shè)計(jì)）人: 朱歡敏
• 申請（專利權(quán)）人: 中國平安財(cái)產(chǎn)保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/52;H04L29/08
• 代理公司: 北京英特普羅知識(shí)產(chǎn)權(quán)代理有限公司 11015
• 代理人: 鄧小玲;王勇

本發(fā)明實(shí)施例提供了一種任務(wù)調(diào)度方法，包括：通過任務(wù)調(diào)度器定時(shí)查詢所述數(shù)據(jù)庫中存儲(chǔ)的任務(wù)表，并從所述任務(wù)表中獲取預(yù)設(shè)數(shù)量的狀態(tài)為待處理的任務(wù)；判斷獲取到的各個(gè)待處理任務(wù)對應(yīng)的哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配；及在判定出哈希值匹配時(shí)，確定哈希值匹配的待處理任務(wù)為與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的待處理任務(wù)，通過所述任務(wù)調(diào)度器對應(yīng)的實(shí)例執(zhí)行與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的待處理任務(wù)。本發(fā)明還涉及區(qū)塊鏈技術(shù)，所述quartz服務(wù)器節(jié)點(diǎn)為區(qū)塊鏈節(jié)點(diǎn)，所述數(shù)據(jù)庫的任務(wù)調(diào)度系統(tǒng)基于區(qū)塊鏈平臺(tái)建立，可以提高任務(wù)的時(shí)效性，以及可以充分利用到quartz集群的資源并且避免出現(xiàn)數(shù)據(jù)庫死鎖問題。

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

本發(fā)明實(shí)施例涉及區(qū)塊鏈技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度、裝置及計(jì)算機(jī)設(shè)備。

背景技術(shù)

Quartz框架是一個(gè)完全由java編寫的開源作業(yè)調(diào)度框架，被廣泛地應(yīng)用于實(shí)現(xiàn)同一數(shù)據(jù)庫的單集群任務(wù)的任務(wù)管理及調(diào)度。Quartz框架在執(zhí)行定時(shí)任務(wù)時(shí)，通過單個(gè)實(shí)例節(jié)點(diǎn)從數(shù)據(jù)庫任務(wù)表中有序抓取一批選中的異步任務(wù)，并在抓取到任務(wù)后，通過樂觀鎖的機(jī)制對抓取到的任務(wù)進(jìn)行鎖定，以便集群中的其他實(shí)例節(jié)點(diǎn)不能再抓取該任務(wù)。

然而，隨著業(yè)務(wù)場景的增加，平臺(tái)對任務(wù)調(diào)度的依賴場景也越來越多，這種單個(gè)實(shí)例節(jié)點(diǎn)的調(diào)度機(jī)制的任務(wù)處理效率較低，已無法滿足高實(shí)時(shí)性的業(yè)務(wù)需求。

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

有鑒于此，本發(fā)明實(shí)施例的目的是提供一種任務(wù)調(diào)度方法、裝置、計(jì)算機(jī)設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，用于解決現(xiàn)有的任務(wù)調(diào)度機(jī)制效率較低，無法滿足高實(shí)時(shí)性的業(yè)務(wù)需求的問題。

為實(shí)現(xiàn)上述目的，本發(fā)明實(shí)施例提供了一種任務(wù)調(diào)度方法，包括：

通過任務(wù)調(diào)度器定時(shí)查詢所述數(shù)據(jù)庫中存儲(chǔ)的任務(wù)表，并從所述任務(wù)表中獲取預(yù)設(shè)數(shù)量的狀態(tài)為待處理的任務(wù)；

判斷獲取到的各個(gè)待處理任務(wù)對應(yīng)的哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配；及

在判定出哈希值匹配時(shí)，確定哈希值匹配的待處理任務(wù)為與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的待處理任務(wù)，通過所述任務(wù)調(diào)度器對應(yīng)的實(shí)例執(zhí)行與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的待處理任務(wù)。

可選地，所述任務(wù)調(diào)度方法還包括：

在接收到基于quartz集群的配置文件，根據(jù)所述配置文件配置所述quartz服務(wù)器對應(yīng)的哈希槽，所述哈希槽中包括至少一個(gè)哈希值。

可選地，所述判斷獲取到的各個(gè)待處理任務(wù)對應(yīng)的哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配包括：

采用預(yù)設(shè)的哈希算法計(jì)算得到的各個(gè)待處理任務(wù)對應(yīng)的哈希值；

判斷計(jì)算得到的各個(gè)哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配。

可選地，所述判斷獲取到的各個(gè)待處理任務(wù)對應(yīng)的哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配包括：

查找與所述獲取到的各個(gè)待處理任務(wù)關(guān)聯(lián)保存的哈希值；

判斷查找得到的各個(gè)哈希值是否與所述quartz服務(wù)器節(jié)點(diǎn)預(yù)先配置的哈希值相匹配。

可選地，所述通過所述任務(wù)調(diào)度器對應(yīng)的實(shí)例執(zhí)行與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的任務(wù)包括：

通過所述任務(wù)調(diào)度器創(chuàng)建調(diào)度器的工廠，并基于所述工廠生成所述任務(wù)調(diào)度的實(shí)例；

通過所述實(shí)例執(zhí)行與所述quartz服務(wù)器節(jié)點(diǎn)相匹配的任務(wù)。

可選地，所述任務(wù)調(diào)度方法還包括：

在任務(wù)執(zhí)行完畢之后，通過所述任務(wù)調(diào)度器將任務(wù)的狀態(tài)從待處理狀態(tài)修改為已處理狀態(tài)。