[發(fā)明專利]一種基于消息分段式的工作流引擎以及集群系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201210345577.7
• 申請(qǐng)日: 2012-09-17
• 公開(kāi)（公告）號(hào): CN102902572A
• 公開(kāi)（公告）日: 2013-01-30
• 發(fā)明（設(shè)計(jì)）人: 張敏杰;田應(yīng)生;羅華永
• 申請(qǐng)（專利權(quán)）人: 北京中電普華信息技術(shù)有限公司;國(guó)家電網(wǎng)公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06Q10/06
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

1.一種基于消息分段式的工作流引擎，其特征在于，包括：

渠道層，用于接收用戶的請(qǐng)求，將所述用戶請(qǐng)求轉(zhuǎn)換為具有固定格式的消息，并將所述具有固定格式的消息通過(guò)第一輸出管道發(fā)送至引擎層；

所述引擎層，用于從第一輸出管道中獲取所述具有固定格式的消息，并判斷所述固定格式的消息是否為第三方應(yīng)用，如果否，則將所述具有固定格式的消息轉(zhuǎn)換成引擎的API調(diào)用任務(wù)，根據(jù)所述引擎的API調(diào)用任務(wù)，執(zhí)行相應(yīng)的操作，并將所述任務(wù)完成的消息通過(guò)第一輸入管道返回至所述渠道層，如果是，則將所述具有固定格式的消息通過(guò)第二輸出管道發(fā)送至應(yīng)用調(diào)用層；

所述應(yīng)用調(diào)用層，用于接收所述具有固定格式的消息，并將所述具有固定格式的消息引轉(zhuǎn)化為引擎的API調(diào)用任務(wù)，根據(jù)所述引擎的API調(diào)用任務(wù)，執(zhí)行相應(yīng)的操作，并通過(guò)所述消息組件將所述任務(wù)完成的消息通過(guò)第二輸入管道返回至所述引擎層，以使所述引擎層將所述任務(wù)完成的消息返回至所述渠道層。

2.根據(jù)權(quán)利要求1所述工作流引擎，其特征在于，所述渠道層包括：

請(qǐng)求代理模塊，用于接收用戶的請(qǐng)求，并將所述用戶請(qǐng)求轉(zhuǎn)換為具有固定格式的消息；

第一消息處理模塊，用于將所述具有固定格式的消息通過(guò)第一輸出管道發(fā)送至引擎層。

3.根據(jù)權(quán)利要求2所述工作流引擎，其特征在于，所述渠道層還包括：

第一判斷模塊，用于判斷所述具有固定格式的消息對(duì)應(yīng)的流程是否為請(qǐng)求回調(diào)流程，如果是，則將所述具有固定格式的消息進(jìn)行存儲(chǔ)；

第一標(biāo)記模塊，用于在接收到所述引擎層返回的所述任務(wù)完成的消息后，將存儲(chǔ)的所述具有固定格式的消息的狀態(tài)更改為已完成狀態(tài)。

4.根據(jù)權(quán)利要求1所述工作流引擎，其特征在于，所述引擎層包括：

第二判斷模塊，用于判斷所述具有固定格式的消息是否為第三方應(yīng)用，如果是，則觸發(fā)第二消息處理模塊，如果否，則觸發(fā)第二發(fā)送模塊；

所述第二消息處理模塊，用于將所述具有固定格式的消息引轉(zhuǎn)化為引擎的API調(diào)用任務(wù)；

引擎線程管理模塊，用于存儲(chǔ)所述引擎的API調(diào)用任務(wù)；

引擎核心模塊，用于根據(jù)所述引擎線程管理模塊存儲(chǔ)的所述引擎的API調(diào)用任務(wù)，執(zhí)行相應(yīng)的操作；

第一發(fā)送模塊，用于將所述任務(wù)完成的消息通過(guò)第一輸入管道返回至所述渠道層；

所述第二發(fā)送模塊，用于將所述具有固定格式的消息通過(guò)第二輸出管道發(fā)送至應(yīng)用調(diào)用層。

5.根據(jù)權(quán)利要求4所述工作流引擎，其特征在于，所述應(yīng)用調(diào)用層包括：

第三消息處理模塊，用于將所述具有固定格式的消息引轉(zhuǎn)化為引擎的API調(diào)用任務(wù)；

調(diào)用層程管理模塊，用于存儲(chǔ)所述引擎的API調(diào)用任務(wù)；

調(diào)度模塊，用于根據(jù)所述調(diào)用層程管理模塊中的所述引擎的API調(diào)用任務(wù)，執(zhí)行相應(yīng)的操作；

第二標(biāo)記模塊，用于將存儲(chǔ)的所述引擎的API調(diào)用任務(wù)的狀態(tài)更改為已完成狀態(tài)；

第三發(fā)送模塊，用于將所述任務(wù)完成的消息通過(guò)第二輸入管道返回至所述引擎層。

6.根據(jù)權(quán)利要求5所述工作流引擎，其特征在于，所述應(yīng)用調(diào)用層還包括：

第三判斷模塊，用于判斷所述具有固定格式的消息對(duì)應(yīng)的流程是否為異步調(diào)用流程，如果是，則觸發(fā)所述第二標(biāo)記模塊，如果否，則觸發(fā)所述調(diào)度模塊。

7.一種集群系統(tǒng)，其特征在于，包括：第一預(yù)設(shè)值個(gè)如權(quán)利要求1中所述的渠道層，第二預(yù)設(shè)值個(gè)如權(quán)利要求1中所述的引擎層以及第三預(yù)設(shè)值個(gè)如權(quán)利要求1中所述應(yīng)用調(diào)用層。