Activiti总体框架分析
參考資料
- activiti數(shù)據(jù)表結(jié)構(gòu)
- Activiti 5.16 用戶手冊
- Activiti User Guide
- activiti與BPMN
- activiti源碼
- activiti_doc文檔
Engine解析
| org.activiti.engine | 流程引擎公共API方法,均采用鏈式方式 一般通過ProcessEngineConfiguration創(chuàng)建 可以獲得的服務(wù)包括： RepositoryService RuntimeService TaskService IdentityService ManagementService HistoryService FormService |
| org.activiti.engine.impl | engine模塊的核心,包含了: pvm的實現(xiàn) 接口方法的實現(xiàn) 命令模式 |
| org.activiti.engine.cfg | 配置接口 |
| org.activiti.engine.ProcessEngine | 引擎接口 |
| org.activiti.engine.ProcessEngineConfiguration | 配置管理 |
| org.activiti.engine.ActivitiException | 基礎(chǔ)異常類 |
| org.activiti.engine.delegate | ? |
| org.activiti.engine.form | 表單信息,和FormService相關(guān)聯(lián) |
| org.activiti.engine.history | 流程歷史信息,和HistoryService相關(guān)聯(lián) |
| org.activiti.engine.identity | 用戶、組管理信息,和IdentityService相關(guān)聯(lián) |
| org.activiti.engine.logging | 日志 |
| org.activiti.engine.management | 流程管理和控制信息,和ManagementService相關(guān)聯(lián) |
| org.activiti.engine.repository | 流程資源信息,和RepositoryService相關(guān)聯(lián) |
| org.activiti.engine.runtime | 流程運行時相關(guān)信息,和RuntimeService相關(guān)聯(lián) |
| org.activiti.engine.task | 表示任務(wù)相關(guān)信息,和TaskService相關(guān)聯(lián) |
1. org.activiti.engine
定義了流程管理服務(wù)的接口：RepositoryService、RuntimeService、?FormService、TaskService、HistoryService、IdentityService、?ManagementService?。
定義了引擎配置管理接口ProcessEngineConfiguration。
定義了activiti異常類ActivitiException。
org.activiti.engine是activiti的核心功能，控制工作流的流轉(zhuǎn)。幾個核心的類如下圖所示：
1.1 ProcessEngine
ProcessEngine接口繼承EngineServices，EngineServices包括很多工作流/BPM方法的服務(wù)，它們都是線程安全的。EngineServices提供的服務(wù)包括：
-
RepositoryService:提供了管理和控制流程定義的操作。
-
RuntimeService:提供了管理和控制流程實例的操作。
-
FormService:提供了管理流程表單的操作，即使不用FormService，activiti也可以完美運行。
-
TaskService:提供了任務(wù)管理的操作，包括實例任務(wù)掛起、激活、完成、暫停、查詢。
-
HistoryService:提供對歷史流程，歷史任務(wù)，歷史變量的查詢操作。
-
IdentityService:提供用戶和組管理的操作（創(chuàng)建，更新，刪除，查詢...）。
-
ManagementService:提供了查詢和管理異步操作(定時器，異步操作， 延遲暫停、激活等)的功能，它還可以查詢到數(shù)據(jù)庫的表和表的元數(shù)據(jù)。
EngineServices?代碼如下所示：
public interface EngineServices {RepositoryService getRepositoryService();RuntimeService getRuntimeService();FormService getFormService();TaskService getTaskService();HistoryService getHistoryService();IdentityService getIdentityService();ManagementService getManagementService();ProcessEngineConfiguration getProcessEngineConfiguration();}ProcessEngine?代碼如下所示：
public interface ProcessEngine extends EngineServices {/** the version of the activiti library */public static String VERSION = "5.17.0.2";/** The name as specified in 'process-engine-name' in* the activiti.cfg.xml configuration file.* The default name for a process engine is 'default */String getName();void close();}1.2 ProcessEngineConfiguration
ProcessEngineConfiguration是配置管理類，它管理的對象包括ProcessEngine，XXservice，數(shù)據(jù)庫session等。ProcessEngineConfiguration的配置，activiti默認會從activiti.cfg.xml中讀取，也可以在Spring的配置文件中讀取。ProcessEngineConfiguration的實現(xiàn)包括：
-
ProcessEngineConfigurationImpl繼承ProcessEngineConfiguration，實現(xiàn)了各種Service的初始化
-
StandaloneProcessEngineConfiguration是單獨運行的流程引擎，繼承ProcessEngineConfigurationImpl。代碼如下:
public class StandaloneProcessEngineConfiguration extends ProcessEngineConfigurationImpl {@Overrideprotected CommandInterceptor createTransactionInterceptor() {return null;} } -
StandaloneInMemProcessEngineConfiguration是單元測試時的輔助類，繼承StandaloneProcessEngineConfiguration，默認使用H2內(nèi)存數(shù)據(jù)庫。數(shù)據(jù)庫表會在引擎啟動時創(chuàng)建，關(guān)閉時刪除。代碼如下所示：
public class StandaloneInMemProcessEngineConfiguration extends StandaloneProcessEngineConfiguration {public StandaloneInMemProcessEngineConfiguration() {this.databaseSchemaUpdate = DB_SCHEMA_UPDATE_CREATE_DROP;this.jdbcUrl = "jdbc:h2:mem:activiti";} } -
SpringProcessEngineConfiguration是Spring環(huán)境下使用的流程引擎。
-
JtaProcessEngineConfiguration單獨運行的流程引擎，并使用JTA事務(wù)。
1.3 ActivitiException
activiti的基礎(chǔ)異常類是org.activiti.engine.ActivitiException，一個非檢查異常。Activiti的異常都是通過org.activiti.engine.ActivitiException拋出，但存在以下特殊情況：
-
ActivitiWrongDbException：當Activiti引擎發(fā)現(xiàn)數(shù)據(jù)庫版本號和引擎版本號不一致時拋出。
-
ActivitiOptimisticLockingException：對同一數(shù)據(jù)進行并發(fā)方法并出現(xiàn)樂觀鎖時拋出。
-
ActivitiClassLoadingException：當無法找到需要加載的類或在加載類時出現(xiàn)了錯誤（比如，JavaDelegate，TaskListener等。
-
ActivitiObjectNotFoundException：當請求或操作的對應(yīng)不存在時拋出。
-
ActivitiIllegalArgumentException：這個異常表示調(diào)用Activiti API時傳入了一個非法的參數(shù)，可能是引擎配置中的非法值，或提供了一個非法制，或流程定義中使用的非法值。
-
ActivitiTaskAlreadyClaimedException：當任務(wù)已經(jīng)被認領(lǐng)了，再調(diào)用taskService.claim(...)就會拋出。
-
BpmnError：流程部署錯誤，如流程定義文件不合法。
-
JobNotFoundException：JOB不存在。
2. org.activiti.engine.impl
實現(xiàn)了流程管理服務(wù)RepositoryServiceImpl,?RuntimeServiceImpl,?FormServiceImpl,?TaskServiceImpl,?HistoryServiceImpl,?IdentityServiceImpl,?ManagementServiceImpl
實現(xiàn)流程虛擬機PVM
數(shù)據(jù)持久化，腳本任務(wù)，條件表達式EL的解析等等
命令接口的定義
| org.activiti.engine.impl.asyncexecutor | job調(diào)度，主要管理調(diào)度線程 |
| org.activiti.engine.impl.bpmn | 部署文件，BPMN元素管理 |
| org.activiti.engine.impl.calendar | 時間，日期管理 |
| org.activiti.engine.impl.cfg | ProcessEngineConfiguration的實現(xiàn) |
| org.activiti.engine.impl.cmd | 命令模式的client，實現(xiàn)了各種命令 |
| org.activiti.engine.impl.context | 上下文定義文件，保存線程數(shù)據(jù) |
| org.activiti.engine.impl.db | 數(shù)據(jù)庫基本增刪改操作 |
| org.activiti.engine.impl.delegate | 任務(wù)監(jiān)聽 |
| org.activiti.engine.impl.el | 表達式解析，執(zhí)行 |
| org.activiti.engine.impl.event | 事件 |
| org.activiti.engine.impl.form | 表單 |
| org.activiti.engine.impl.history | 歷史 |
| org.activiti.engine.impl.interceptor | 攔截器的定義 |
| org.activiti.engine.impl.javax.el | ???? |
| org.activiti.engine.impl.jobexecutor | 控制job的執(zhí)行 |
| org.activiti.engine.impl.juel | 對el的擴展 |
| org.activiti.engine.impl.persistence | 數(shù)據(jù)庫實體的定義 |
| org.activiti.engine.impl.pvm | 流程虛擬機，整個流程的流轉(zhuǎn)，分支該怎么走都靠它了 |
| org.activiti.engine.impl.transformer | 基礎(chǔ)類型轉(zhuǎn)換，Long轉(zhuǎn)String之類的 |
| org.activiti.engine.impl.ServiceImpl | 流程管理服務(wù)類 |
2.1 org.activiti.engine.impl.ServiceImpl
-
XXService?的定義
org.activiti.engine.impl.ServiceImpl是流程管理服務(wù)的基類，它的派生類包括RepositoryServiceImpl,?RuntimeServiceImpl,?FormServiceImpl,?TaskServiceImpl,?HistoryServiceImpl,?IdentityServiceImpl,?ManagementServiceImpl，它定義了配置管理服務(wù)processEngineConfiguration、命令執(zhí)行接口commandExecutor(activiti方法調(diào)用都通過命令模式)。源碼如下所示：
public class ServiceImpl {protected ProcessEngineConfigurationImpl processEngineConfiguration;public ServiceImpl() {}public ServiceImpl(ProcessEngineConfigurationImpl processEngineConfiguration) {this.processEngineConfiguration = processEngineConfiguration;}protected CommandExecutor commandExecutor;public CommandExecutor getCommandExecutor() {return commandExecutor;}public void setCommandExecutor(CommandExecutor commandExecutor) {this.commandExecutor = commandExecutor;}}XXServiceImpl繼承類org.activiti.engine.impl.ServiceImpl，并且實現(xiàn)對應(yīng)的XXService接口。下面是RepositoryServiceImpl示例代碼：
public class RepositoryServiceImpl extends ServiceImpl implements RepositoryService {} -
XXService的初始化
XXService的初始化在ProcessEngineConfigurationImpl中
protected RepositoryService repositoryService = new RepositoryServiceImpl(); protected RuntimeService runtimeService = new RuntimeServiceImpl();protected HistoryService historyService = new HistoryServiceImpl(this);protected IdentityService identityService = new IdentityServiceImpl();protected TaskService taskService = new TaskServiceImpl(this);protected FormService formService = new FormServiceImpl();protected ManagementService managementService = new ManagementServiceImpl();XXService的commandExecutor初始化在ProcessEngineConfigurationImpl的initService中
protected void initService(Object service) {if (service instanceof ServiceImpl) {((ServiceImpl)service).setCommandExecutor(commandExecutor);} }
2.2 org.activiti.engine.impl.interceptor
包org.activiti.engine.impl.interceptor定義了攔截器和命令。activiti里面所有的指令都是通過命令模式執(zhí)行，在命令執(zhí)行之前，可以切入多個攔截器。
-
commandContext是命令上下文。
-
command是命令接口，command中定義了execute方法，代碼如下所示：
public interface Command <T> {T execute(CommandContext commandContext); } -
CommandExecutor這個是命令的執(zhí)行方法，CommandConfig是CommandExecutor的配置。CommandExecutor代碼如下所示：
public interface CommandExecutor {/*** @return the default {@link CommandConfig}, used if none is provided.*/CommandConfig getDefaultConfig();/*** Execute a command with the specified {@link CommandConfig}.*/<T> T execute(CommandConfig config, Command<T> command);/*** Execute a command with the default {@link CommandConfig}.*/<T> T execute(Command<T> command);} -
CommandInterceptor攔截器，在命令執(zhí)行之前進行攔截，一個命令可以有多個攔截器，這些攔截器通過鏈表鏈接起來順序執(zhí)行。CommandInterceptor代碼如下：
public interface CommandInterceptor {<T> T execute(CommandConfig config, Command<T> command);CommandInterceptor getNext();void setNext(CommandInterceptor next);} -
commandExecutor到底是如何注入的？
以RuntimeServiceImpl為例，?RuntimeServiceImpl繼承類ServiceImpl，ServiceImpl包含CommandExecutor屬性
在ProcessEngineConfigurationImpl中有個init方法，里面有對于executor和intecerptor的初始化
// 初始化各種服務(wù) protected void initServices() {initService(repositoryService);initService(runtimeService);initService(historyService);initService(identityService);initService(taskService);initService(formService);initService(managementService); }// 初始化服務(wù)方法 protected void initService(Object service) {if (service instanceof ServiceImpl) {((ServiceImpl)service).setCommandExecutor(commandExecutor);} }// 初始化攔截器 protected void initCommandInterceptors() {if (commandInterceptors==null) {commandInterceptors = new ArrayList<CommandInterceptor>();if (customPreCommandInterceptors!=null) {commandInterceptors.addAll(customPreCommandInterceptors);}commandInterceptors.addAll(getDefaultCommandInterceptors());if (customPostCommandInterceptors!=null) {commandInterceptors.addAll(customPostCommandInterceptors);}commandInterceptors.add(commandInvoker);} }// 將攔截器初始化成鏈式結(jié)構(gòu) protected void initCommandExecutor() {if (commandExecutor==null) {CommandInterceptor first = initInterceptorChain(commandInterceptors);commandExecutor = new CommandExecutorImpl(getDefaultCommandConfig(), first);} }
2.3 org.activiti.engine.impl.delegate
包org.activiti.engine.impl.delegate實現(xiàn)了監(jiān)聽器和事件處理，activiti 允許客戶端代碼介入流程的執(zhí)行，為此提供了這個基礎(chǔ)組件。
activiti5.16 用戶手冊的介紹，監(jiān)聽器，事件處理。
2.3.1 監(jiān)聽器
監(jiān)聽器可以捕獲的事件包括：
DelegateInterceptor是事件攔截器接口，DelegateInvocation是事件調(diào)用接口，XXXInvocation是DelegateInvocation的實現(xiàn)類，XXXInvocation里面包含監(jiān)聽接口XXXListener。
-
怎樣添加監(jiān)聽
下面的流程定義文件包含2個監(jiān)聽器，event表示時間類型，class表示處理事件的java類。
<extensionElements><activiti:taskListener event="create" class="com.alfrescoblog.MyTest.imple.CreateTaskDelegate"></activiti:taskListener><activiti:taskListener event="complete" class="com.alfrescoblog.MyTest.imple.MyJavaDelegate"></activiti:taskListener> </extensionElements>``CreateTaskDelegate是客戶端實現(xiàn)的監(jiān)聽類，TaskListener是activiti的監(jiān)聽接口。
TaskListener代碼如下所示：
public interface TaskListener extends Serializable {String EVENTNAME_CREATE = "create";String EVENTNAME_ASSIGNMENT = "assignment";String EVENTNAME_COMPLETE = "complete";String EVENTNAME_DELETE = "delete";/*** Not an actual event, used as a marker-value for {@link TaskListener}s that should be called for all events,* including {@link #EVENTNAME_CREATE}, {@link #EVENTNAME_ASSIGNMENT} and {@link #EVENTNAME_COMPLETE} and {@link #EVENTNAME_DELETE}.*/String EVENTNAME_ALL_EVENTS = "all";void notify(DelegateTask delegateTask);}-
監(jiān)聽怎樣被注入的
BPMN流程文件部署的時候會注入各種listener。比如TaskListener在org.activiti.engine.impl.task.TaskDefinition的addTaskListener方法中被注入，代碼如下：
public void addTaskListener(String eventName, TaskListener taskListener) {if(TaskListener.EVENTNAME_ALL_EVENTS.equals(eventName)) {// In order to prevent having to merge the "all" tasklisteners with the ones for a specific eventName,// every time "getTaskListener()" is called, we add the listener explicitally to the individual liststhis.addTaskListener(TaskListener.EVENTNAME_CREATE, taskListener);this.addTaskListener(TaskListener.EVENTNAME_ASSIGNMENT, taskListener);this.addTaskListener(TaskListener.EVENTNAME_COMPLETE, taskListener);this.addTaskListener(TaskListener.EVENTNAME_DELETE, taskListener);} else {List<TaskListener> taskEventListeners = taskListeners.get(eventName);if (taskEventListeners == null) {taskEventListeners = new ArrayList<TaskListener>();taskListeners.put(eventName, taskEventListeners);}taskEventListeners.add(taskListener);} }
-
監(jiān)聽在什么時候觸發(fā)的
以TaskListener為例，調(diào)用鏈：UserTaskActivityBehavior.execute()?→?task.fireEvent(TaskListener.EVENTNAME_CREATE);?→?DelegateInterceptor.handleInvocation()?→?DefaultDelegateInterceptor.handleInvocation()?→?DelegateInvocation.proceed()?→?TaskListenerInvocation.invoke()?→?TaskListener.notify()
UserTaskActivityBehavior?是任務(wù)新增、修改、刪除行為，UserTask節(jié)點解析(UserTaskParseHandler.executeParse)的時候設(shè)置到activiti中，觸發(fā)的代碼還沒找到。
protected void executeParse(BpmnParse bpmnParse, UserTask userTask) {ActivityImpl activity = createActivityOnCurrentScope(bpmnParse, userTask, BpmnXMLConstants.ELEMENT_TASK_USER);activity.setAsync(userTask.isAsynchronous());activity.setExclusive(!userTask.isNotExclusive());TaskDefinition taskDefinition = parseTaskDefinition(bpmnParse, userTask, userTask.getId(), (ProcessDefinitionEntity) bpmnParse.getCurrentScope().getProcessDefinition());activity.setProperty(PROPERTY_TASK_DEFINITION, taskDefinition);activity.setActivityBehavior(bpmnParse.getActivityBehaviorFactory().createUserTaskActivityBehavior(userTask, taskDefinition)); }
from:?https://haibinpark.gitbooks.io/activiti-develop-plan/content/activiti_analysis/whole_framework.html#%E5%8F%82%E8%80%83%E8%B5%84%E6%96%99
總結(jié)
以上是生活随笔為你收集整理的Activiti总体框架分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Activiti 工作流引擎的初步使用
- 下一篇： 第一个 Dubbo 应用