Activiti7的基本原理和使用 1 什么是工作流?# 1.1 工作流介绍#
工作流(Workflow),就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程,从而实现某个预期的业务目标,或者促使此目标的实现”。
1.2 工作流系统# 1.2.1 概述#
一个软件系统中具有工作流的功能,我们把它称为工作流系统。
一个系统中工作流的功能是什么?就是对系统的业务流程进行自动化管理,所以工作流是建立在业务流程的基础上,所以一个软件的系统核心根本上还是系统的业务流程,工作流只是协助进行业务流程管理。
即使没有工作流业务系统也可以开发运行,只不过有了工作流可以更好的管理业务流程,提高系统的可扩展性。
1.2.2 使用行业#
消费品行业,制造业,电信服务业,银证险等金融服务业,物流服务业,物业服务业,物业管理,大中型进出口贸易公司,政府事业机构,研究院所及教育服务业等,特别是大的跨国企业和集团公司。
1.2.3 具体应用#
关键业务流程:订单、报价处理、合同审核、客户电话处理、供应链管理等。
行政管理类:出差申请、加班申请、请假申请、用车申请、各种办公用品申请、购买申请、日报周报等凡是原来手工流转处理的行政表单。
人事管理类:员工培训安排、绩效考评、职位变动处理、员工档案信息管理等。
财务相关类:付款请求、应收款处理、日常报销处、出差报销、预算和计划申请等。
客户服务类:客户信息管理、客户投诉、请求处理、售后财务管理等。
特殊服务类:ISO系统对应流程、质量管理对应流程、产品数据信息管理、贸易公司报关处理、物流公司货物跟踪处理等各种通过表单逐步手动流转完成的任务均可应用工作流软件自动规范实施。
1.3 工作流实现方式#
在没有专门的工作流引擎之前,我们之前为了实现流程控制,通常的做法就是采用状态字段的值来跟踪流程的变化情况。这样不同角色的用户,通过状态字段的取值来决定记录是否显示。
针对有权限可以查看的记录,当前用户根据自己的角色来决定审批是否是合格的操作。如果合格将状态字段设置一个值,来代表合格;当然如果不合格也需要设置一个值来代表不合格的情况。
这是一种最为原始的方式。通过状态字段虽然做到了流程控制,但是当我们的流程发生变更的时候,这种方式所编写的代码也要进行调整。
那么有没有专业的方式来实现工作流的管理呢?并且可以做到业务流程变化之后,我们的程序可以不用改变,如果可以实现这样的效果,那么我们的业务系统的适应能力就得到了极大提升。答案就是采用工作流引擎。
1.4 工作流实现原理分析#
如何做到我们在业务流程发生变更后,我们的业务系统代码可以不发生改变?原理如下:
将业务流程的每个节点读取到数据库中,这样每个节点(包括开始节点和结束节点)就是数据库中的一条记录,当发生业务流程的时候,不断的从业务流程图中读取下一个节点,其实就相当于操作节点对应的数据库记录,这样就实现流程管理和状态字段无关。
2 什么是Activiti7?# 2.1 Activiti7介绍# 2.1.1 概述#
Alfresco 软件在 2010 年 5 月 17 日宣布 Activiti 业务流程管理(BPM)开源项目的正式启动, 其 首席架构师由业务流程管理 BPM 的专家 Tom Baeyens 担任, Tom Baeyens 就是原来 jbpm 的架构师, 而 jbpm 是一个非常有名的工作流引擎,当然 activiti 也是一个工作流引擎。
Activiti 是一个工作流引擎, activiti 可以将业务系统中复杂的业务流程抽取出来,使用专门的 建模语言(BPMN2.0)进行定义,业务系统按照预先定义的流程进行执行,实现了业务系统的业务 流程由 activiti 进行管理,减少业务系统由于流程变更进行系统升级改造的工作量,从而提高系统的 健壮性,同时也减少了系统开发维护成本。
官方网站
2.1.2 Activiti7内部核心机制#
1️⃣业务流程图要规范化,需要遵守一套标准。
2️⃣业务流程图本质上就是一个XML文件,而XML可以存放所要的数据。
3️⃣读取业务流程图的过程就是解析XML文件的过程。
4️⃣读取一个业务流程图的结点就相当于解析一个XML的结点,进一步将数据插入到MySQL表中,形成一条记录。
5️⃣将一个业务流程图的所有节点都读取并存入到MySQL表中。
6️⃣后面只要读取MySQL表中的记录就相当于读取业务流程图的一个节点。
7️⃣业务流程的推进,后面就转换为读取表中的数据,并且处理数据,结束的时候这一行数据就可以删除了。
2.1.3 BPM#
BPM(Business Process Management),即业务流程管理,是一种以规范化的构造端到端的卓越业务流程为中心,以持续的提高组织业务绩效为目的的系统化方法,常见商业管理教育如EMBA、MBA等均将BPM包含在内。
企业流程管理主要是对企业内部改革,改变企业只能管理机构重叠、中间层次多、流程不闭环等,做到机构不重叠、业务不复杂,达到缩短流程周期、节约运作资本、提高企业效益的作用。
比较下面的两个人事加薪流程,那个效率更高?
人事加薪流程制定加薪计划部门经理审批总经理审批财务经理审批
1万元以内1万元以上人事加薪流程制定加薪计划部门经理审批1万元财务经理审批总经理审批
上面的两个流程的区别在于第二个流程在执行时,如果本次加薪金额在一万元内不再由总经理审批将比第一个流程缩短流程周期,从而提高效率。
比较下面的两个看病的流程,那个效率更高?
病人看病流程病人去医院看病挂号看病交费取药
病人看病流程病人去医院看病挂号看病交费取药
上面的两个流程的区别在于第二个流程将交费和取药放在一起进行,这样导致的结果是此窗口的工作人员必须具有财务、药学专业知识,岗位强度加大,人员培训难度加大从而导致人员不易扩展,工作效率低下。
2.1.4 BPM软件#
BPM软件就是根据企业中业务环境的变化,推进人和人之间、人和系统之间以及系统和系统之间的整合及调整的经营方法和解决方案的IT工具。通常以Internet方式实现信息传、数据同步、业务监控和企业业务流程的持续升级优化,从而实现跨应用、跨部门、夸合作伙伴和客户的企业运作。通过BPM软件对企业内部及外部的业务流程的整个生命周期进行建模、自动化、管理监控和优化,使企业成本降低,利润得以大幅度提升。
BPM软件在企业中应用领域广泛,凡是有业务流程的地方都可以用BPM软件进行管理,比如企业人事办公管理、采购流程管理、公文审批流程管理、财务管理等。
2.1.5 BPMN#
BPMN(Business Process Model And Notation),业务流程模型和符号,是由BPMI(Business Process Management Initiative)开发的一套的业务流程建模符号,使用BPMN提供的符号可以创建业务流程。2004年5月发布了BPMN1.0规范。BPMI于2005年9月并入OMG(The Object Management Group,对象管理组织)组织。OMG于2011年1月发布BPMN2.0的最终版本。
BPMN是目前被各BPM厂商广泛接受的BPM标准。Activit就是使用BPMN2.0进行流程建模、流程执行管理,它包括很多的建模符号。
比如:
Event用一个圆圈表示,它是流程中运行过程中发生的事情。
活动用圆形矩形表示,一个流程由一个活动或多个活动组成。
一个BPMN的例子:
首先当事人发起一个请假单;
其次他所在部门的经理对请假单进行审核;
然后人事经理进行复核并进行备案;
最后请假流程结束。
BPMN其实是用XML表示业务流程的,上面的.bpmn文件使用文本编辑器打开:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 <?xml version="1.0" encoding="utf-8" ?> <bpmn2:definitions xmlns:bpmn2 ="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmndi ="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc ="http://www.omg.org/spec/DD/20100524/DC" xmlns:di ="http://www.omg.org/spec/DD/20100524/DI" id ="sample-diagram" targetNamespace ="http://bpmn.io/schema/bpmn" xsi:schemaLocation ="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd" > <bpmn2:process id ="process1596086637078" name ="流程1596086637078" > <bpmn2:startEvent id ="StartEvent_01ydzqe" name ="开始" > <bpmn2:outgoing > SequenceFlow_13g4uaz</bpmn2:outgoing > </bpmn2:startEvent > <bpmn2:userTask id ="UserTask_1lf9x0v" name ="填写请假单" > <bpmn2:incoming > SequenceFlow_13g4uaz</bpmn2:incoming > <bpmn2:outgoing > SequenceFlow_0yljdna</bpmn2:outgoing > </bpmn2:userTask > <bpmn2:sequenceFlow id ="SequenceFlow_13g4uaz" sourceRef ="StartEvent_01ydzqe" targetRef ="UserTask_1lf9x0v" /> <bpmn2:userTask id ="UserTask_0xa95fp" name ="部门经理审批" > <bpmn2:incoming > SequenceFlow_0yljdna</bpmn2:incoming > <bpmn2:outgoing > SequenceFlow_0wc7wvy</bpmn2:outgoing > </bpmn2:userTask > <bpmn2:sequenceFlow id ="SequenceFlow_0yljdna" sourceRef ="UserTask_1lf9x0v" targetRef ="UserTask_0xa95fp" /> <bpmn2:userTask id ="UserTask_1p57lka" name ="人事复核" > <bpmn2:incoming > SequenceFlow_0wc7wvy</bpmn2:incoming > <bpmn2:outgoing > SequenceFlow_0o4nsg1</bpmn2:outgoing > </bpmn2:userTask > <bpmn2:sequenceFlow id ="SequenceFlow_0wc7wvy" sourceRef ="UserTask_0xa95fp" targetRef ="UserTask_1p57lka" /> <bpmn2:endEvent id ="EndEvent_05yb7io" name ="结束" > <bpmn2:incoming > SequenceFlow_0o4nsg1</bpmn2:incoming > </bpmn2:endEvent > <bpmn2:sequenceFlow id ="SequenceFlow_0o4nsg1" sourceRef ="UserTask_1p57lka" targetRef ="EndEvent_05yb7io" /> </bpmn2:process > <bpmndi:BPMNDiagram id ="BPMNDiagram_1" > <bpmndi:BPMNPlane id ="BPMNPlane_1" bpmnElement ="process1596086637078" > <bpmndi:BPMNShape id ="StartEvent_01ydzqe_di" bpmnElement ="StartEvent_01ydzqe" > <dc:Bounds x ="382" y ="82" width ="36" height ="36" /> <bpmndi:BPMNLabel > <dc:Bounds x ="389" y ="58" width ="22" height ="14" /> </bpmndi:BPMNLabel > </bpmndi:BPMNShape > <bpmndi:BPMNShape id ="UserTask_1lf9x0v_di" bpmnElement ="UserTask_1lf9x0v" > <dc:Bounds x ="490" y ="60" width ="100" height ="80" /> </bpmndi:BPMNShape > <bpmndi:BPMNEdge id ="SequenceFlow_13g4uaz_di" bpmnElement ="SequenceFlow_13g4uaz" > <di:waypoint x ="418" y ="100" /> <di:waypoint x ="490" y ="100" /> </bpmndi:BPMNEdge > <bpmndi:BPMNShape id ="UserTask_0xa95fp_di" bpmnElement ="UserTask_0xa95fp" > <dc:Bounds x ="700" y ="60" width ="100" height ="80" /> </bpmndi:BPMNShape > <bpmndi:BPMNEdge id ="SequenceFlow_0yljdna_di" bpmnElement ="SequenceFlow_0yljdna" > <di:waypoint x ="590" y ="100" /> <di:waypoint x ="700" y ="100" /> </bpmndi:BPMNEdge > <bpmndi:BPMNShape id ="UserTask_1p57lka_di" bpmnElement ="UserTask_1p57lka" > <dc:Bounds x ="910" y ="60" width ="100" height ="80" /> </bpmndi:BPMNShape > <bpmndi:BPMNEdge id ="SequenceFlow_0wc7wvy_di" bpmnElement ="SequenceFlow_0wc7wvy" > <di:waypoint x ="800" y ="100" /> <di:waypoint x ="910" y ="100" /> </bpmndi:BPMNEdge > <bpmndi:BPMNShape id ="EndEvent_05yb7io_di" bpmnElement ="EndEvent_05yb7io" > <dc:Bounds x ="1152" y ="82" width ="36" height ="36" /> <bpmndi:BPMNLabel > <dc:Bounds x ="1159" y ="125" width ="22" height ="14" /> </bpmndi:BPMNLabel > </bpmndi:BPMNShape > <bpmndi:BPMNEdge id ="SequenceFlow_0o4nsg1_di" bpmnElement ="SequenceFlow_0o4nsg1" > <di:waypoint x ="1010" y ="100" /> <di:waypoint x ="1152" y ="100" /> </bpmndi:BPMNEdge > </bpmndi:BPMNPlane > </bpmndi:BPMNDiagram > </bpmn2:definitions >
2.2 Activiti如何使用# 2.2.1 整合Activiti#
Activiti是一个工作流引擎,业务系统使用Activiti来对系统的业务流程进行自动化管理,为了方便业务系统访问(操作)Activiti的接口或功能,通常将Activiti和业务系统的环境集成在一起。
2.2.2 实现业务流程建模,使用BPMN实现业务流程图#
使用Activiti流程建模工具(Activity-designer)定义业务流程(.bpmn文件)。
.bpmn文件就是业务流程定义文件,通过xml定义业务流程。
如果使用其他公司开发的工作引擎一般都提供了可视化的建模工具(Process Designer)用于生成流程定义文件,建模工具操作直观,一般都支持图形化拖拽方式、多窗口的用户界面、丰富的过程图形元素、过程元素拷贝、粘贴、删除等功能。
2.2.3 部署业务流程到Activiti#
向Activiti部署业务流程定义(.bpmn文件)。
使用Activiti提供的API向Activiti中部署.bpmn文件(一般情况下还需要一起部署业务流程的图片.png)。
2.2.4 启动流程实例(ProcessInstance)#
启动一个流程实例表示开始一次业务流程的运行,比如员工请假流程部署完成,如果张三要请假就可以启动一个流程实例,如果李四要请假也需要启动一个流程实例,两个流程的执行互不影响,就好比定义一个Java类,实例化两个Java对象一样,部署的流程就好比Java类,启动一个流程实例就好比new一个Java对象。
2.2.5 查询待办任务(Task)#
因为现在系统的业务流程已经交给Activiti管理,通过Activiti就可以查询当前流程执行到哪里了,当前用户需要办理什么任务了,这些Activiti帮我们管理了,而不像传统方式中需要我们在SQL语句中的WHERE条件中指定当前查询的状态值是多少。。
2.2.6 处理待办任务#
用户查询待办任务后,就可以办理某个任务,如果这任务办理完成还需要其他用户办理,比如采购单创建后由部门经理审核,这个过程也是由Activiti帮我们完成了,不需要我们在代码中硬编码指定下一个任务办理人了。
2.2.7 结束流程#
当任务办理完成没有下一个任务/结点了,这个流程实例就完成了。
3 环境准备# 3.1 开发环境# 3.1.1 Java环境#
3.1.2 数据库#
3.1.3 Web容器#
3.1.4 开发工具#
MySQL客户端连接工具:Navicat for MySQL。
文件编辑器NotePad++或其他。
Java开发工具:IDEA(Eclipse)。
3.2 Activiti环境#
3.2.1 IDEA中安装ActivitiDesigner(Activiti流程设计器)#
3.2.2 在IDEA中解决actiBPM中文乱码问题#
在IDEA中将File–>Settings–>Editor–>File Encodings修改为UTF-8
在IDEA的Help–>Edit Custom VM Options中末尾添加-Dfile.encoding=UTF-8
在IDEA的安装目录的bin目录下将idea.exe.vmoptions和idea64.exe.vmoptions两个文件末尾添加-Dfile.encoding=UTF-8
3.2.3 Activiti支持的数据库#
Activiti的运行需要数据库的支撑,支持如下版本:
h2。
MySQL。
Oracle。
Db2。
postgres。
mssql。
3.2.4 创建activiti数据库#
1 CREATE DATABASE activiti DEFAULT CHARACTER SET utf8mb4;
3.2.5 创建表#
3.2.5.1 创建Java工程#
3.2.5.2 加入相关jar包的Maven坐标#
在Java工程中加入ProcessEngine所需要的jar包,包括:
activiti-engine-7.0.0.GA.jar
activiti依赖的jar包:mybatis、slf4j、log4j等
activiti依赖的spring的jar包
数据库驱动
第三方数据库连接池dbcp
单元测试junit
pom.xml
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 <properties > <activiti.version > 7.0.0.GA</activiti.version > </properties > <dependencies > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-engine</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-spring</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-bpmn-model</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-bpmn-converter</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-json-converter</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti</groupId > <artifactId > activiti-bpmn-layout</artifactId > <version > ${activiti.version}</version > </dependency > <dependency > <groupId > org.activiti.cloud</groupId > <artifactId > activiti-cloud-services-api</artifactId > <version > 7-201802-EA</version > </dependency > <dependency > <groupId > mysql</groupId > <artifactId > mysql-connector-java</artifactId > <version > 8.0.19</version > </dependency > <dependency > <groupId > junit</groupId > <artifactId > junit</artifactId > <version > 4.12</version > </dependency > <dependency > <groupId > org.apache.logging.log4j</groupId > <artifactId > log4j-core</artifactId > <version > 2.13.3</version > </dependency > <dependency > <groupId > org.apache.logging.log4j</groupId > <artifactId > log4j-api</artifactId > <version > 2.13.3</version > </dependency > <dependency > <groupId > org.slf4j</groupId > <artifactId > slf4j-api</artifactId > <version > 1.7.30</version > </dependency > <dependency > <groupId > org.apache.logging.log4j</groupId > <artifactId > log4j-slf4j-impl</artifactId > <version > 2.13.3</version > </dependency > <dependency > <groupId > org.mybatis</groupId > <artifactId > mybatis</artifactId > <version > 3.4.5</version > </dependency > <dependency > <groupId > commons-dbcp</groupId > <artifactId > commons-dbcp</artifactId > <version > 1.4</version > </dependency > </dependencies > <dependencyManagement > <dependencies > <dependency > <groupId > org.activiti.cloud.dependencies</groupId > <artifactId > activiti-cloud-dependencies</artifactId > <version > 7.0.0.GA</version > <scope > import</scope > <type > pom</type > </dependency > </dependencies > </dependencyManagement >
3.2.5.3 日志文件log4j2.xml#
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 <?xml version="1.0" encoding="UTF-8" ?> <configuration status ="INFO" > <appenders > <console name ="Console" target ="SYSTEM_OUT" > <PatternLayout pattern ="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n" /> </console > </appenders > <loggers > <root level ="info" > <appender-ref ref ="Console" /> </root > </loggers > </configuration >
3.2.5.4 Activit核心配置文件activiti-cfg.xml#
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 <?xml version="1.0" encoding="UTF-8" ?> <beans xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:context ="http://www.springframework.org/schema/context" xmlns ="http://www.springframework.org/schema/beans" 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.xsd" > <bean id ="dataSource" class ="org.apache.commons.dbcp.BasicDataSource" > <property name ="driverClassName" value ="com.mysql.cj.jdbc.Driver" /> <property name ="username" value ="root" /> <property name ="url" value ="jdbc:mysql://192.168.134.100:3306/activiti?useUnicode=true& characterEncoding=UTF-8& autoReconnect=true& useSSL=false& serverTimezone=GMT%2B8& allowPublicKeyRetrieval=true" /> <property name ="password" value ="123456" /> <property name ="maxActive" value ="3" /> <property name ="maxIdle" value ="1" /> </bean > <bean id ="processEngineConfiguration" class ="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration" > <property name ="dataSource" ref ="dataSource" /> <property name ="databaseSchemaUpdate" value ="true" /> </bean > </beans >
3.2.5.5 测试#
创建ProcessEngineConfiguration,通过ProcessEngineConfiguration创建ProcessEngine,在创建ProcessEngine的同时会自动创建数据库。
示例:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 package com.sunxiaping;import org.activiti.engine.ProcessEngine;import org.activiti.engine.ProcessEngineConfiguration;public class ActivitiTest { public static void main (String[] args) { ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti-cfg.xml" ); ProcessEngine processEngine = configuration.buildProcessEngine(); System.out.println("processEngine = " + processEngine); } }
1️⃣:运行以上程序即可完成Activiti数据库表的创建,通过改变activiti-cfg.xml中的databaseSchemaUpdate参数的值执行不同的数据表处理策略。
2️⃣:上面的方法createProcessEngineConfigurationFromResource在执行activiti-cfg.xml中找固定的名称processEngineConfiguration,也可以使用重载方法调用,这时就可以不用限定processEngineConfiguration名称。
1 2 3 public static ProcessEngineConfiguration createProcessEngineConfigurationFromResource (String resource, String beanName) { return BeansConfigurationHelper.parseProcessEngineConfigurationFromResource(resource, beanName); }
3.2.6 数据库表的命名规则#
Activiti的表都是以ACT_
开头。第二部分是表示表的用途的两个字母标识。用途也和服务的API对应。
ACT_RE_*
:’RE’表示Repository。这个前缀的表包含了流程定义和流程静态资源(图片、规则等等)。
ACT_RU_*
:’RU’表示Runtime。这些运行时的表,包含流程实例,任务、变量,异步任务等运行中的数据。Activiti只在流程实例执行过程中保存这些数据,在流程结束时就会删除这些记录。这些运行时表可以一直很小并且速度很快。
ACT_HI_*
:’HI’表示History。这些表包含历史数据,比如历史流程实例,变量,任务等等。
ACT_GE_*
:’GE’表示General。通用数据,用于不同场景下。