activiti
的
API
在
activiti
引擎中,你可以通过多种方式获取
ProcessEngine
对象,从
ProcessEngine
中获取各种服务对象,从而访问工作流
/BPM
方法。
ProcessEngine
和她的各种服务均为线程安全性服务。在整个项目中每一种服务仅需要保持一个引用。
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RuntimeService runtimeService = processEngine.getRuntimeService();
RepositoryService repositoryService = processEngine.getRepositoryService();
TaskService taskService = processEngine.getTaskService();
ManagementService managementService = processEngine.getManagementService();
IdentityService identityService = processEngine.getIdentityService();
HistoryService historyService = processEngine.getHistoryService();
FormService formService = processEngine.getFormService();
针对
ProcessEngine
的说明:
ProcessEngine.getDefaultProcessEngine()
在第一个被调用的时候初始化并创建一个流程引擎,在以后的调用中返回同一个引用的流程引擎对象。针对流程引擎中初始化方法为
ProcessEngine.init().
销毁方法的方法为
ProcessEngine.destroy().
ProcessEngineConfiguration.createProcessEngineConfigurationFromInputStream(inputStream).buildProcessEngine()
创建工作流引擎,
ProcessEngine
见扫描所有的
activiti.cfg.xml
文件和
activiti-context.xml
文件。
异常策略:
在
activiti
中
org.activiti.engine.ActivitiException
类为所有异常的基类。
ActivitiException
为非检查性异常。例如:
**
* Called when the task is successfully executed.
* @ param taskId the id of the task to complete , cannot be null .
* @ throws ActivitiException when no task exists with the given id.
*/
void
complete(String taskId)
;
其他异常类如下:
ActivitiWrongDbException:
Thrown when the Activiti engine discovers a mismatch between the database schema version and the engine version(schema
版本和引擎版本不匹配报的错误
).
ActivitiOptimisticLockingException:
Thrown when an optimistic locking occurs in the datastore caused by concurrent access of the same data entry.
ActivitiClassLoadingException:
Thrown when an class requested to load was not found or when error occurred while loading it (eg. JavaDelegates, TaskListeners, ...).
Activiti
的测试:
activiti
的测试支持
Junit3
和
Junit4
的单元测试。在
junit3
的单元测试中,
org.activit.engine.test.ActivitiTestCase
必须被继承。在
setup
()方法中,流程引擎要初始化加载
classpath
下默认的
activi.cfg.xml
资源文件。针对不同的配置文件可能需要重新
getConfigurationResource()
方法。在
ActivitiTestCase
中可以使用
org.activiti.engine.test.Deployment
注解方法。
public
class
MyBusinessProcessTest
extends
ActivitiTestCase
{
@ Deployment
public void testSimpleProcess() {
runtimeService .startProcessInstanceByKey( "simpleProcess" );
Task task = taskService .createTaskQuery().singleResult();
assertEquals ( "My Task" , task.getName());
taskService .complete(task.getId());
assertEquals (0, runtimeService .createProcessInstanceQuery().count());
}
}
在
junit4
中
org.activiti.engine.test.ActivitiRule Rule
被采用。通过
ActivitiRule
中
getter
方法获取相关的服务。在
Junit4
同样功能的单元测试如下:
public class MyBusinessProcessTest { @Rule public ActivitiRule activitiRule = new ActivitiRule(); @Test @Deployment public void ruleUsageExample() { RuntimeService runtimeService = activitiRule.getRuntimeService(); runtimeService.startProcessInstanceByKey("ruleUsage"); TaskService taskService = activitiRule.getTaskService(); Task task = taskService.createTaskQuery().singleResult(); assertEquals("My Task", task.getName()); taskService.complete(task.getId()); assertEquals(0, runtimeService.createProcessInstanceQuery().count()); } }
在
web
环境中流程引擎的使用:
由于
processEngine
是一个线程安全性的对象可以容易在多个线程中被共享。在
web
容器启动加载创建工作流引擎,在容器销毁销毁工作流引擎。可以
ServletContextListener
实现相关的功能。
public
class
ProcessEnginesServletContextListener
implements
ServletContextListener
{
public void contextInitialized( ServletContextEvent servletContextEvent) {
ProcessEngines .init();
}
public void contextDestroyed( ServletContextEvent servletContextEvent) {
ProcessEngines .destroy();
}
}
Activiti
提供模拟流程的
API
PvmProcessDefinition processDefinition = new ProcessDefinitionBuilder() .createActivity("a") .initial() .behavior(new WaitState()) .transition("b") .endActivity() .createActivity("b") .behavior(new WaitState()) .transition("c") .endActivity() .createActivity("c") .behavior(new WaitState()) .endActivity() .buildProcessDefinition(); PvmProcessInstance processInstance = processDefinition.createProcessInstance(); processInstance.start(); PvmExecution activityInstance = processInstance.findExecution("a"); assertNotNull(activityInstance); activityInstance.signal(null, null); activityInstance = processInstance.findExecution("b"); assertNotNull(activityInstance); activityInstance.signal(null, null); activityInstance = processInstance.findExecution("c"); assertNotNull(activityInstance);
activiti
中表达式
activiti
使用
UEL(Unified Expression Lanuage)
标记解析配置文件中表达式。
UEL
是
EE6
特性。
activiti
中
Expressions
支持两种方式:
1.Value expression:
在
activiti
中
DelegateExecution
是在上下文中是使用“
execution
”在表达式上下文被使用的。所有在使用值表达式是,所有变量和
spring
的
beans
使用
execution
将被隐藏,在表达式将不被执行。使用方法如下:
${myVar}
${myBean.myProperty}
2.Method expression:
使用方法访问的方式。常用方式如下:
${printer.print()}
${myBean.addNewOrder(“orerName”)}
备注:在
activiti
中
expression
支持解析的类型为原始类型,
beans
,
lists,arrays
和
maps