jBPM4實現(xiàn)基本活動（下）
5.5. 基本流程執(zhí)行
在下一個例子里，我們會結(jié)合自動活動和等待狀態(tài)。 這里例子構(gòu)建了貸款審批流程，使用WaitState 和Display活動，我們剛剛創(chuàng)建的。 貸款流程的圖形看起來像這樣：
貸款流程
圖 5.3. 貸款流程
使用Java構(gòu)建流程圖形是很乏味的事情， 因為你必須在局部變量中跟蹤所有的引用。 為了解決這個問題，流程虛擬機提供了一個ProcessFactory。 ProcessFactory是一種領(lǐng)域特定語言（DSL），可以嵌入到Java中， 簡化流程圖形的結(jié)構(gòu)。這個模型也叫做 流暢接口。
- ClientProcessDefinition processDefinition = ProcessFactory.build("loan")
- .activity("submit loan request").initial().behaviour(new Display("loan request submitted"))
- .transition().to("evaluate")
- .activity("evaluate").behaviour(new WaitState())
- .transition("approve").to("wire money")
- .transition("reject").to("end")
- .activity("wire money").behaviour(new Display("wire the money"))
- .transition().to("archive")
- .activity("archive").behaviour(new WaitState())
- .transition().to("end")
- .activity("end").behaviour(new WaitState())
- .done();
為了了解ProcessFactory的更多細節(jié)，可以參考 api文檔。 ProcessFactory的另一種選擇是創(chuàng)建一個XML語言和一個XML解析器，來表示流程。 XML解析器可以直接實例化 org.jbpm.pvm.internal.model包中的類。 這種方式一般都被流程語言選擇使用。
初始化活動submit loan request和 wire the money活動是自動活動。 在這個例子中，wire the money活動的 Display實現(xiàn) 使用Java API來把信息輸出到控制臺上。但是讀取器可以想象一個可選的 Activity實現(xiàn)，使用支付流程庫的Java API 來實現(xiàn)一個真實的自動支付。
上述流程的一個新執(zhí)行可以像下面這樣啟動
ClientExecution execution = processDefinition.startProcessInstance();
當(dāng)startExecution方法返回時， submit loan request活動會被執(zhí)行， 執(zhí)行會位于evaluate活動。
位于'evaluate'活動的執(zhí)行
圖 5.4. 位于'evaluate'活動的執(zhí)行
現(xiàn)在，執(zhí)行處在一個很有趣的點。這里有兩個轉(zhuǎn)移從evaluate指向外邊。 一個轉(zhuǎn)移叫approve 一個轉(zhuǎn)移叫reject。像我們上面解釋的， WaitState實現(xiàn)會根據(jù)執(zhí)行的signal選擇轉(zhuǎn)移。 讓我們像這樣執(zhí)行'approve' signal：
execution.signal("approve");
這個approve signal會導(dǎo)致執(zhí)行選擇approve轉(zhuǎn)移 它會到達wire money活動。
在wire money活動中，信息會打印到控制臺里。 因為Display沒有調(diào)用execution.waitForSignal()， 也沒有調(diào)用其他執(zhí)行傳播方法， 默認流程行為只會讓執(zhí)行繼續(xù)， 使用向外的轉(zhuǎn)移到達archive活動， 這也是一個WaitState。
位于'archive'活動的執(zhí)行
圖 5.5. 位于'archive'活動的執(zhí)行
所以只有當(dāng)archive到達時， signal("approve")會返回。
另一個signal就像這樣：
- execution.signal("approve");
將讓執(zhí)行最終到達結(jié)束狀態(tài)。
位于'end'活動的執(zhí)行
圖 5.6. 位于'end'活動的執(zhí)行
5.6. 事件
事件位于流程定義中， 一系列的EventListener可以進行注冊。
- public interface EventListener extends Serializable {
- void notify(EventListenerExecution execution) throws Exception;
- }
事件的目的是讓開發(fā)者可以為流程添加程序邏輯， 不必改變流程圖。 這是非常有價值的機制，可以促進業(yè)務(wù)分析人員和開發(fā)者之間的協(xié)作。 業(yè)務(wù)分析人員負責(zé)描述需求。 當(dāng)他們使用流程圖歸檔那些需求， 開發(fā)者可以獲得這些圖形，讓它可執(zhí)行化。 事件會非常方便，向一個流程中添加技術(shù)細節(jié)（比如一些數(shù)據(jù)庫插入操作） 這些都是業(yè)務(wù)分析人員不感興趣的東西。
最常用的事件是由執(zhí)行自動觸發(fā)的：
TODO: 在用戶手冊中解釋事件
事件是由流程元素和事件名稱結(jié)合而成。 用戶和流程語言也可以出發(fā)事件， 使用編程的方式在流程中使用fire方法。
- public interface Execution extends Serializable {
- ...
- void fire(String eventName, ProcessElement eventSource);
- ...
- }
可以把一系列的EventListeners分配給一個事件。 但是事件監(jiān)聽器不能控制執(zhí)行的流向， 因為它們僅僅是監(jiān)聽已經(jīng)執(zhí)行了的執(zhí)行。 這與活動處理活動的行為是不同的。 活動行為可以響應(yīng)執(zhí)行的傳播。
我們會創(chuàng)建一個PrintLn事件監(jiān)聽器， 這與上面的Display活動是非常相似的。
- public class PrintLn implements EventListener {
- String message;
- public PrintLn(String message) {
- this.message = message;
- }
- public void notify(EventListenerExecution execution) throws Exception {
- System.out.println("message");
- }
- }
多個PrintLn監(jiān)聽器 會在流程中注冊。
PrintLn監(jiān)聽器流程
圖 5.7. PrintLn監(jiān)聽器流程
- ClientProcessDefinition processDefinition = ProcessFactory.build()
- .activity("a").initial().behaviour(new AutomaticActivity())
- .event("end")
- .listener(new PrintLn("leaving a"))
- .listener(new PrintLn("second message while leaving a"))
- .transition().to("b")
- .listener(new PrintLn("taking transition"))
- .activity("b").behaviour(new WaitState())
- .event("start")
- .listener(new PrintLn("entering b"))
- .done();
***個事件演示如何為相同的事件注冊多個監(jiān)聽器。 它們會根據(jù)它們指定的順序依次執(zhí)行。
然后，在轉(zhuǎn)椅上，這里的事件只有一種類型。 所以在那種情況下，事件類型不需要指定， 監(jiān)聽器可以直接添加到轉(zhuǎn)移上。
一個監(jiān)聽器每次都會執(zhí)行，當(dāng)一個執(zhí)行觸發(fā)事件時，如果這個監(jiān)聽器被注冊了。 執(zhí)行會作為一個參數(shù)提供給活動接口， 除了控制流程傳播的方法以外， 都可以被監(jiān)聽器使用。
5.7. 事件傳播
事件會默認傳播給最近的流程元素。 目的是允許監(jiān)聽器在流程定義或組合活動中 可以執(zhí)行所有發(fā)生在流程元素中的事件。 比如這個功能允許為end事件在流程定義或一個組合活動中注冊一個事件監(jiān)聽器。 這種動作會被執(zhí)行，如果一個活動離開。 如果事件監(jiān)聽器被注冊到一個組合活動中， 它也會被所有活動執(zhí)行，當(dāng)組合活動中出現(xiàn)了離開事件。
為了清楚地顯示這個，我們會創(chuàng)建一個DisplaySource事件監(jiān)聽器， 這會把leaving信息和事件源 打印到控制臺。
- public class DisplaySource implements EventListener {
- public void execute(EventListenerExecution execution) {
- System.out.println("leaving "+execution.getEventSource());
- }
- }
注意事件監(jiān)聽器的目的不是可視化，這是為什么事件監(jiān)聽器本身 不應(yīng)該顯示在圖形中。一個DisplaySource事件監(jiān)聽器 會作為end事件的監(jiān)聽器添加到組合活動中。
下一個流程展示了DisplaySource事件監(jiān)聽器如何 作為'end'事件的監(jiān)聽器注冊到composite活動：
一個在組合活動中為end事件注冊了不可見的事件監(jiān)聽器的流程。
圖 5.8. 一個在組合活動中為end事件注冊了不可見的事件監(jiān)聽器的流程。
TODO 更新代碼片段
下一步，我們會啟動一個執(zhí)行。
ClientExecution execution = processDefinition.startProcessInstance();
在啟動一個新執(zhí)行后，執(zhí)行將在a活動中 作為初始活動。沒有活動離開，所以沒有信息被記錄下來。 下一個signal會給與執(zhí)行， 導(dǎo)致它選擇從a到b。
execution.signal();
當(dāng)signal方法返回，執(zhí)行會選擇轉(zhuǎn)移 然后end事件會被a活動觸發(fā)。 那個組合活動會被傳播到組合活動和流程定義中。 因為我們的DisplaySource 監(jiān)聽器放到 composite活動中， 它會接收事件，把下面的信息打印到控制臺中：
leaving activity(a)
另一個
execution.signal();
會選擇b到c的轉(zhuǎn)移。那會觸發(fā)兩個活動離開事件。 一個在b活動，一個在組合活動。 所以下面的幾行會添加到控制臺輸出中：
leaving activity(b)
leaving activity(composite)
事件傳播建立在流程定義的繼承組合結(jié)構(gòu)中。 ***元素總是流程定義。 流程定義包含一系列活動。每個活動可以是葉子活動或者可以是一個組合節(jié)點， 這意味著它包含了一系列內(nèi)嵌活動。 內(nèi)嵌活動可以被使用，比如超級狀態(tài)或組合活動，在內(nèi)嵌流程語言中，像BPEL。
所以事件模型在組合活動和上面的流程定義中的功能是相似的。 想象'Phase one'模型一個超級狀態(tài)作為一個狀態(tài)機。 然后事件傳播允許在超級狀態(tài)中注冊所有事件。 這個主意是繼承組合響應(yīng)圖形展示。 如果一個'e'元素畫在另一個'p'元素中， 'p'是'e'的父節(jié)點。一個流程定義擁有一系列定義活動。 每個活動可以擁有一系列內(nèi)嵌活動。 一個轉(zhuǎn)移的父節(jié)點就是它的源頭和目的的***個父節(jié)點。
如果一個事件監(jiān)聽器對傳播的事件沒有興趣， 可以在構(gòu)建流程使用ProcessFactory的propagationDisabled()。 下一個流程是與上面相同的流程， 除了傳播的事件會被事件監(jiān)聽器禁用。 圖形還是一樣。
注冊到'end'事件的事件監(jiān)聽器被禁用的流程。
圖 5.9. 注冊到'end'事件的事件監(jiān)聽器被禁用的流程。
使用流程工廠構(gòu)建流程：
TODO 更新代碼
所以當(dāng)***個signal在流程中調(diào)用時，end事件 會再次觸發(fā)在a活動上，但是現(xiàn)在在組合活動的事件監(jiān)聽器 不會被執(zhí)行，因為傳播的事件被禁用了。 禁用傳播是單獨的事件監(jiān)聽器的一個屬性， 不會影響其他監(jiān)聽器。事件會一直被觸發(fā)， 傳播到整個父繼承結(jié)構(gòu)。
ClientExecution execution = processDefinition.startProcessInstance();
***個signal會選擇從a到b的流程。 沒有信息會被打印到控制臺。
execution.signal();
下一步，第二個signal會選擇從b到c的轉(zhuǎn)移。
execution.signal()
還是兩個end事件被觸發(fā)， 就像上面分別在b和composite活動中。 ***個事件是b活動上的 end事件。 那將被傳播給composite活動。 所以事件監(jiān)聽器不會為這個事件執(zhí)行，因為它已經(jīng)禁用了傳播。 但是事件監(jiān)聽器會在composite活動上 為end事件執(zhí)行。 那是不傳播的，但是直接在composite活動上觸發(fā)。 所以事件監(jiān)聽器現(xiàn)在會被執(zhí)行 一次，為組合活動，就像下面控制臺里顯示的那樣：
leaving activity(composite)
【編輯推薦】
