Activiti介绍
什么是Activiti?
Activiti5是由Alfresco软件在2010年5月17日发布的业务流程管理(BPM)框架,它是覆盖了业务流程管理、工作流、服务协作】等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。Activiti基于Apache许可的开源BPM平台,创始人Tom Baeyens是JBoss jBPM的项目架构师,它特色是提供了eclipse插件,开发人员可以通过插件直接绘画出业务
流程图。.
我们即将学习的是一个业务流程管理框架, 常见开源工作流引擎框架 : OSWorkFlow、jBPM(jboss business process management),Activiti工作流(是对jBPM升级)。一般我们称作为工作流框架..
为什么要学习Activiti
那我们为什么要学习业务流程管理框架呢???学习它干嘛???工作流(Workflow),就是“业务过程的部分或整体在计算机应用环境下的自动化”
我们来提出一个常见的需求来更好地理解:
我们在学生时代,肯定会遇到请假写请假条的情况,如果学校的请假抓得非常严,就需要经过多层的同意才能确定能不能请假..
这里写图片描述
班主任->任课老师->教学总监->校长这么一个流程,首先我们先明确一点:我们作为一个学生,不可能直接跳过老师,去找校长申请请假的【校长是你随便找的吗??】
因此我们请假的流程是一步一步的,并不能做跳跃
也就是说,当班主任没有批准请假的时候,即使你去找任课老师了,任课老师会让你回去找班主任的,作为任课老师了,只关注班主任有没有批准你请假,同理,作为校长,只关注教学总监有没有批准你请假!
进一步说:当教学总监还没有批准你请假时,你请假的请求是不会出现在校长的范围里的。
其实是非常好理解的,就是一步步往下执行,当还没有执行到自己处理的点子上时,是不会有对应的处理请求的。分工有序
对上面的请假流程进行分析,如果我们没有使用框架,而把这么一个请假流程写到我们的网站中,我们会怎么做呢??
这里写图片描述
我们需要维护一个变量,来不断传递过去给下一个处理者…如果一切正常,需求不会变,并没有条件的处理。这是我们非常希望看到的…但是,如果有条件判断【请假三天以下、请假三天以上的处理方式不一样】,需求会变【不需要校长批准了,教学总监批准完,你就能够请假了】,那么我们的代码就会变得乱
基于这么一个原因,我们是需要学习一个框架来帮我们完成工作流的…
采用工作流管理系统的优点
- 1、提高系统的柔性,适应业务流程的变化
- 2、实现更好的业务过程控制,提高顾客服务质量
- 3、降低系统开发和维护成本
一、快速入门Activiti
首先我们来梳理一下Activiti的开发步骤:
- 我们要用到一个工作流,首先就要把这个工作流定义出来【也就是工作流的步骤的怎么样的】,Activiti支持以“图”的方式来定义工作流
- 定义完工作流,就要部署到起来【我们可以联想到Tomcat,我们光下载了Tomcat是没有用的,要把它部署起来】
- 随后我们就执行该工作流,该工作流就随着我们定义的步骤来一一执行!
1.1BPMN
业务流程建模与标注(Business Process Model and Notation,BPMN) ,描述流程的基本符号,包括这些图元如何组合成一个业务流程图(Business Process Diagram)
BPMN这个就是我们所谓把工作流定义出来的流程图..
1.2数据库相关
我们在执行工作流步骤的时候会涉及到很多数据【执行该流程的人是谁、所需要的参数是什么、包括想查看之前流程执行的记录等等】,因此我们会需要用到数据库的表来保存数据…
由于我们使用的是Activiti框架,这个框架会自动帮我们把对应的数据库表创建起来,它涉及的表有23个,但是常用的并不是很多,因此也不用很慌…
下面就列举一下表的情况
Activiti的后台是有数据库的支持,所有的表都以ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。 ACT_RE_*: 'RE'表示repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。 ACT_RU_*: 'RU'表示runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。 ACT_ID_*: 'ID'表示identity。 这些表包含身份信息,比如用户,组等等。 ACT_HI_*: 'HI'表示history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。 ACT_GE_*: 通用数据, 用于不同场景下,如存放资源文件。
1.3搭建配置环境
我这里使用的Intellij idea来使用Activiti,首先,我们得下载插件来使用Activiti【因为定义流程图需要用到插件】
详情可以看这篇博文:http://blog.sina.com.cn/s/blog_4b3196670102woix.html
Activiti插件中文乱码问题:
http://www.cnblogs.com/mymelody/p/6049291.html
流程之前的连线是通过图中的蓝色小点点拖动来进行连接的…
导入对应的jar包
- activation-1.1.jar
- activiti-bpmn-converter-5.13.jar
- activiti-bpmn-layout-5.13.jar
- activiti-bpmn-model-5.13.jar
- activiti-common-rest-5.13.jar
- activiti-engine-5.13.jar
- activiti-json-converter-5.13.jar
- activiti-rest-5.13.jar
- activiti-simple-workflow-5.13.jar
- activiti-spring-5.13.jar
- aopalliance-1.0.jar
- commons-dbcp-1.4.jar
- commons-email-1.2.jar
- commons-fileupload-1.2.2.jar
- commons-io-2.0.1.jar
- commons-lang-2.4.jar
- commons-pool-1.5.4.jar
- h2-1.3.170.jar
- hamcrest-core-1.3.jar
- jackson-core-asl-1.9.9.jar
- jackson-mapper-asl-1.9.9.jar
- javaGeom-0.11.0.jar
- jcl-over-slf4j-1.7.2.jar
- jgraphx-1.10.4.2.jar
- joda-time-2.1.jar
- junit-4.11.jar
- log4j-1.2.17.jar
- mail-1.4.1.jar
- mybatis-3.2.2.jar
- mysql-connector-java.jar
- org.restlet.ext.fileupload-2.0.15.jar
- org.restlet.ext.jackson-2.0.15.jar
- org.restlet.ext.servlet-2.0.15.jar
- org.restlet-2.0.15.jar
- slf4j-api-1.7.2.jar
- slf4j-log4j12-1.7.2.jar
- spring-aop-3.1.2.RELEASE.jar
- spring-asm-3.1.2.RELEASE.jar
- spring-beans-3.1.2.RELEASE.jar
- spring-context-3.1.2.RELEASE.jar
- spring-core-3.1.2.RELEASE.jar
- spring-expression-3.1.2.RELEASE.jar
- spring-jdbc-3.1.2.RELEASE.jar
- spring-orm-3.1.2.RELEASE.jar
- spring-tx-3.1.2.RELEASE.jar
1.4开发步骤
上面已经说过了,我们要想使用Activiti就需要有数据库的支持,虽然Activiti是自动帮我们创建对应的数据库表,但是我们是需要配置数据库的信息的。我们配置数据库的信息,接着拿到Activiti最重要的API------Activiti引擎
这里写图片描述
1.4.1得到工作流引擎
Activiti提供使用代码的方式来配置数据库的信息:
@Test public void createActivitiEngine(){ /* *1.通过代码形式创建 * - 取得ProcessEngineConfiguration对象 * - 设置数据库连接属性 * - 设置创建表的策略 (当没有表时,自动创建表) * - 通过ProcessEngineConfiguration对象创建 ProcessEngine 对象*/ //取得ProcessEngineConfiguration对象 ProcessEngineConfiguration engineConfiguration=ProcessEngineConfiguration. createStandaloneProcessEngineConfiguration(); //设置数据库连接属性 engineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver"); engineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activitiDB?createDatabaseIfNotExist=true" + "&useUnicode=true&characterEncoding=utf8"); engineConfiguration.setJdbcUsername("root"); engineConfiguration.setJdbcPassword("root"); // 设置创建表的策略 (当没有表时,自动创建表) // public static final java.lang.String DB_SCHEMA_UPDATE_FALSE = "false";//不会自动创建表,没有表,则抛异常 // public static final java.lang.String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";//先删除,再创建表 // public static final java.lang.String DB_SCHEMA_UPDATE_TRUE = "true";//假如没有表,则自动创建 engineConfiguration.setDatabaseSchemaUpdate("true"); //通过ProcessEngineConfiguration对象创建 ProcessEngine 对象 ProcessEngine processEngine = engineConfiguration.buildProcessEngine(); System.out.println("流程引擎创建成功!"); }
Activiti也可以通过配置文件来配置数据库的信息,加载配置文件从而得到工作流引擎
/**2. 通过加载 activiti.cfg.xml 获取 流程引擎 和自动创建数据库及表 * ProcessEngineConfiguration engineConfiguration= ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml"); //从类加载路径中查找资源 activiti.cfg.xm文件名可以自定义 ProcessEngine processEngine = engineConfiguration.buildProcessEngine(); System.out.println("使用配置文件Activiti.cfg.xml获取流程引擎"); */
activiti.cfg.xml
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd"> <!-- 配置 ProcessEngineConfiguration --> <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"> <!-- 配置数据库连接 --> <property name="jdbcDriver" value="com.mysql.jdbc.Driver"></property> <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activitiDB?createDatabaseIfNotExist=true&useUnicode=true&characterEncoding=utf8"></property> <property name="jdbcUsername" value="root"></property> <property name="jdbcPassword" value="root"></property> <!-- 配置创建表策略 :没有表时,自动创建 --> <property name="databaseSchemaUpdate" value="true"></property> </bean> </beans>
这里写图片描述
上面的那种加载配置文件方式,配置文件的名字是可以自定义的,如果我们配置文件的名字默认就是activiti.cfg.xml
的话,也是放在类路径下,我们就可以使用默认的方式来进行加载了!
@Test public void createActivitiEngine(){ /** * 3. 通过ProcessEngines 来获取默认的流程引擎 */ // 默认会加载类路径下的 activiti.cfg.xml ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); System.out.println("通过ProcessEngines 来获取流程引擎"); }
1.4.2定义工作流
定义工作流就需要我们刚才下载的插件了,我们是使用图形的方式来定义工作流的….
这里写图片描述
在每个流程中,我们都可以指定对应的处理人是谁,交由谁处理
1.4.3部署工作流
我们上面已经定义了工作流了,工作流引擎我们也已经拿到了,接下来就是把工作流部署到工作流引擎中了
@Test public void deploy() { //获取仓库服务 :管理流程定义 RepositoryService repositoryService = processEngine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment()//创建一个部署的构建器 .addClasspathResource("LeaveActiviti.bpmn")//从类路径中添加资源,一次只能添加一个资源 .name("请求单流程")//设置部署的名称 .category("办公类别")//设置部署的类别 .deploy(); System.out.println("部署的id"+deploy.getId()); System.out.println("部署的名称"+deploy.getName()); }
相对应的数据库表就会插入数据、涉及到的数据库表后面会详细说明。现在我们只要了解到,我们工作流引擎执行操作会有数据库表记录
这里写图片描述
1.4.4执行工作流
指定指定工作流就是我们定义时工作流程表的id
这里写图片描述
@Test public void startProcess(){ //指定执行我们刚才部署的工作流程 String processDefiKey="leaveBill"; //取运行时服务 RuntimeService runtimeService = processEngine.getRuntimeService(); //取得流程实例 ProcessInstance pi = runtimeService.startProcessInstanceByKey(processDefiKey);//通过流程定义的key 来执行流程 System.out.println("流程实例id:"+pi.getId());//流程实例id System.out.println("流程定义id:"+pi.getProcessDefinitionId());//输出流程定义的id }
1.4.5根据代理人查询当前任务的信息
刚才我们已经开始了工作流了,随后工作流应该去到了申请请假的流程,申请请假的处理人是钟福成,我们可以查询出对应的信息:
//查询任务 @Test public void queryTask(){ //任务的办理人 String assignee="钟福成"; //取得任务服务 TaskService taskService = processEngine.getTaskService(); //创建一个任务查询对象 TaskQuery taskQuery = taskService.createTaskQuery(); //办理人的任务列表 List<Task> list = taskQuery.taskAssignee(assignee)//指定办理人 .list(); //遍历任务列表 if(list!=null&&list.size()>0){ for(Task task:list){ System.out.println("任务的办理人:"+task.getAssignee()); System.out.println("任务的id:"+task.getId()); System.out.println("任务的名称:"+task.getName()); } } }
这里写图片描述
1.4.6处理任务
我们现在处理流程去到“申请请假”中,处理人是钟福成…接着就是钟福成去处理任务,根据任务的id使得流程继续往下走
任务的id刚才我们已经查询出来了【上面】,我们如果是在web端操作数据的话,那么只要传递过去就行了!
//完成任务 @Test public void compileTask(){ String taskId="304"; //taskId:任务id processEngine.getTaskService().complete(taskId); System.out.println("当前任务执行完毕"); }
这里写图片描述
当我们处理完该任务的时候,就到了批准【班主任】任务了,我们查询一下是不是如我们想象的效果:
这里写图片描述
我们按照定义的工作流程图一步一步往下走,最终把流程走完
这里写图片描述