[發(fā)明專利]一種業(yè)務(wù)流程的處理方法及相關(guān)裝置和服務(wù)器

在審

• 申請?zhí)枺?/td>: 201611219300.4
• 申請日: 2016-12-26
• 公開（公告）號: CN107656820A
• 公開（公告）日: 2018-02-02
• 發(fā)明（設(shè)計(jì)）人: 方敏
• 申請（專利權(quán)）人: 武漢票據(jù)交易中心有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06Q10/10
• 代理公司: 北京匯澤知識(shí)產(chǎn)權(quán)代理有限公司11228
• 代理人: 程殿軍,張瑾

1.一種業(yè)務(wù)流程的處理方法，用于應(yīng)用服務(wù)器，其特征在于，包括：

在啟動(dòng)時(shí)，將各類交易下各業(yè)務(wù)流程對應(yīng)的狀態(tài)機(jī)信息緩存，并分別啟動(dòng)用于處理服務(wù)器事件的線程池和狀態(tài)機(jī)流轉(zhuǎn)引擎線程池；

當(dāng)從消息服務(wù)器中監(jiān)聽到本應(yīng)用服務(wù)器處理的服務(wù)器事件時(shí)，讀取該事件；

根據(jù)該服務(wù)器事件對應(yīng)流程，從狀態(tài)機(jī)流轉(zhuǎn)引擎線程池中調(diào)用對應(yīng)的狀態(tài)機(jī)流轉(zhuǎn)引擎線程，通過所述狀態(tài)機(jī)流轉(zhuǎn)引擎線程，讀取預(yù)先緩存的狀態(tài)機(jī)信息中定義的流程數(shù)據(jù)，確定下個(gè)操作狀態(tài)和處理該服務(wù)器事件的類；

從處理服務(wù)器事件的線程池中，調(diào)用所述處理該服務(wù)器事件的類的線程，并通過處理該服務(wù)器事件的類的線程，處理所述服務(wù)器事件得到處理結(jié)果；

將處理結(jié)果生成服務(wù)器事件并發(fā)送至消息服務(wù)器，并更新數(shù)據(jù)庫服務(wù)器中的數(shù)據(jù)庫數(shù)據(jù)。

2.如權(quán)利要求1所述的方法，其特征在于，所述狀態(tài)機(jī)信息包括：

狀態(tài)機(jī)的標(biāo)識(shí)、狀態(tài)標(biāo)識(shí)、狀態(tài)名稱、當(dāng)前狀態(tài)對應(yīng)的操作/事件、下一個(gè)狀態(tài)的標(biāo)識(shí)和下一個(gè)狀態(tài)的名稱和處理該事件的類。

3.如權(quán)利要求2所述的方法，其特征在于，所述根據(jù)該服務(wù)器事件對應(yīng)流程，從狀態(tài)機(jī)流轉(zhuǎn)引擎線程池中調(diào)用對應(yīng)的狀態(tài)機(jī)流轉(zhuǎn)引擎線程，通過所述狀態(tài)機(jī)流轉(zhuǎn)引擎線程，讀取緩存的狀態(tài)機(jī)信息中定義的流程數(shù)據(jù)，確定下個(gè)操作狀態(tài)和處理該服務(wù)器事件的類，包括：

從所述服務(wù)器事件中解析出交易信息和流程信息；

從所緩存的各流程對應(yīng)的狀態(tài)機(jī)信息中，確定所述交易下所述流程對應(yīng)的狀態(tài)機(jī)信息；

從狀態(tài)機(jī)流轉(zhuǎn)引擎線程池中調(diào)用對應(yīng)的狀態(tài)機(jī)流轉(zhuǎn)引擎線程；

通過對應(yīng)的狀態(tài)機(jī)流轉(zhuǎn)引擎線程，查詢所述狀態(tài)機(jī)信息，根據(jù)所述交易下所述流程的當(dāng)前狀態(tài)、當(dāng)前狀態(tài)對應(yīng)的操作/事件，得到下個(gè)狀態(tài)的標(biāo)識(shí)和處理該事件的類。

4.如權(quán)利要求1所述的方法，其特征在于，所述處理服務(wù)器事件的線程池和狀態(tài)機(jī)流轉(zhuǎn)引擎線程池中的線程的數(shù)量，根據(jù)服務(wù)器事件的數(shù)量動(dòng)態(tài)增加或減少。

5.如權(quán)利要求1-4任一項(xiàng)所述的方法，其特征在于，所述讀取該服務(wù)器事件之后，還包括：將所述服務(wù)器事件所屬的服務(wù)器之間的消息類型，轉(zhuǎn)換成本應(yīng)用服務(wù)器處理的消息類型；

所述處理結(jié)果生成服務(wù)器事件，包括：

將所述處理結(jié)果，按照所述服務(wù)器之間的消息類型進(jìn)行封裝，生成服務(wù)器事件。

6.如權(quán)利要求1-4任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

當(dāng)通過處理該服務(wù)器事件的類的線程，處理所述服務(wù)器事件成功時(shí)，更新所述流程的狀態(tài)為所述下一個(gè)狀態(tài)；

將交易信息、流程的狀態(tài)信息和處理結(jié)果生成服務(wù)器事件并發(fā)送給消息服務(wù)器；

否則，結(jié)束所述流程的處理，并通告中控客戶端。

7.一種業(yè)務(wù)流程的處理裝置，其特征在于，包括：

緩存模塊，用于在啟動(dòng)時(shí)，將各類交易下業(yè)務(wù)流程對應(yīng)的狀態(tài)機(jī)信息緩存；

線程池啟動(dòng)模塊，用于在啟動(dòng)時(shí)，分別啟動(dòng)用于處理服務(wù)器事件的線程池和狀態(tài)機(jī)流轉(zhuǎn)引擎線程池；

消息讀取模塊，用于當(dāng)從消息服務(wù)器中監(jiān)聽到本應(yīng)用服務(wù)器處理的服務(wù)器事件時(shí)，讀取該事件；

狀態(tài)流轉(zhuǎn)模塊，用于根據(jù)該服務(wù)器事件對應(yīng)流程，從狀態(tài)機(jī)流轉(zhuǎn)引擎線程池中調(diào)用對應(yīng)的狀態(tài)機(jī)流轉(zhuǎn)引擎線程，通過所述狀態(tài)機(jī)流轉(zhuǎn)引擎線程，讀取預(yù)先緩存的狀態(tài)機(jī)信息中定義的流程數(shù)據(jù)，確定下個(gè)操作狀態(tài)和處理該服務(wù)器事件的類；

事件處理模塊，用于從處理服務(wù)器事件的線程池中，調(diào)用所述處理該服務(wù)器事件的類的線程，并通過處理該服務(wù)器事件的類的線程，處理所述服務(wù)器事件得到處理結(jié)果；

生成模塊，用于將處理結(jié)果生成服務(wù)器事件；

發(fā)送模塊，用于將所述生成模塊生成的服務(wù)器事件發(fā)送給消息服務(wù)器；

數(shù)據(jù)更新模塊，用于根據(jù)所述處理結(jié)果，更新數(shù)據(jù)庫服務(wù)器中的數(shù)據(jù)庫數(shù)據(jù)。

8.如權(quán)利要求7所述的裝置，其特征在于，所述狀態(tài)機(jī)信息包括：

狀態(tài)機(jī)的標(biāo)識(shí)、狀態(tài)標(biāo)識(shí)、狀態(tài)名稱、當(dāng)前狀態(tài)對應(yīng)的操作/事件、下一個(gè)狀態(tài)的標(biāo)識(shí)和下一個(gè)狀態(tài)的名稱和處理該事件的類。