[發(fā)明專利]任務(wù)調(diào)度方法、系統(tǒng)、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201910649276.5
• 申請(qǐng)日: 2019-07-16
• 公開(kāi)（公告）號(hào): CN110377410A
• 公開(kāi)（公告）日: 2019-10-25
• 發(fā)明（設(shè)計(jì)）人: 董井智;邵亮
• 申請(qǐng)（專利權(quán)）人: 中信百信銀行股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京市蘭臺(tái)律師事務(wù)所 11354
• 代理人: 張峰;田君露

本申請(qǐng)?zhí)峁┝艘环N任務(wù)調(diào)度方法、系統(tǒng)、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，應(yīng)用于任務(wù)調(diào)度領(lǐng)域，其中該方法包括：接收任務(wù)請(qǐng)求；根據(jù)請(qǐng)求向業(yè)務(wù)端發(fā)起調(diào)度任務(wù)請(qǐng)求；當(dāng)調(diào)度任務(wù)請(qǐng)求失敗時(shí)，發(fā)起重試請(qǐng)求，并發(fā)出調(diào)度失敗信息；當(dāng)重試請(qǐng)求執(zhí)行異常時(shí)，由在線模式轉(zhuǎn)為離線模式，重新發(fā)起所述重試請(qǐng)求，當(dāng)重試請(qǐng)求次數(shù)超過(guò)閾值時(shí)，停止發(fā)起調(diào)度任務(wù)。本發(fā)明通過(guò)調(diào)度任務(wù)失敗后，重試請(qǐng)求方法進(jìn)行細(xì)化設(shè)置，繼而保證了調(diào)度任務(wù)在離線模式下依然能夠繼續(xù)進(jìn)行，順利的完成調(diào)度任務(wù)。通過(guò)在調(diào)度中心中對(duì)調(diào)度的任務(wù)進(jìn)行統(tǒng)一監(jiān)管，避免了由各系統(tǒng)獨(dú)立維護(hù)調(diào)度任務(wù)導(dǎo)致業(yè)務(wù)系統(tǒng)的穩(wěn)定性差的問(wèn)題。

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

本申請(qǐng)涉及任務(wù)調(diào)度領(lǐng)域，具體而言，本申請(qǐng)涉及一種任務(wù)調(diào)度方法、裝置、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

無(wú)論是互聯(lián)網(wǎng)應(yīng)用或者企業(yè)級(jí)應(yīng)用，都充斥著大量的批處理任務(wù)。常常需要一些任務(wù)調(diào)度系統(tǒng)幫助開(kāi)發(fā)者解決問(wèn)題。隨著服務(wù)化架構(gòu)的逐步演進(jìn)，單體架構(gòu)逐漸演變?yōu)榉植际健⑽⒎?wù)架構(gòu)。在此背景下，很多原先的任務(wù)調(diào)度平臺(tái)已經(jīng)不能滿足業(yè)務(wù)系統(tǒng)的需求，尤其是在銀行體系中，隨著直銷銀行和互聯(lián)網(wǎng)系統(tǒng)繁多，而每個(gè)內(nèi)部系統(tǒng)都有定時(shí)調(diào)度的業(yè)務(wù)需求，各系統(tǒng)獨(dú)立維護(hù)定時(shí)任務(wù)不利于業(yè)務(wù)系統(tǒng)的穩(wěn)定性，也不利于管理；銀行的日切、對(duì)賬、計(jì)結(jié)息等場(chǎng)景都是離線任務(wù)，對(duì)準(zhǔn)確性，容錯(cuò)性要求高；目前的調(diào)度平臺(tái)均不能滿足上述需求，一旦發(fā)生宕機(jī)會(huì)影響線上業(yè)務(wù)，容易造成資金損失等一系列問(wèn)題。

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

為了解決上述問(wèn)題申請(qǐng)人提供了一種任務(wù)調(diào)度方法、系統(tǒng)、電子設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，用于解決在線任務(wù)調(diào)度失敗后，如何在離線模式下繼續(xù)調(diào)度任務(wù)并通知任務(wù)請(qǐng)求主體的問(wèn)題，本申請(qǐng)采用的技術(shù)方案如下：

第一方面，提供了一種任務(wù)調(diào)度方法，該方法包括，

接收任務(wù)請(qǐng)求；

根據(jù)請(qǐng)求向業(yè)務(wù)端發(fā)起調(diào)度任務(wù)請(qǐng)求；

當(dāng)調(diào)度任務(wù)請(qǐng)求失敗時(shí)，發(fā)起重試請(qǐng)求，并發(fā)出調(diào)度失敗信息；

當(dāng)重試請(qǐng)求執(zhí)行異常時(shí)，由在線模式轉(zhuǎn)為離線模式，重新發(fā)起所述重試請(qǐng)求，當(dāng)重試請(qǐng)求次數(shù)超過(guò)閾值時(shí)，停止發(fā)起調(diào)度任務(wù)。

在上述方法中，在調(diào)度任務(wù)失敗的情況下，即使發(fā)起重試請(qǐng)求，一旦重試異常，將在離線模式下繼續(xù)重試，保證了調(diào)度任務(wù)的穩(wěn)定執(zhí)行。但無(wú)限制的重試將浪費(fèi)計(jì)算資源，必須有一個(gè)閾值限定，當(dāng)重試的次數(shù)超過(guò)閾值后，即刻停止發(fā)起調(diào)度任務(wù)。

進(jìn)一步地，為了限定重試請(qǐng)求的具體方式，所述重試請(qǐng)求中還包含如下參數(shù)的一種或多種：

重試延時(shí)執(zhí)行時(shí)間，為距離首次調(diào)度任務(wù)失敗的時(shí)間；

重試間隔時(shí)間，為重試請(qǐng)求之間的間隔時(shí)間；

可重試的異常，為反饋的執(zhí)行異常被納入可重試的范圍內(nèi)。

進(jìn)一步地，為了使得每一個(gè)任務(wù)都有對(duì)應(yīng)的重試請(qǐng)求，所述重試請(qǐng)求以注釋名稱的方式與所述任務(wù)對(duì)應(yīng)，一般將任務(wù)的名稱含在重試請(qǐng)求注釋名稱中，并存儲(chǔ)于數(shù)據(jù)庫(kù)中。

進(jìn)一步地，為了實(shí)現(xiàn)調(diào)度端與業(yè)務(wù)端的連接，有效地發(fā)出任務(wù)調(diào)度指令，發(fā)起調(diào)度任務(wù)前，建立接口與所述業(yè)務(wù)端的所述任務(wù)實(shí)現(xiàn)接口方法的連接。

進(jìn)一步地，為了解決新類型任務(wù)調(diào)度的問(wèn)題，當(dāng)出現(xiàn)新任務(wù)的調(diào)度請(qǐng)求時(shí)，發(fā)起添加所述新任務(wù)調(diào)度方法請(qǐng)求，將新任務(wù)的相關(guān)信息添加到所述數(shù)據(jù)庫(kù)，再發(fā)起調(diào)度請(qǐng)求；

新任務(wù)的實(shí)現(xiàn)接口方法通過(guò)接口以反射方式獲取，反射方式可以參照J(rèn)ava編程中用到的反射方式，并將新任務(wù)的實(shí)現(xiàn)接口方法存儲(chǔ)于所述數(shù)據(jù)庫(kù)中。

進(jìn)一步地，為了系統(tǒng)地管理每一個(gè)任務(wù)的調(diào)度，所述任務(wù)的相關(guān)信息由執(zhí)行器管理，一個(gè)執(zhí)行器對(duì)應(yīng)多個(gè)批量任務(wù)信息。