[發(fā)明專利]一種工作流引擎系統(tǒng)和業(yè)務(wù)處理方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202010157883.2
• 申請(qǐng)日: 2020-03-09
• 公開（公告）號(hào): CN111427701A
• 公開（公告）日: 2020-07-17
• 發(fā)明（設(shè)計(jì)）人: 王海幸
• 申請(qǐng)（專利權(quán)）人: 中國(guó)建設(shè)銀行股份有限公司;建信金融科技有限責(zé)任公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F9/445
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 王志遠(yuǎn);陳繼越

本發(fā)明公開了一種工作流引擎系統(tǒng)和業(yè)務(wù)處理方法，涉及計(jì)算機(jī)技術(shù)領(lǐng)域。該方法的一具體實(shí)施方式包括一種工作流引擎系統(tǒng)，包括：插件管理中心、引擎控制中心、業(yè)務(wù)調(diào)度器；其中，所述插件管理中心，用于管理一個(gè)或多個(gè)用于進(jìn)行業(yè)務(wù)處理的插件；所述引擎控制中心，用于接收業(yè)務(wù)處理請(qǐng)求，根據(jù)所述業(yè)務(wù)處理請(qǐng)求指示的一個(gè)或多個(gè)參數(shù)從所述插件管理中心獲取一個(gè)或多個(gè)插件，并在獲取到所述插件之后，遠(yuǎn)程調(diào)用所述業(yè)務(wù)調(diào)度器；所述業(yè)務(wù)調(diào)度器，用于確定待調(diào)用的一個(gè)或多個(gè)用于進(jìn)行業(yè)務(wù)處理的業(yè)務(wù)類，并按照預(yù)設(shè)順序調(diào)用所述業(yè)務(wù)類及所述插件，以對(duì)所述業(yè)務(wù)處理請(qǐng)求指示的待處理業(yè)務(wù)進(jìn)行處理。該實(shí)施方式降低了業(yè)務(wù)系統(tǒng)與工作流程的耦合性。

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

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及種一種工作流引擎系統(tǒng)和業(yè)務(wù)處理方法。

背景技術(shù)

工作流(Workflow)是指將工作流程中的工作如何前后組織在一起的邏輯和規(guī)則在計(jì)算機(jī)中以恰當(dāng)?shù)哪Ｐ瓦M(jìn)行表示并實(shí)施工作，而工作流引擎則是指workflow作為業(yè)務(wù)系統(tǒng)的一部分，為業(yè)務(wù)系統(tǒng)根據(jù)角色、分工和條件的不同決定信息傳遞路由、內(nèi)容等級(jí)等方案。

現(xiàn)有的工作流引擎常作為一個(gè)子模塊嵌入到業(yè)務(wù)系統(tǒng)中，以作為一個(gè)整體共同運(yùn)行。如此，現(xiàn)有的工作流引擎至少存在以下技術(shù)問題：當(dāng)業(yè)務(wù)系統(tǒng)存在線程阻塞、運(yùn)行異常等問題時(shí)，工作流引擎也無法正常運(yùn)行；工作流引擎與業(yè)務(wù)系統(tǒng)的代碼耦合性高、擴(kuò)展性低，當(dāng)需要增加新的功能時(shí)需要改動(dòng)的代碼量大；在工作流引擎版本需要更新時(shí)，業(yè)務(wù)系統(tǒng)無法正常運(yùn)行。

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

有鑒于此，本發(fā)明實(shí)施例提供了一種工作流引擎系統(tǒng)和業(yè)務(wù)處理方法，能夠降低業(yè)務(wù)系統(tǒng)與工作流程的耦合性，且能夠?qū)崿F(xiàn)工作流引擎中插件的熱更新，不影響業(yè)務(wù)系統(tǒng)的正常運(yùn)行。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的第一方面，提供了一種工作流引擎系統(tǒng)，包括：插件管理中心、引擎控制中心、業(yè)務(wù)調(diào)度器；其中，

所述插件管理中心，用于管理一個(gè)或多個(gè)用于進(jìn)行業(yè)務(wù)處理的插件；

所述引擎控制中心，用于接收業(yè)務(wù)處理請(qǐng)求，根據(jù)所述業(yè)務(wù)處理請(qǐng)求指示的一個(gè)或多個(gè)參數(shù)從所述插件管理中心獲取一個(gè)或多個(gè)插件，并在獲取到所述插件之后，遠(yuǎn)程調(diào)用所述業(yè)務(wù)調(diào)度器；

所述業(yè)務(wù)調(diào)度器，用于確定待調(diào)用的一個(gè)或多個(gè)用于進(jìn)行業(yè)務(wù)處理的業(yè)務(wù)類，并按照預(yù)設(shè)順序調(diào)用所述業(yè)務(wù)類及所述插件，以對(duì)所述業(yè)務(wù)處理請(qǐng)求指示的待處理業(yè)務(wù)進(jìn)行處理。

可選地，所述插件管理中心，還用于，

在所述插件數(shù)量或所述插件版本存在更新的情況下，通過消息總線廣播插件更新消息。

可選地，所述引擎控制中心，還用于，

在獲取到所述插件之后，將所獲取的插件存儲(chǔ)至本地緩存。

可選地，所述引擎控制中心，還用于，

在根據(jù)所述業(yè)務(wù)處理請(qǐng)求指示的一個(gè)或多個(gè)參數(shù)從所述插件管理中心獲取一個(gè)或多個(gè)插件之前，判斷本地緩存中是否存在所述插件：

若存在，則直接從本地緩存中獲取所述插件，若不存在，則從所述插件管理中心獲取所述插件。

可選地，所述按照預(yù)設(shè)順序調(diào)用所述業(yè)務(wù)類及所述插件，以對(duì)所述業(yè)務(wù)處理請(qǐng)求指示的待處理業(yè)務(wù)進(jìn)行處理，包括：

調(diào)用業(yè)務(wù)類的第一回調(diào)函數(shù)，對(duì)所述待處理業(yè)務(wù)進(jìn)行處理；

調(diào)用所述插件的處理函數(shù)，繼續(xù)對(duì)所述待處理業(yè)務(wù)進(jìn)行處理；

調(diào)用業(yè)務(wù)類的第二回調(diào)函數(shù)，以完成對(duì)所述待處理業(yè)務(wù)的處理。

可選地，使用kubernetes部署所述工作流引擎系統(tǒng)。

為實(shí)現(xiàn)上述目的，根據(jù)本發(fā)明實(shí)施例的第二方面，提供了一種業(yè)務(wù)處理方法，應(yīng)用于工作流引擎系統(tǒng)，包括：