王劍冰

一種基于流程的高效引擎開發(fā)

王劍冰

(北京福富軟件技術(shù)股份有限公司福州分公司，福建，福州 350013)

在某些業(yè)務環(huán)境下，對實時的處理要求較高，需要由高效的流程引擎來帶動的業(yè)務功能運行。高效流程引擎使用C/C++編寫引擎內(nèi)核，使用共享內(nèi)存作為流程定義和流程實例等相關(guān)數(shù)據(jù)的緩存，并使用高效、交互性好、易擴展的Lua腳本作為流程引擎部分類型節(jié)點的嵌入式執(zhí)行內(nèi)容。同時，使用流程加載和日志落地等模塊，使得持久層和緩存之間進行同步，不影響流程引擎核心的執(zhí)行效率。通過以上各方面的優(yōu)化提高了流程引擎整體的執(zhí)行效率。

流程引擎；Lua腳本語言；C/C++；共享內(nèi)存

業(yè)務流程管理一詞通常是指企業(yè)通過一系列活動，以能夠適應動態(tài)變化的環(huán)境的方式，自動管理及優(yōu)化流程。業(yè)務流程可以被定義為一個由各種不同功能的活動相連的一組有相互關(guān)系的任務，它們依照一定的業(yè)務邏輯和順序依次執(zhí)行，業(yè)務流程有起點和終點，而且它們都是可以重復的。業(yè)務流程管理（BPM）正在迅速成為企業(yè)獲得軟件敏捷性和適應性的重要方法。近年來，基于流程引擎技術(shù)構(gòu)建的應用系統(tǒng)越來越受到客戶的追捧和認可，能否支持流程可定制、可更改、可運行的目標，也逐漸成為客戶衡量一個應用系統(tǒng)主要標準之一[1]。目前國外有關(guān)流程引擎的產(chǎn)品有很多，如jBPM[2]、OSWorkflow、Apache ODE、WebSphere Process Server、Oracle Aqulogic、Microsoft BizTalk等。在國內(nèi)，主要是在上述幾個引擎基礎(chǔ)上做擴展和應用，而且絕大部分是使用Java或C#實現(xiàn)，主要是因為電子商務的在流程引擎方面的應用較多，流程引擎中的節(jié)點調(diào)用的業(yè)務相對流程引擎本身的性能要慢得多，流程引擎的優(yōu)化對整個流程的執(zhí)行效率影響不明顯[3]，所以對于性能優(yōu)化的側(cè)重點一般不在流程引擎本身，但是，對于非電子商務的系統(tǒng)，尤其是某些對實時性要求較高的系統(tǒng)，如電信計費系統(tǒng)，業(yè)務網(wǎng)關(guān)等，流程引擎節(jié)點調(diào)用的業(yè)務執(zhí)行速度很快，如果流程引擎不夠優(yōu)化，對整個流程執(zhí)行的效率影響就比較大。流程引擎的主要功能是執(zhí)行業(yè)務流程，是BPM的架構(gòu)核心，其設(shè)計好壞、效率高低直接影響到整個BPM的性能高低。C/C++語言的主要特性就是高效，與操作系統(tǒng)底層交互良好，高效流程引擎應基于C/C++來編寫[4]。

1 高效流程引擎設(shè)計

1.1 流程引擎總體架構(gòu)

一個流程引擎包括很多模塊，其內(nèi)核主要是流程加載、流程執(zhí)行和數(shù)據(jù)同步，提高流程引擎的性能，就必須提高流程引擎執(zhí)行內(nèi)核的效率，讓流程的執(zhí)行環(huán)境在內(nèi)存中進行，所以架構(gòu)中引入了緩存部分，設(shè)計專門的流程加載模塊可以將配置數(shù)據(jù)向緩存中加載，同時還設(shè)計專門的數(shù)據(jù)同步模塊能將緩存中執(zhí)行結(jié)束的流程實例同步到持久層（數(shù)據(jù)庫或文件），而流程引擎的使用者通過接口調(diào)用流程執(zhí)行的時候只會在緩存中進行，故而能提高流程引擎的性能。高效流程引擎總體架構(gòu)圖如圖1所示。

圖1 高效流程引擎架構(gòu)

從圖1可以看出，業(yè)務流程必然和功能模塊打交道，可以將一些功能模塊編寫成動態(tài)庫，以便在流程中動態(tài)加載并被流程直接調(diào)用，模塊化調(diào)用增強了執(zhí)行的效率。另外為支持靈活性和維護的方便性，需要引入一些即時生效的腳本作為節(jié)點的執(zhí)行內(nèi)容。從執(zhí)行效率以及接口效率來評估，使用C/C++語言作為流程引擎核心的編寫語言，而采用和C/C++語言交互性好且執(zhí)行效率很高的腳本語言Lua，是比較合適的方案。

1.2 流程定義

流程引擎的設(shè)計是面向圖的設(shè)計，流程是由兩個最基本的元素組成：“節(jié)點”及“有向連接”。對于“有向連接”幾乎沒有任何歧義，所有的流程建模描述中“有向連接”都是存在“From”和“To”這兩個特性。但是對于“節(jié)點”，則因為所處的視角、功能不同，則存在很多不同的理解，比如WFMC的過程定義元模型、jBPM、EPC中對節(jié)點含義和種類的定義都不太相同[5]。高效流程引擎中的節(jié)點類型包含：開始、結(jié)束、函數(shù)、腳本、狀態(tài)、分支（并行、判斷）、匯聚等，如圖2所示。

圖2 節(jié)點連接圖

各節(jié)點既有共性也有個性，從流程定義的角度，將節(jié)點抽象為父類，各種類型的節(jié)點繼承節(jié)點父類，并增加自己的屬性、函數(shù)，以及實現(xiàn)節(jié)點執(zhí)行函數(shù)。各節(jié)點的類圖關(guān)系如圖3所示。

圖3 節(jié)點類關(guān)系

將節(jié)點類設(shè)計為一個抽象類，它包含了純虛函數(shù)virtual execute()=0，在執(zhí)行流程時以父類對象指針指向最終節(jié)點類的對象，并調(diào)用父類對象指針的execute函數(shù)，則實際會調(diào)用最終子類中的所實現(xiàn)的execute成員函數(shù)。在流程引擎中我們?nèi)コ擞邢蚓€連接對象，即jBPM中的Transition，使用每個節(jié)點的前驅(qū)或后續(xù)節(jié)點號的方式來貫穿整個流程。任何流程的開始節(jié)點號都定義為0。

1.3 流程解析與加載

前臺配置的流程的定義是存儲在數(shù)據(jù)庫中的，一般的流程引擎的做法是每次連續(xù)的執(zhí)行都要到數(shù)據(jù)庫中去讀取流程配置，這樣勢必造成I/O的增加，降低流程引擎的性能。由于流程定義的讀頻率要遠遠高于寫頻率，所以，要保證流程的高速運轉(zhuǎn)，必須將流程定義加載到內(nèi)存中，并且解決好讀寫的沖突問題。

流程定義緩存主要分為共享內(nèi)存和私有內(nèi)存兩部分，共享內(nèi)存是流程定義索引區(qū)和流程定義區(qū)，這部分可以由所有調(diào)用者的程序共享讀??；私有內(nèi)存是腳本加載區(qū)和動態(tài)庫加載區(qū)，在程序啟動的時候需加載和初始化。流程索引是根據(jù)流程定義ID以及流程的版本號查找流程定義存放的地址的區(qū)域，為了加速流程定義的查找速度。流程定義使用xml格式配置，調(diào)用rapidxml[6]開源程序中的函數(shù)進行解析，并將配置按類的定義以序列化方式保存在共享內(nèi)存的流程定義中。

由于流程的執(zhí)行是一個持續(xù)的過程，在流程實例未結(jié)束之前，改流程實例使用的流程配置都應該保持在內(nèi)存中且不能被改動。對于新增的流程，在流程定義區(qū)新開辟空間并上載新流程定義，上載完成后鎖定流程定義索引區(qū)，更新Hash(流程定義ID，流程版本)和流程定義存放地址的對應關(guān)系，然后解鎖；對于要刪除的流程，一般是將該流程打上刪除標志而不是立即刪除，由流程上載模塊負責查詢沒有使用該流程定義的流程實例后將其刪除并回收空間；對于修改的流程，采用升級的方式處理，也就是先將新的流程加載到新開辟的流程區(qū)，并更新流程定義索引區(qū)，新的流程實例會按新版本執(zhí)行，當使用舊版本的流程實例全部結(jié)束后，流程上載模塊會將舊版本的流程定義刪除并回收空間。通過這樣的增、刪、改的機制可以解決流程定義讀寫的沖突。

1.4 流程腳本

腳本具有靈活性強、能立即生效等特點，在流程引擎的節(jié)點中使用腳本可以帶來靈活性和擴展性和高效性。Lua腳本語言是用標準C編寫而成的嵌入式腳本語言和C/C++有良好的交互性，能為應用程序提供靈活的擴展和定制功能，而且?guī)缀踉谒胁僮飨到y(tǒng)和平臺上都可以編譯和運行。Lua是腳本語言中執(zhí)行效率最高且很輕量級，內(nèi)存占用很少[7]。

經(jīng)過對相同的浮點數(shù)運算程序測試，以C語言(編譯器gcc 4.0.1)為基準，進行速度測試，可得出如圖4的各種腳本語言執(zhí)行效率的對比數(shù)據(jù)。

圖4 腳本語言效率對比

Lua和C語言的交互，一般是Lua嵌入到C/C++程序中，簡單的功能可以直接由Lua函數(shù)提供，如果Lua完成不了的，也可以編寫可由Lua調(diào)用的C/C++接口函數(shù)，讓Lua起到橋梁作用，快速重組這些接口函數(shù)。

1.5 流程監(jiān)控

流程的執(zhí)行過程在后臺進行，流程引擎需要提供對流程實例執(zhí)行情況的監(jiān)控。流程實例中的節(jié)點狀態(tài)、執(zhí)行時間、流程變量值等的都在共享內(nèi)存區(qū)中可以通過IPC進行訪問，流程引擎為監(jiān)控提供了一系列查詢接口供同主機的外部進程訪問，并且可以在此基礎(chǔ)上封裝成監(jiān)控服務，供遠程主機訪問和顯示。由于在共享內(nèi)存中進行查詢開銷較少，所以可以提供較為實時的監(jiān)控。

1.6 流程日志

一個流程實例執(zhí)行結(jié)束的流程引擎會產(chǎn)生一個消息存放在隊列中，由入庫模塊將流程實例執(zhí)行的成功與否以及各節(jié)點執(zhí)行情況和時間保存到數(shù)據(jù)庫，相當于記錄了流程的執(zhí)行軌跡，并將該流程實例從共享內(nèi)存中的空間釋放出來。

流程入庫程序可以是多線程并行執(zhí)行，并且是在流程結(jié)束后才進行，而且實例與監(jiān)控區(qū)的共享內(nèi)存空間較大，可以是對多個流程的批量處理，所以如果配置合適，并且流程實例的執(zhí)行壓力不是特別大的情況，基本不會形成性能瓶頸。關(guān)閉流程引擎將共享內(nèi)存中的所有數(shù)據(jù)落地到文件，重新啟動時則從文件上載到共享內(nèi)存，如果主機在流程實例未執(zhí)行完成的時候出現(xiàn)崩潰，則因共享內(nèi)存數(shù)據(jù)失去，流程實例數(shù)據(jù)將會丟失，這是一種缺陷，但這是流程執(zhí)行效率和數(shù)據(jù)安全之間的一種權(quán)衡的結(jié)果。

2 測試與分析

2.1 測試環(huán)境

該測試的實驗環(huán)境是：操作系統(tǒng)AIX 6.1，主機CPU 3.5GHZ，主機內(nèi)存8G的臺式機；開發(fā)工具為Java編譯器Java1.6，C++編譯器xlC 。

2.2 測試數(shù)據(jù)

在jBPM和高效率流程引擎都配置一個相同的流程定義如圖5。其中節(jié)點1腳本節(jié)點，功能是設(shè)置一個整數(shù)型的流程變量值。節(jié)點2為判斷節(jié)點，功能是將變量值取出，并將其乘以1.5加0.01，判斷結(jié)果是否大于3。節(jié)點3為業(yè)務功能節(jié)點，操作是對變量進行500次浮點加減乘除運算。節(jié)點4為狀態(tài)節(jié)點，無操作。

圖5 測試流程

2.3 測試結(jié)果

分別編寫Java程序和C++程序?qū)?.2中的準備的完全相同的流程定義調(diào)用兩種流程引擎（jBPM和高效流程引擎）進行流程定義加載、流程實例創(chuàng)建和實例執(zhí)行的速度測試。各進行5組測試。流程定義加載效率測試和流程實例執(zhí)行測試的結(jié)果如表1所示。

表1 流程引擎加載與流程實例執(zhí)行測試

從表1測試結(jié)果可以得出，高效流程引擎的效率遠遠高于jBPM，分析其主要原因是jBPM的流程加載和流程執(zhí)行的每一步都對數(shù)據(jù)庫進行了操作，增加了大量的I/O開銷，而高效流程引擎使用共享內(nèi)存；并且jBPM使用的是Java語言，本身執(zhí)行效率上不如高效流程引擎使用的C/C++語言效率高。該測試數(shù)據(jù)的結(jié)果也表明可滿足大多數(shù)系統(tǒng)應用中對流程引擎的性能要求。

3 結(jié)束語

在某些業(yè)務要求下，流程引擎除了注重功能還需注重性能。C/C++語言是當前執(zhí)行效率最高的語言[8]，Lua腳本是效率最高的腳本，且和C/C++語言的交互性以及自身擴展性都很強，高效流程引擎使用C++作為引擎核心的編寫語言，使用Lua作為腳本節(jié)點以及判斷節(jié)點的應用，從程序執(zhí)行方面對性能進行了提高。流程引擎在執(zhí)行過程中對流程定義的讀取以及日志的保存如果都使用數(shù)據(jù)庫或者文件，會給性能帶來較大瓶頸，所以高效流程引擎使用共享內(nèi)存作為流程定義、流程實例、流程日志等的數(shù)據(jù)緩存，并使用其他模塊來對流程定義進行加載和日志的落地。高效流程引擎從各個方面提高了流程引擎的性能，經(jīng)過測試達到了業(yè)務系統(tǒng)對性能的要求。

[1] 胡長城. 工作流的微內(nèi)核架構(gòu)[EB/OL].http://gocom. primeton.com/modules/gSpace/modules/techresource/article1803.htm, 2007-9-7.

[2] 胡長城. 揭秘jbpm流程引擎內(nèi)核設(shè)計思想及構(gòu)架[EB/OL].http://www.uml.org.cn/workclass/200709305.asp, 2007-9-22.

[3] 何智華,王力生. 基于Web服務的電子商務業(yè)務流程中間件引擎的研究[J].計算機應用, 2004(11):135-138.

[4] 陳蘭新. 基于C++的BPEL流程引擎原型的設(shè)計與實現(xiàn)[D]. 廣州:華南理工大學,2009.

[5] 胡奇. jBPM4工作流應用開發(fā)指南[M].北京:電子工業(yè)出版社，2010.

[6] Marcin Kalicinski. RAPIDXML Manual[EB/OL].http:// rapidxml.sourceforge.net/manual.html, 2009-8-2.

[7] Roberto Ierusalimschy. Programming in Lua[EB/OL]. http://www.lua.org/pil/, 2012-3-4

[8] 盧曉苗,李從龍,張建明. 一例Java語言與C語言代碼運行效率的比較[J]. 現(xiàn)代計算機(專業(yè)版), 2010(1): 116-118.

Development of High-performance and Flexible Process Engine

WANG Jian-bing

(Beijing Forich Software Technology Co., Ltd. Fuzhou Branch, Fuzhou , Fujiang 350013, China)

High real-time processing is required in some business environments, and then the high-performance process engine is needed to drive the business functions running. The core of high-performance process engine is written by C/C++, shared memory is used as a data cache for process definition and process instance, and the Lua script, which is efficient, interactive, easy to extend, is embedded in the execution content of some nodes of process engine. At the same time, the module of process loading and log storage synchronize the persistence layer and cache, the core of process engine is not affected. Through the optimization of the above aspects, the overall performance of the process engine is improved.

process engine; Lua script language; C/C++; share memory

TP391

A

10.3969/j.issn.1674-8085.2012.04.014

1674-8085(2012)04-0061-05

2012-02-24；

2012-03-27

王劍冰(1975-)，男，福建浦城人，工程師，主要從事引擎開發(fā)、數(shù)據(jù)庫優(yōu)化研究(E-mail: wangjb@ffcs.cn).