[發(fā)明專利]一種實時任務(wù)處理方法及其設(shè)備

無效

• 申請?zhí)枺?/td>: 200910204559.5
• 申請日: 2009-12-01
• 公開（公告）號: CN101710411A
• 公開（公告）日: 2010-05-19
• 發(fā)明（設(shè)計）人: 吳奔;王耀強(qiáng);周健涌;鄭駿;許之珉;賁俊;丁彥;葉茂
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司
• 主分類號: G06Q40/00
• 分類號: G06Q40/00;G06F9/46
• 代理公司: 廣州三環(huán)專利代理有限公司 44202
• 代理人: 郝傳鑫;潘中毅

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

本發(fā)明涉及銀行數(shù)據(jù)處理領(lǐng)域，具體而言，涉及一種實時任務(wù)處理方法及其設(shè)備。

背景技術(shù)

隨著服務(wù)行業(yè)電子化進(jìn)程的加速以及金融產(chǎn)品種類的日益增多，銀行的代理業(yè)務(wù)量日趨增長。隨著代理業(yè)務(wù)量的增多，銀行核心系統(tǒng)中的代理交易量也相應(yīng)增長。批量代理模式作為處理代理服務(wù)的主要模式，在業(yè)務(wù)量大量增加的情況下，現(xiàn)有的處理效率、處理時間無法滿足用戶的需求。

在現(xiàn)有技術(shù)一中，把每種批量代理服務(wù)都作為一類實時任務(wù)，實際執(zhí)行的功能則為一個任務(wù)的實體。對于實時任務(wù)的處理，當(dāng)實時任務(wù)是由單個作業(yè)執(zhí)行完成時，可采用將作業(yè)長時間掛在系統(tǒng)的運行隊列中的方式。當(dāng)系統(tǒng)的運行隊列中有實時任務(wù)存在時，系統(tǒng)及時處理該實時任務(wù)；當(dāng)系統(tǒng)中的運行隊列里無實時任務(wù)時，則系統(tǒng)采取等待的方式，直至下一個實時任務(wù)出現(xiàn)在運行隊列里。而對于由多個作業(yè)完成的實時任務(wù)，只能采取定時提交的方式完成對于該實時任務(wù)的執(zhí)行，由于采取了定時提交的方式，會造成一定時間的延誤，無法滿足業(yè)務(wù)的時效性。

在現(xiàn)有技術(shù)二中，采用外部系統(tǒng)來實現(xiàn)實時任務(wù)處理。在由外部系統(tǒng)來實現(xiàn)實時任務(wù)的處理機(jī)制中，先由外部系統(tǒng)(非國際商業(yè)機(jī)器公司(International?Business?Machines，IBM)主機(jī)系統(tǒng)環(huán)境)對批量數(shù)據(jù)進(jìn)行分拆，然后將分拆后的數(shù)據(jù)依次提交后臺服務(wù)系統(tǒng)進(jìn)行處理。例如：對于實時性要求高的、需要批量處理數(shù)據(jù)的任務(wù)，采用批量拆聯(lián)機(jī)交易(俗稱聯(lián)機(jī)小批量)的方法。這種機(jī)制無法根據(jù)后臺服務(wù)系統(tǒng)的運行情況，動態(tài)調(diào)整任務(wù)的并發(fā)數(shù)，且后臺服務(wù)系統(tǒng)無法根據(jù)自身的運行狀況干預(yù)實時任務(wù)的運行，并且由于涉及數(shù)據(jù)分拆、合并等額外的處理，流程較為復(fù)雜、運行效率也比較低。

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

本發(fā)明提供了一種實時任務(wù)處理方法及其設(shè)備，無需外部系統(tǒng)處理，通過直接接收由外部系統(tǒng)轉(zhuǎn)發(fā)的任務(wù)請求，根據(jù)該任務(wù)請求進(jìn)行實時任務(wù)處理，縮短了中間環(huán)節(jié)的處理時間，提高了數(shù)據(jù)準(zhǔn)確性及處理效率，同時，由于使用至少一個實時任務(wù)觸發(fā)控制器，對于由多個作業(yè)完成的實時任務(wù)，也可以實時處理，滿足了業(yè)務(wù)的時效性。

為此，一方面，本發(fā)明提供了一種實時任務(wù)處理方法，包括：

實時任務(wù)生成器接收由外部系統(tǒng)轉(zhuǎn)發(fā)的任務(wù)請求，根據(jù)該任務(wù)請求生成任務(wù)實體，并將生成的任務(wù)實體遞交至實時任務(wù)等待隊列中；

至少一個實時任務(wù)觸發(fā)控制器掃描所述實時任務(wù)等待隊列，將掃描到的任務(wù)實體觸發(fā)后提交至實時任務(wù)執(zhí)行控制器；

實時任務(wù)執(zhí)行控制器根據(jù)所述任務(wù)實體獲取實時任務(wù)參數(shù)，根據(jù)所述實時任務(wù)參數(shù)運行該任務(wù)實體。

另一方面，本發(fā)明還提供了一種實時任務(wù)處理設(shè)備，包括：

實時任務(wù)生成器，用于接收由外部系統(tǒng)轉(zhuǎn)發(fā)的任務(wù)請求，根據(jù)該任務(wù)請求生成任務(wù)實體，并將生成的任務(wù)實體遞交至實時任務(wù)等待隊列中；

至少一個實時任務(wù)觸發(fā)控制器，用于掃描所述實時任務(wù)等待隊列，將掃描到的任務(wù)實體觸發(fā)后提交至實時任務(wù)執(zhí)行控制器；

所述實時任務(wù)執(zhí)行控制器，用于根據(jù)所述任務(wù)實體獲取實時任務(wù)參數(shù)，根據(jù)所述實時任務(wù)參數(shù)運行該任務(wù)實體。

實施本發(fā)明的一種實時任務(wù)處理方法及其設(shè)備，通過直接接收由外部系統(tǒng)轉(zhuǎn)發(fā)的任務(wù)請求，而不需要由外部系統(tǒng)對批量數(shù)據(jù)進(jìn)行分拆并將分拆后的數(shù)據(jù)依次提交進(jìn)行處理，縮短了中間環(huán)節(jié)的處理時間，提高了數(shù)據(jù)準(zhǔn)確性及處理效率，滿足業(yè)務(wù)時效性的要求，同時，由于使用至少一個實時任務(wù)觸發(fā)控制器，對于由多個作業(yè)完成的實時任務(wù)，也可以實時處理，滿足了業(yè)務(wù)的時效性。

附圖說明

圖1是本發(fā)明的一種實時任務(wù)處理方法的流程圖；

圖2是圖1中步驟S1的實施方式1的具體流程圖；

圖3是圖1中步驟S1的實施方式2的具體流程圖；

圖4是圖1中步驟S2的具體流程圖；

圖5是圖1中步驟S3的具體流程圖；

圖6是本發(fā)明的一種實時任務(wù)處理設(shè)備的結(jié)構(gòu)框圖；

圖7是圖6中的實時任務(wù)生成器501的實施方式1的結(jié)構(gòu)框圖；

圖8是圖6中的實時任務(wù)生成器501的實施方式2的結(jié)構(gòu)框圖；

圖9是圖6中的實時任務(wù)觸發(fā)控制器502的實施方式1的結(jié)構(gòu)框圖；

圖10是圖6中的實時任務(wù)觸發(fā)控制器502的實施方式2的結(jié)構(gòu)框圖；

圖11是圖6中的實時任務(wù)執(zhí)行控制器503的實施方式1的結(jié)構(gòu)框圖；

圖12是圖6中的實時任務(wù)執(zhí)行控制器503的實施方式2的結(jié)構(gòu)框圖。

具體實施方式

為使本發(fā)明實施例的目的、技術(shù)方案和優(yōu)點更加清楚，下面將結(jié)合附圖對本發(fā)明作進(jìn)一步地詳細(xì)描述。