1.介绍
Activiti是一个工作流引擎, activiti可以将业务系统中复杂的业务流程抽取出来,使用专门的建模语言
BPMN2.0进行定义,业务流程按照预先定义的流程进行执行,实现了系统的流程由activiti进行管理,减
少业务系统由于流程变更进行系统升级改造的工作量,从而提高系统的健壮性,同时也减少了系统开发
维护成本。
官方网站:https://www.activiti.org/
2.BPM和BPMN
BPM(Business Process Management),即业务流程管理,是一种规范化的构造端到端的业务流程,
以持续的提高组织业务效率。常见商业管理教育如EMBA、MBA等均将BPM包含在内。
BPMN(Business Process Model AndNotation)- 业务流程模型和符号 是由BPMI(BusinessProcess
Management Initiative)开发的一套标准的业务流程建模符号,使用BPMN提供的符号可以创建业务流
程。
BPMN 是目前被各 BPM 厂商广泛接受的 BPM 标准。Activiti 就是使用 BPMN 2.0 进行流程建模、流程
执行管理,它包括很多的建模符号,比如:
Event
用一个圆圈表示,它是流程中运行过程中发生的事情。
活动用圆角矩形表示,一个流程由一个活动或多个活动组成
Bpmn图形其实是通过xml表示业务流程,上边的.bpmn文件使用文本编辑器打开:
<?xml version="1.0" encoding="UTF-8"?> <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef"> <process id="myleaveprocess" name="员工请假审批流程" isExecutable="true"> <startEvent id="sid-30C5C04C-6B86-48CB-A849-F61F8410FF0F"></startEvent> <userTask id="sid-0B17D13A-0775-48F9-AB7F-B4F1B42419E5" name="提交请假申请" activiti:assignee="employee"> <extensionElements> <modeler:initiator-can-complete xmlns:modeler="http://activiti.com/modeler"><![CDATA[false]]></modeler:initiator-can-complete> </extensionElements> </userTask> <sequenceFlow id="sid-39191196-966E-4254-9826-CB20D34C913B" sourceRef="sid-30C5C04C-6B86-48CB-A849-F61F8410FF0F" targetRef="sid-0B17D13A-0775-48F9-AB7F-B4F1B42419E5"></sequenceFlow> <userTask id="sid-348B9833-9B49-4512-937D-8C0A6A7755BA" name="部门主任审批" activiti:assignee="sub-leader"> <extensionElements> <modeler:initiator-can-complete xmlns:modeler="http://activiti.com/modeler"><![CDATA[false]]></modeler:initiator-can-complete> </extensionElements> </userTask> <sequenceFlow id="sid-B30122A6-C14B-4A40-8C9C-0CB0769D66A7" sourceRef="sid-0B17D13A-0775-48F9-AB7F-B4F1B42419E5" targetRef="sid-348B9833-9B49-4512-937D-8C0A6A7755BA"></sequenceFlow> <endEvent id="sid-1AB096A5-310D-43A0-94D4-28B5C66C115C"></endEvent> <sequenceFlow id="sid-AA6AD2DE-719D-49A1-B076-DAC245D613B5" sourceRef="sid-348B9833-9B49-4512-937D-8C0A6A7755BA" targetRef="sid-1AB096A5-310D-43A0-94D4-28B5C66C115C"></sequenceFlow> <userTask id="sid-50F0FA1F-E8A5-4E0D-99DD-20F3598F5C69" name="单位领导审批" activiti:assignee="leader"> <extensionElements> <modeler:initiator-can-complete xmlns:modeler="http://activiti.com/modeler"><![CDATA[false]]></modeler:initiator-can-complete> </extensionElements> </userTask> <sequenceFlow id="sid-4A201AC4-B343-466A-9058-9833D59FB9C6" sourceRef="sid-348B9833-9B49-4512-937D-8C0A6A7755BA" targetRef="sid-50F0FA1F-E8A5-4E0D-99DD-20F3598F5C69"></sequenceFlow> <endEvent id="sid-D9E1C646-2864-4D2E-9350-42B51B5EB7B7"></endEvent> <sequenceFlow id="sid-89698514-937E-4DB5-836C-C475BF7649BF" sourceRef="sid-50F0FA1F-E8A5-4E0D-99DD-20F3598F5C69" targetRef="sid-D9E1C646-2864-4D2E-9350-42B51B5EB7B7"></sequenceFlow> </process> <bpmndi:BPMNDiagram id="BPMNDiagram_myleaveprocess"> <bpmndi:BPMNPlane bpmnElement="myleaveprocess" id="BPMNPlane_myleaveprocess"> <bpmndi:BPMNShape bpmnElement="sid-30C5C04C-6B86-48CB-A849-F61F8410FF0F" id="BPMNShape_sid-30C5C04C-6B86-48CB-A849-F61F8410FF0F"> <omgdc:Bounds height="30.0" width="30.0" x="200.5" y="60.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="sid-0B17D13A-0775-48F9-AB7F-B4F1B42419E5" id="BPMNShape_sid-0B17D13A-0775-48F9-AB7F-B4F1B42419E5"> <omgdc:Bounds height="80.0" width="100.0" x="275.5" y="35.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="sid-348B9833-9B49-4512-937D-8C0A6A7755BA" id="BPMNShape_sid-348B9833-9B49-4512-937D-8C0A6A7755BA"> <omgdc:Bounds height="80.0" width="100.0" x="420.5" y="35.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="sid-1AB096A5-310D-43A0-94D4-28B5C66C115C" id="BPMNShape_sid-1AB096A5-310D-43A0-94D4-28B5C66C115C"> <omgdc:Bounds height="28.0" width="28.0" x="565.5" y="61.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="sid-50F0FA1F-E8A5-4E0D-99DD-20F3598F5C69" id="BPMNShape_sid-50F0FA1F-E8A5-4E0D-99DD-20F3598F5C69"> <omgdc:Bounds height="80.0" width="100.0" x="565.5" y="35.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="sid-D9E1C646-2864-4D2E-9350-42B51B5EB7B7" id="BPMNShape_sid-D9E1C646-2864-4D2E-9350-42B51B5EB7B7"> <omgdc:Bounds height="28.0" width="28.0" x="710.5" y="61.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNEdge bpmnElement="sid-39191196-966E-4254-9826-CB20D34C913B" id="BPMNEdge_sid-39191196-966E-4254-9826-CB20D34C913B"> <omgdi:waypoint x="230.5" y="75.0"></omgdi:waypoint> <omgdi:waypoint x="275.5" y="75.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="sid-AA6AD2DE-719D-49A1-B076-DAC245D613B5" id="BPMNEdge_sid-AA6AD2DE-719D-49A1-B076-DAC245D613B5"> <omgdi:waypoint x="520.5" y="75.0"></omgdi:waypoint> <omgdi:waypoint x="565.5" y="75.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="sid-4A201AC4-B343-466A-9058-9833D59FB9C6" id="BPMNEdge_sid-4A201AC4-B343-466A-9058-9833D59FB9C6"> <omgdi:waypoint x="520.5" y="75.0"></omgdi:waypoint> <omgdi:waypoint x="565.5" y="75.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="sid-89698514-937E-4DB5-836C-C475BF7649BF" id="BPMNEdge_sid-89698514-937E-4DB5-836C-C475BF7649BF"> <omgdi:waypoint x="665.5" y="75.0"></omgdi:waypoint> <omgdi:waypoint x="710.5" y="75.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="sid-B30122A6-C14B-4A40-8C9C-0CB0769D66A7" id="BPMNEdge_sid-B30122A6-C14B-4A40-8C9C-0CB0769D66A7"> <omgdi:waypoint x="375.5" y="75.0"></omgdi:waypoint> <omgdi:waypoint x="420.5" y="75.0"></omgdi:waypoint> </bpmndi:BPMNEdge> </bpmndi:BPMNPlane> </bpmndi:BPMNDiagram> </definitions>
3.使用步骤
4.表结构介绍
25张表:
4.1表的命名规则和作用
看到刚才创建的表,我们发现Activiti 的表都以 ACT_ 开头。
第二部分是表示表的用途的两个字母标识。 用途也和服务的 API 对应。
ACT_RE :'RE’表示 repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。
ACT_RU:'RU’表示 runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Activiti 只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。
ACT_HI:'HI’表示 history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。
ACT_GE : GE 表示 general。 通用数据, 用于不同场景下
4.2Activiti数据表介绍
表分类表名解释
一般数据
[ACT_GE_BYTEARRAY] 通用的流程定义和流程资源
[ACT_GE_PROPERTY] 系统相关属性
流程历史记录
[ACT_HI_ACTINST] 历史的流程实例
[ACT_HI_ATTACHMENT] 历史的流程附件
[ACT_HI_COMMENT] 历史的说明性信息
[ACT_HI_DETAIL] 历史的流程运行中的细节信息
[ACT_HI_IDENTITYLINK] 历史的流程运行过程中用户关系
[ACT_HI_PROCINST] 历史的流程实例
[ACT_HI_TASKINST] 历史的任务实例
[ACT_HI_VARINST] 历史的流程运行中的变量信息
流程定义表
[ACT_RE_DEPLOYMENT] 部署单元信息
[ACT_RE_MODEL] 模型信息
[ACT_RE_PROCDEF] 已部署的流程定义
运行实例表
[ACT_RU_EVENT_SUBSCR] 运行时事件
[ACT_RU_EXECUTION] 运行时流程执行实例
[ACT_RU_IDENTITYLINK]
运行时用户关系信息,存储任务节点与参与者的相关信息
[ACT_RU_JOB] 运行时作业
[ACT_RU_TASK] 运行时任务
[ACT_RU_VARIABLE] 运行时变量表
5.Servcie服务接口
Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口,我们使用这些接口可以就是操
作服务对应的数据表。
5.1 Service创建方式
通过ProcessEngine创建Service
方式如下:
RuntimeService runtimeService = processEngine.getRuntimeService(); RepositoryService repositoryService = processEngine.getRepositoryService(); TaskService taskService = processEngine.getTaskService();
5.2 Service服务接口介绍
RepositoryService
是activiti的资源管理类,提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的
业务流程图需要使用此service将流程定义文件的内容部署到计算机。除了部署流程定义以外还可以:查询引擎中的发布包和流程定义。
暂停或激活发布包,对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了,激活是对应的
反向操作。获得多种资源,像是包含在发布包里的文件, 或引擎自动生成的流程图。
获得流程定义的pojo版本, 可以用来通过java解析流程,而不必通过xml。
RuntimeService
Activiti的流程运行管理类。可以从这个服务类中获取很多关于流程执行相关的信息
TaskService
Activiti的任务管理类。可以从这个类中获取任务的信息。
HistoryService
Activiti的历史管理类,可以查询历史信息,执行流程时,引擎会保存很多数据(根据配置),比如流程
实例启动时间,任务的参与者, 完成任务的时间,每个流程实例的执行路径,等等。 这个服务主要通过
查询功能来获得这些数据。
ManagementService
Activiti的引擎管理类,提供了对 Activiti 流程引擎的管理和维护功能,这些功能不在工作流驱动的应用
程序中使用,主要用于 Activiti 系统的日常维护。
5.idea中的工作流插件
Activiti BPMN visualizer简单使用
1.安装
2,使用-绘制流程
3.流程符号
BPMN 2.0是业务流程建模符号2.0的缩写。
它由Business Process Management Initiative这个非营利协会创建并不断发展。作为一种标识,BPMN
2.0是使用一些符号来明确业务流程设计流程图的一整套符号规范,它能增进业务建模时的沟通效率。
目前BPMN2.0是最新的版本,它用于在BPM上下文中进行布局和可视化的沟通。
接下来我们先来了解在流程设计中常见的 符号。
BPMN2.0的基本符合主要包含:
事件 Event
活动 Activity
活动是工作或任务的一个通用术语。一个活动可以是一个任务,还可以是一个当前流程的子处理流程;
其次,你还可以为活动指定不同的类型。常见活动如下:
网关 GateWay
网关用来处理决策,有几种常用网关需要了解:
流向 Flow
流是连接两个流程节点的连线。常见的流向包含以下几种:
6.Activiti流程操作
6.1流程的部署
单个文件部署
/** * 实现文件的单个部署 */ @Test public void test03(){ // 1.获取ProcessEngine对象 ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); // 2.获取RepositoryService进行部署操作 RepositoryService service = engine.getRepositoryService(); // 3.使用RepositoryService进行部署操作 Deployment deploy = service.createDeployment() .addClasspathResource("bpmn/evection.bpmn") // 添加bpmn资源 .addClasspathResource("bpmn/evection.png") // 添加png资源 .name("出差申请流程") .deploy();// 部署流程 // 4.输出流程部署的信息 System.out.println("流程部署的id:" + deploy.getId()); System.out.println("流程部署的名称:" + deploy.getName()); }
部署zip文件 将bpmn文件和png文件两个打包为一个zip文件,统一上传
/** * 通过一个zip文件来部署操作 */ @Test public void test04(){ // 定义zip文件的输入流 InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("bpmn/evection.zip"); // 对 inputStream 做装饰 ZipInputStream zipInputStream = new ZipInputStream(inputStream); ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); 上传后的数据库中的数据和单个文件上传其实是一样的。 4.1.3 操作数据表 流程定义部署后操作activiti中的三张表 act_re_deployment: 流程定义部署表,每部署一次就增加一条记录 act_re_procdef :流程定义表,部署每个新的流程定义都会在这张表中增加一条记录 RepositoryService repositoryService = engine.getRepositoryService(); Deployment deploy = repositoryService.createDeployment() .addZipInputStream(zipInputStream) .name("出差申请流程") .deploy(); // 4.输出流程部署的信息 System.out.println("流程部署的id:" + deploy.getId()); System.out.println("流程部署的名称:" + deploy.getName()); }
操作数据表 :流程定义部署后操作activiti中的三张表
act_re_deployment: 流程定义部署表,每部署一次就增加一条记录
**act_re_procdef :**流程定义表,部署每个新的流程定义都会在这张表中增加一条记录
act_ge_bytearray :流程资源表,流程部署的 bpmn文件和png图片会保存在该表中
6.2启动流程实例
流程定义部署在Activiti后就可以通过工作流管理业务流程,也就是说上边部署的出差申请流程可以使用
了。针对该流程,启动一个流程表示发起一个新的出差申请单,这就相当于Java类和Java对象的关系,类定
义好了后需要new创建一个对象使用,当然可以new出多个对象来,对于出差申请流程,张三可以发起
一个出差申请单需要启动一个流程实例。
/** * 启动一个流程实例 */ @Test public void test05(){ // 1.创建ProcessEngine对象 ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); // 2.获取RuntimeService对象 RuntimeService runtimeService = engine.getRuntimeService(); // 3.根据流程定义的id启动流程 String id= "evection"; ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(id); // 4.输出相关的流程实例信息 System.out.println("流程定义的ID:" +processInstance.getProcessDefinitionId()); System.out.println("流程实例的ID:" + processInstance.getId()); System.out.println("当前活动的ID:" + processInstance.getActivityId()); }
输出内容:
启动流程实例涉及到的表结构
act_hi_actinst 流程实例执行历史
act_hi_identitylink 流程的参与用户的历史信息
act_hi_procinst 流程实例历史信息
act_hi_taskinst 流程任务历史信息
act_ru_execution 流程执行信息
act_ru_identitylink 流程的参与用户信息
act_ru_task 任务信息
6.3任务查找
流程启动后,任务的负责人就可以查询自己当前能够处理的任务了,查询出来的任务都是当前用户的待
办任务
/** * 任务查询 */ @Test public void test06(){ String assignee ="zhansan"; ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); // 任务查询 需要获取一个 TaskService 对象 TaskService taskService = engine.getTaskService(); // 根据流程的key和任务负责人 查询任务 List<Task> list = taskService.createTaskQuery() .processDefinitionKey("evection") .taskAssignee(assignee) .list(); // 输出当前用户具有的任务 for (Task task : list) { System.out.println("流程实例id:" + task.getProcessInstanceId()); System.out.println("任务id:" + task.getId()); System.out.println("任务负责人:" + task.getAssignee()); System.out.println("任务名称:" + task.getName()); } }
6.4流程任务处理
任务负责人查询出来了待办的人,选择任务进行处理,完成任务
/** * 流程任务的处理 */ @Test public void test07(){ ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); TaskService taskService = engine.getTaskService(); Task task = taskService.createTaskQuery() .processDefinitionKey("evection") .taskAssignee("zhansan") .singleResult(); // 完成任务 taskService.complete(task.getId()); }
zhangsan处理了这个操作后,流程就流转到了 lisi处
然后就是不同的用户登录,然后查询任务处理任务,直到任务流程走完。
6.5流程定义的查询
查询流程相关的信息,包括流程的定义,流程的部署,流程定义的版本
/**
- 查询流程的定义
*/
@Test
public void test08(){
ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = engine.getRepositoryService();
// 获取一个 ProcessDefinitionQuery对象 用来查询操作
ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();
List list = processDefinitionQuery.processDefinitionKey(“evection”)
.orderByProcessDefinitionVersion() // 安装版本排序
.desc() // 倒序
.list();
// 输出流程定义的信息
for (ProcessDefinition processDefinition : list) {
System.out.println(“流程定义的ID:” + processDefinition.getId());
System.out.println(“流程定义的name:” + processDefinition.getName());
System.out.println(“流程定义的key:” + processDefinition.getKey());
System.out.println(“流程定义的version:” +
processDefinition.getVersion());
System.out.println(“流程部署的id:” +
processDefinition.getDeploymentId());
}
}
6.6流程的删除
/** * 删除流程 */ @Test public void test09(){ ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); RepositoryService repositoryService = engine.getRepositoryService(); // 删除流程定义,如果该流程定义已经有了流程实例启动则删除时报错 repositoryService.deleteDeployment("12501"); // 设置为TRUE 级联删除流程定义,及时流程有实例启动,也可以删除,设置为false 非级联删 除操作。 //repositoryService.deleteDeployment("12501",true); }
注意:项目开发中级联删除操作的权限一般只开发给超级管理员使用。
6.7从了数据库中下载流程资源
现在我们的流程资源文件已经上传到了数据库中,如果其他用户想要查看这些资源,可以从数据库中把
这些资源下载到本地。
解决方案:
- jdbc对blob类型处理clob类型数据读取出来就可以了。
- 使用activiti的api来实现操作。
使用activiti的api来操作我们需要添加commons-io的依赖
<dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.6</version> </dependency>
/** * 读取数据库中的资源文件 */ @Test public void test10() throws Exception{ // 1.得到ProcessEngine对象 ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); // 2.获取RepositoryService对象 RepositoryService repositoryService = engine.getRepositoryService(); // 3.得到查询器 ProcessDefinition definition = repositoryService.createProcessDefinitionQuery() .processDefinitionKey("evection") .singleResult(); // 4.获取流程部署的id String deploymentId = definition.getDeploymentId(); // 5.通过repositoryService对象的相关方法 来获取图片信息和bpmn信息 // png图片 InputStream pngInput = repositoryService.getResourceAsStream(deploymentId,definition.getDiagramResourceName()); // bpmn 文件的流 InputStream bpmnInput = repositoryService.getResourceAsStream(deploymentId,definition.getResourceName()); // 6.文件的保存 File filePng = new File("d:/evection.png"); File fileBpmn = new File("d:/evection.bpmn"); OutputStream pngOut = new FileOutputStream(filePng); OutputStream bpmnOut = new FileOutputStream(fileBpmn); IOUtils.copy(pngInput,pngOut); IOUtils.copy(bpmnInput,bpmnOut); pngInput.close(); pngOut.close(); bpmnInput.close(); bpmnOut.close(); }
6.8流程历史信息查看
即使流程定义已经被删除了,流程执行的实例信息通过前面的分析,依然保存在Activiti的act_hi_* 的相
关表结构中,所以我们还是可以查询流程的执行的历史信息,可以通过HistoryService来查看
/** * 流程历史信息查看 */ @Test public void test11(){ ProcessEngine engine = ProcessEngines.getDefaultProcessEngine(); // 查看历史信息我们需要通过 HistoryService来实现 HistoryService historyService = engine.getHistoryService(); // 获取 actinst 表的查询对象 HistoricActivityInstanceQuery instanceQuery =historyService.createHistoricActivityInstanceQuery(); instanceQuery.processDefinitionId("evection:1:12504"); instanceQuery.orderByHistoricActivityInstanceStartTime().desc(); List<HistoricActivityInstance> list = instanceQuery.list(); // 输出查询的结果 for (HistoricActivityInstance hi : list) { System.out.println(hi.getActivityId()); System.out.println(hi.getActivityName()); System.out.println(hi.getActivityType()); System.out.println(hi.getAssignee()); System.out.println(hi.getProcessDefinitionId()); System.out.println(hi.getProcessInstanceId()); System.out.println("-----------------------"); } }