jBPM4的架構(gòu)
4.1. APIs
流程虛擬機(jī)包含4個(gè)集成的API，在不同的執(zhí)行模式下， 覆蓋完整的流程工作。 每個(gè)API都有特定的目的， 滿足下面的架構(gòu)。
流程虛擬機(jī)中的4個(gè)API
圖 4.1. 流程虛擬機(jī)中的4個(gè)API
服務(wù)接口用在應(yīng)用代碼中，與流程虛擬機(jī)進(jìn)行交互， 它將運(yùn)行在支持事務(wù)的持久化模式下，后端基于數(shù)據(jù)庫(kù)。 這是用戶將PVM作為一個(gè)工作流引擎使用的最常用的方式。
如果不想使用持久化方式執(zhí)行流程，可以直接使用客戶端API來(lái)處理流程和執(zhí)行對(duì)象。 客戶端API對(duì)外暴露了核心模型對(duì)象的方法。
活動(dòng)API用來(lái)實(shí)現(xiàn)活動(dòng)在運(yùn)行時(shí)的行為。 因此一個(gè)活動(dòng)類型實(shí)際上是一個(gè)組件，核心是實(shí)現(xiàn)了ActivityBehaviour接口。 活動(dòng)行為實(shí)現(xiàn)可以控制執(zhí)行的流程。
事件監(jiān)聽(tīng)器API用來(lái)編寫(xiě)java代碼，它可以用來(lái)處理流程事件。 它比活動(dòng)API類似， 唯一的差別是事件監(jiān)聽(tīng)器不能控制執(zhí)行的流程。
4.2. 活動(dòng)API
活動(dòng)API允許使用java實(shí)現(xiàn)運(yùn)行時(shí)的活動(dòng)行為。
- public interface ActivityBehaviour extends Serializable {
- void execute(ActivityExecution execution) throws Exception;
- }
一個(gè)活動(dòng)就是分配給活動(dòng)的一些行為。 提供的執(zhí)行就是到達(dá)這個(gè)活動(dòng)的執(zhí)行。 ActivityExecution接口 暴露了控制執(zhí)行流程的方法。
- public interface ActivityExecution extends OpenExecution {
- void waitForSignal();
- void take(String transitionName);
- void execute(String activityName);
- ...
- }
4.3. 事件監(jiān)聽(tīng)API
事件監(jiān)聽(tīng)API允許使用java開(kāi)發(fā)監(jiān)聽(tīng)器， 并在特定的流程事件發(fā)生時(shí)調(diào)用，像進(jìn)入一個(gè)活動(dòng)或離開(kāi)一個(gè)活動(dòng)。 它與活動(dòng)API類似， 不同的是不能控制執(zhí)行流程的傳播。 比如，當(dāng)一個(gè)執(zhí)行選擇了一個(gè)轉(zhuǎn)移，一個(gè)對(duì)應(yīng)的監(jiān)聽(tīng)器會(huì)被激活， 但是因?yàn)檫@個(gè)轉(zhuǎn)移已經(jīng)被選擇了， 執(zhí)行的流程無(wú)法被事件監(jiān)聽(tīng)器改變。
- public interface EventListener extends Serializable {
- void notify(EventListenerExecution execution) throws Exception;
- }
4.4. 客戶端API
客戶端API是一套暴露了相關(guān)方法的接口， 它用來(lái)直接管理流程定義上的執(zhí)行和執(zhí)行對(duì)應(yīng)。
最小的需求，客戶端API和活動(dòng)API需要使用活動(dòng)創(chuàng)建 流程定義并執(zhí)行它。
4.5. 環(huán)境
在持久化執(zhí)行環(huán)境下，環(huán)境的第一目的 是讓流程在不同的事務(wù)環(huán)境下執(zhí)行， 比如Java標(biāo)準(zhǔn)版，Java企業(yè)版，SEAM和Spring。
PVM代碼自身只通過(guò)自身定義的接口來(lái)調(diào)用事務(wù)資源。 比如，PVM自身?yè)碛幸恍┙⒃趆ibernate會(huì)話，異步消息會(huì)話 和定時(shí)任務(wù)會(huì)話的接口方法。
環(huán)境允許為其配置真實(shí)的實(shí)現(xiàn)， 在請(qǐng)求的基礎(chǔ)上實(shí)現(xiàn)服務(wù)的延遲加載， 為事務(wù)的持續(xù)獲得服務(wù)對(duì)象。
一個(gè)環(huán)境工廠是靜態(tài)的，一個(gè)環(huán)境工廠 提供應(yīng)用中的所有線程。
- EnvironmentFactory environmentFactory = new PvmEnvironmentFactory("environment.cfg.xml");
環(huán)境部分可以像這樣 圍繞在持久化流程操作周圍：
- Environment environment = environmentFactory.openEnvironment();
- try {
- ... inside the environment block...
- } finally {
- environment.close();
- }
PVM自身會(huì)從環(huán)境中獲得所有事務(wù)資源和配置。 Activity實(shí)現(xiàn) 也可以做同樣的事情。
org.jbpm.pvm.internal.cfg.JbpmConfiguration 這個(gè)類扮演著Configuration， ProcessEngine和EnvironmentFactory三個(gè)角色。
4.6. 命令
命令封裝了將被運(yùn)行在環(huán)境塊中的操作。 命令的主要目的是獲得邏輯。
- public interface Command< T> extends Serializable {
- T execute(Environment environment) throws Exception;
- }
4.7. 服務(wù)
這里有三個(gè)主要服務(wù)：RepositoryService， ExecutionService和ManagementService。 通常來(lái)說(shuō)，服務(wù)是會(huì)話外觀，用來(lái)暴露PVM持久化應(yīng)用的方法。 下一部分用例子展示 這些服務(wù)中的基本方法。
RepositoryService管理 流程定義的資源。
- public interface RepositoryService {
- Deployment createDeployment();
- ProcessDefinitionQuery createProcessDefinitionQuery();
- ...
- }
- ExecutionService管理 運(yùn)行時(shí)的執(zhí)行。
- public interface ExecutionService {
- ProcessInstance startProcessInstanceById(String processDefinitionId);
- ProcessInstance signalExecutionById(String executionId);
- ...
- }
- ManagementService包含了所有管理操作 來(lái)保持系統(tǒng)啟動(dòng)運(yùn)行。
- public interface ManagementService {
- JobQuery createJobQuery();
- void executeJob(long jobDbid);
- ...
- }
所有這些方法都封裝成Command。 這三個(gè)服務(wù)執(zhí)行的方法 都委派給一個(gè)CommandService：
- public interface CommandService {
- < T> T execute(Command< T> command);
- }
CommandService被配置到環(huán)境中。 一個(gè)CommandService鏈可以看做環(huán)繞在一個(gè)命令周圍的一些攔截器。 這就是如何在不同的環(huán)境下 進(jìn)行持久化和事務(wù)支持的核心機(jī)制。
默認(rèn)的配置文件jbpm.default.cfg.xml 包含了下面的配置服務(wù)。
- < jbpm-configuration>
- < process-engine>
- < repository-service />
- < repository-cache />
- < execution-service />
- < history-service />
- < management-service />
- < identity-service />
- < task-service />
文件 jbpm.tx.hibernate.cfg.xml包含了 下面的command service配置:
- < jbpm-configuration>
- < process-engine-context>
- < command-service>
- < retry-interceptor />
- < environment-interceptor />
- < standard-transaction-interceptor />
- < /command-service>
- < /process-engine-context>
- ...
這些服務(wù)，比如repository-service，execution-service 和management-service將按照類型找到配置好的command-service。 command-service標(biāo)簽符合默認(rèn)的命令服務(wù)， 基本上什么也不做， 只是在提供給它的環(huán)境上執(zhí)行命令。
配置的command-service結(jié)果， 在默認(rèn)的命令執(zhí)行期下面的三個(gè)攔截器鏈中。
CommandService攔截器
圖 4.2. CommandService攔截器
retry攔截器是鏈中的第一個(gè)，它會(huì)被環(huán)境 當(dāng)做CommandService.class暴露出來(lái)。 所以retry攔截器會(huì)分別提供給repository-service， execution-service和management-service這些服務(wù)。
retry-interceptor會(huì)獲取hiberate的StaleObjectExceptions （因?yàn)闃?lè)觀鎖失?。┎⒅匦聡L試執(zhí)行命令。
environment-interceptor會(huì)把一個(gè)環(huán)境塊 放到命令執(zhí)行的周圍。
standard-transaction-interceptor會(huì)初始化一個(gè) StandardTransaction。hibernate會(huì)話/事務(wù)會(huì)被作為 標(biāo)準(zhǔn)事務(wù)的一個(gè)資源。
這個(gè)攔截器棧的不同配置也可以使用：
◆把執(zhí)行委派到一個(gè)本地ejb命令服務(wù)， 這樣可以啟動(dòng)一個(gè)內(nèi)容管理的事務(wù)。
◆把執(zhí)行委派到一個(gè)遠(yuǎn)程ejb命令服務(wù)， 這樣命令實(shí)際執(zhí)行在一個(gè)不同的JVM上。
◆把命令打包成一個(gè)異步消息， 這樣命令會(huì)異步執(zhí)行在一個(gè)不同的事務(wù)中。
【編輯推薦】
