在 上一篇文章 中，我们了解到什么是工作流引擎以及OSWorkflow的基本用法。这一篇文章中，向大家介绍另一种工作流引擎框架，Activiti。

什么是 activiti ？

Activiti项目是一项新的基于Apache许可的开源BPM平台，从基础开始构建，旨在提供支持新的BPMN 2.0标准，包括支持对象管理组（OMG），面对新技术的机遇，诸如互操作性和云架构，提供技术实现。

工作流示例

什么是BPMN 2.0？

由BPMI(The Business process Management Initiative)开发了一套标准叫业务流程建模符号(BPMN – Business Process Modeling Notation)。在 BPMI Notation Working Group超过2年的努力，于2004年5月对外发布了BPMN 1.0 规范。后BPMI并入到OMG组织，OMG于2011年推出BPMN2.0标准，对BPMN进行了重新定义(Business Process Model and Notation)。BPMN的主要目标是提供一些被所有业务用户容易理解的符号，从创建流程轮廓的业务分析到这些流程的实现，直到最终用户的管理监控。BPMN也支持提供一个内部的模型可以生成可执行的BPEL4WS。因此BPMN的出现，弥补了从业务流程设计到流程开发的间隙。

BPMN定义了一个业务流程图（Business Process Diagram），该业务流程图基于一个流程图（flowcharting），该流程图被设计用于创建业务流程操作的图形化模型。而一个业务流程模型（Business Process Model），指一个由图形对象（graphical objects）组成的网状图，图形对象包括活动（activities)和用于定义这些活动执行顺序的流程控制器（flow controls）。

BPMN2.0规范内容

常用的BPMN符号

• 启动与结束事件(event)

启动事件与结束事件是很重要的一部分，分别负责流程的开始与结束。

启动事件

结束事件

1.启动事件

启动事件又分为：空启动事件；定时启动事件；异常启动事件。

1）空启动事件

以上XML表示一个空启动事件，由于startEvent标签内没有任何元素定义，因此表示一个空启动事件。

Activiti扩展了formKey属性avtiviti:formKey，可以用来指定启动事件关联的表单文件。

activiti扩展了initiator事件activiti:initiator，可以用来记录启动流程人的ID，启动流程之后此属性指定的变量就会自动设置当前人的名称。

---

属性名称 属性说明

avtiviti:formKey Activiti扩展的formKey属性，可以用来指定启动事件关联的表单文件

activiti:initiator activiti扩展的initiator事件，可以用来记录启动流程人的ID，启动流程之后此属性指 定的变量就会自动设置当前人的名称

---

2）定时启动事件

定时启动事件可以用于一次性定时启动，也可以用于特定时间定时启动。

定时启动事件

<startEvent id=”timerstartevent1″ name=”Timer start”>

<timerEventDefinition></timerEventDefinition>

</startEvent>

以上XML就表示一个空定时启动事件。

---

属性名称 属性说明

timeDate 一次性定时启动，具体到一个日期

timeDuration 设置多长时间之后启动流程

timeCycle 周期性启动任务，用来设定循环的时间间隔，表示多长时间执行一次循环

---

3）异常启动事件

异常启动事件可以出发一个异常子流程，但不能通过API方式启动，总是在另外一个子流程抛出异常结束事件的时候被触发。异常启动事件”捕获型”，而异常结束事件是抛出型的。

异常启动事件

<endEvent id=”errorendevent1″ name=”ErrorEnd”>

<errorEventDefinition></errorEventDefinition>

</endEvent>

以上XML就表示一个空定时启动事件。

4）消息启动事件

消息启动事件可以通过一个消息名称触发，从而启动一个流程实例，还可以结合消息抛出事件一起使用。

消息启动事件

<startEvent id=”messagestartevent1″ name=”Message start”>

<messageEventDefinition></messageEventDefinition>

</startEvent>

2.结束事件

结束事件又分为：空结束事件；异常结束事件；取消结束事件。

1）空结束事件

结束事件是抛出型的。空结束事件不处理抛出结果，空结束事件一般用于正常结束流程。

空结束事件

<bpmndi:BPMNShape bpmnElement=”endevent2″ id=”BPMNShape_endevent2″>

<omgdc:Bounds height=”35.0″ width=”35.0″ x=”1030.0″ y=”280.0″></omgdc:Bounds>

</bpmndi:BPMNShape>

2）异常结束事件

异常结束事件时有抛出结果的，它定义了需要抛出的错误代码，如果找到了异常开始事件定义的异常代码，则会触发异常开始事件，否则按照空结束事件处理。

异常结束事件

<bpmndi:BPMNShape bpmnElement=”errorendevent1″ id=”BPMNShape_errorendevent1″>

<omgdc:Bounds height=”35.0″ width=”35.0″ x=”1030.0″ y=”370.0″></omgdc:Bounds>

</bpmndi:BPMNShape>

3）终止结束事件

它可以终止一个流程实例的执行。

终止结束事件

<bpmndi:BPMNShape bpmnElement=”terminateendevent1″ id=”BPMNShape_terminateendevent1″>

<omgdc:Bounds height=”35.0″ width=”35.0″ x=”980.0″ y=”260.0″></omgdc:Bounds>

</bpmndi:BPMNShape>

4）取消结束事件

取消结束事件可以取消一个事务子流程的执行，同时也能在子流程中使用，当子流程在执行过程中出现异常时，可以设置一个取消结束事件。

取消结束事件

<bpmndi:BPMNShape bpmnElement=”cancelendevent1″ id=”BPMNShape_cancelendevent1″>

<omgdc:Bounds height=”35.0″ width=”35.0″ x=”860.0″ y=”330.0″></omgdc:Bounds>

</bpmndi:BPMNShape>

• 容器(Container)

容器

• 任务(Task)

任务时流程中重要的组成部分,可分为：用户任务；脚本任务；WebServices任务；业务规则任务；邮件任务；Mule任务；Camle任务；手动任务；Java Service 任务；Shell任务。

1）用户任务

用户任务

<process id=”myProcess” name=”My process” isExecutable=”true”>

<userTask id=”usertask1″ name=”User Task”></userTask>

</process>

以上XML定义了一个用户任务。

---

属性名称 属性说明

activiti:assignee 用来指定用户任务的处理人

activiti:cadidateUsers 用来指定用户任务的候选人，多个用逗号隔开

activiti:cadidateGroups 用来指定多个候选组，多个用逗号隔开

activiti:dueDate 设置任务的到期日，通常用变量代替而不是设定一个具体的日期

activiti:priority 设定任务的优先级，取值区间[0,100]

---

2）脚本任务

脚本任务可以运行引擎依赖的语言之外的脚本语言。

脚本任务

<process id=”myProcess” name=”My process” isExecutable=”true”>

<scriptTask id=”scripttask1″ name=”Script Task” activiti:autoStoreVariables=”false”></scriptTask>

</process>

---

属性名称 属性说明

scriptFormat 用来指定符合规范的脚本类型

activiti:resultvariable 把脚本处理的结果保存到一个变量中

activiti:priority 设定任务的优先级，取值区间[0,100]

---

3）Service 任务

Service 任务允许指定一个实现了指定接口的类，或者执行一个表达式，可以把一个结果保存到一个变量中。

JavaServices任务

<process id=”myProcess” name=”My process” isExecutable=”true”>

<serviceTask id=”servicetask1″ name=”Service Task”></serviceTask>

</process>

---

属性名称 属性说明

activiti:class 实现了接口JavaDelegate的Java类

activit:expression 一个表达式

activiti: delegate Expression 实现了指定接口的表达式

activiti:resultvariable 把脚本处理的结果保存到一个变量中

---

4）业务规则任务

业务规则任务可以根据流程变量的值预设的业务规则，就是把业务数据交由规则引擎处理，规则引擎根据不同的业务规则得到最终的结果在返回给调用者。

业务规则任务

<process id=”myProcess” name=”My process” isExecutable=”true”>

<businessRuleTask id=”businessruletask1″ name=”Business rule task”></businessRuleTask>

</process>

---

属性名称 属性说明

activiti:relues 定义规则的名称，多个用逗号隔开

activit:ruleVariablesInput 业务规则需要的 数据源使用${fooVar方式定义，多个用逗号隔开}

activit:ruleVariablesName 规则执行结果变量，变量的值为ruleVariablesInput定义的变量集合

activiti:execlude 用来设置是否排除某些规则

---

5）邮件任务

邮件任务可以通过Activiti发送邮件，其中邮件的信息通过变量的方式传递。

邮件任务

<process id=”myProcess” name=”My process” isExecutable=”true”>

<serviceTask id=”mailtask1″ name=”Mail Task” activiti:type=”mail”></serviceTask>

</process>

---

属性名称 是否必须 描述

mailServerHost 否 邮件任务的主机名，默认为host

mailServerPost 是，如果不是默认的端口 默认为25，如果是使用SSL则为465

mailServerDefaultFrom 否 发件人 email ,默认：activiti@activiti.org

mailServerUsername 否，是否需要认证设置 邮件服务认证账号

mailServerPassword 否，是否需要认证设置 邮件服务认证密码

---

---

属性名称 属性说明

to 必填，收件人，多个收件人用逗号隔开

from 邮件发送人地址，如果不设置则使用mailServerDefaultFrom属性指定的发件人

subject 发件人email如果不设置，默认为activiti@activiti.org

cc 抄送人列表

bcc 密送人列表

charset 邮件内容字符集，建议使用UTF-8

text 纯文本内容的邮件内容

html html格式的邮件内容

---

• 网关(Gateway)

网关用于控制流程的走向，可分为：排他网关；并行网关；包容网关；事件网关。

1）排他网关

排他网关用来对流程中的决定进行建模，流程执行到该网关时，按照输出流的顺序逐个计算，当条件计算结果为true时，继续执行，如果多个线路的计算结果都为true时，那么只会执行第一个值为true的网关。

排他 网关

<process id=”myProcess” name=”My process” isExecutable=”true”>

<exclusiveGateway id=”exclusivegateway1″ name=”Exclusive Gateway”></exclusiveGateway>

</process>

2）并行网关

并行网关用来对并发的任务进行流程建模，并行网关的任务取决于输入，输出顺序流。

拆分：并行执行所有的输出输入顺序流，并且为每一条顺序流创建一个并行执行线路。

合并：所有从并行网关拆分并执行完成的线路均在此等候，直到所有的线路都执行完成才继续向下执行。

并行网关

<process id=”myProcess” name=”My process” isExecutable=”true”>

<parallelGateway id=”parallelgateway1″ name=”Parallel Gateway”></parallelGateway>

</process>

3）包容网关

包容网关融合了排他网关和并行网关的特性，包容网关既可以同事执行多条线路。有允许在网关上设置条件，也分为拆分与合并。

包容网关

<process id=”myProcess” name=”My process” isExecutable=”true”>

<inclusiveGateway id=”inclusivegateway1″ name=”Inclusive Gateway”></inclusiveGateway>

</process>

4）事件网关

事件网关是专门为中间捕获事件设置的，它允许多个输出流指向多个不同的中间捕获事件。当流程执行到事件网关后流程处于等待的状态，因为中间等待事件需要依赖中间抛出事件触发。

事件网关

<process id=”myProcess” name=”My process” isExecutable=”true”>

<eventBasedGateway id=”eventgateway1″ name=”Event Gateway”></eventBasedGateway>

</process>

• 子流程(Subprocess)

把一切需要处理的任务归结到一起作为作为一个大流程的一部分，因为子流程嵌入在主流程中，所有也叫”嵌入式子流程”。

子流程限制：

1. 只能包含一个空启动事件；

2. 至少有一个结束事件；

3. 在子流程中不能把输出流设置到子流程之外的活动上。

1）调用活动

调用活动解决的问题是流程的通用性，和子流程一样只不过表现的方式不同而已。

调用活动

<process id=”myProcess” name=”My process” isExecutable=”true”>

<callActivity id=”callactivity1″ name=”Call activity”></callActivity>

</process>

---

• 属性名称 属性说明

calledElement 流程的ID对应的流程应该独立存在

activiti:in 调用外部流程时传入的变量，被调用活动需要获取主流的信息

activiti:out 调用活动完成后的结果

---

• 边界事件(Boundary Event)

边界事件

• 中间事件(Intermediate Event)

中间事件

• 监听器(Listener)

在Activiti 中开发人员可以通过配置监听器的方式监听各种动作，例如流程 的启动，结束，创建，任务的完成

监听器分为两类：执行监听器和任务监听器。

执行监听器可以捕获的事件如下：

1. 流程实例的启动，结束

2. 输出流的捕获

3. 活动的启动，结束

4. 路由开始，结束

5. 中间事件开始，结束

6. 触发开始事件，触发结束事件

import org.activiti.engine.delegate.DelegateExecution;

import org.activiti.engine.delegate.ExecutionListener;

public class ExecutionListenerForFlow implements ExecutionListener{

@Override

public void notify(DelegateExecution delegate) throws Exception {

}

任务监听器相对于执行监听器的使用范围要小的多，因为它只适用于用户任务，用来监听三种事件：

1. create:在任务被创建且所有的任务属性设置完成后才触发

2. assignment：在任务被分配给某个办理人之后触发

3. complete：在配置了监听器的上一个任务完成时触发

import org.activiti.engine.delegate.DelegateTask;

import org.activiti.engine.delegate.TaskListener;

public class ExecutionListenerForFlow implements TaskListener{

@Override

public void notify(DelegateTask arg0) {

// TODO Auto-generated method stub

}

}

Activiti之 HelloWorld

从官网上下载activiti，这里使用的版本是6.0，并安装Eclipse BPMN设计插件。

一切就绪后，解压wars/activiti-rest.war，从WEB-INF文件夹中拷贝lib文件夹中的依赖库和classes文件夹中的activiti-custom-context.xml文件。

使用Eclipse建立工程，并绘制bpmn图备用。

BPMN设计器及DEMO

新建HelloWorld类。

1）使用配置文件创建数据库

String resource=”activiti-custom-context.xml”;

String beanName=”processEngineConfiguration”;

ProcessEngineConfiguration configuration= ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(resource,beanName);

//创建一个流程引擎对象，在创建流程引擎对象时会自动建表

ProcessEngine engine= configuration.buildProcessEngine();

配置文件使用之前拷贝的activiti-custom-context.xml文件，修改内容如下：

数据库配置文件

之后，运行程序，成功生成28张表。

数据库表

Activiti所有的表都以ACT_开头。第二部分是表示用途的两个字母标识。用途也和服务的API对应。

1. ACT_RE_*：’RE’表示repository。这个前缀的表包含了流程定义和流程静态资源 （图片，规则等等）。

2. ACT_RU_*：’RU’表示runtime。这些是运行时的表，包含流程实例，任务，变量，异步任务等运行中的数据。Activiti只在流程实例执行过程中保存这些数据， 在流程结束时就会删除这些记录。这样运行时表可以一直很小且速度很快。

3. ACT_ID_*：’ID’表示identity。这些表包含身份信息，比如用户，组等等。

4. ACT_HI_*：’HI’表示history。这些表包含历史数据，比如历史流程实例，变量，任务等等。

5. ACT_GE_*：通用数据，用于不同场景下。

资源库流程规则表

1. act_re_deployment：部署信息表

2. act_re_model：流程设计模型部署表

3. act_re_procdef：流程定义数据表

运行时数据库表

1. act_ru_execution：运行时流程执行实例表

2. act_ru_identitylink：运行时流程人员表，主要存储任务节点与参与者的相关信息

3. act_ru_task：运行时任务节点表

4. act_ru_variable：运行时流程变量数据表

历史数据库表

1. act_hi_actinst：历史节点表

2. act_hi_attachment：历史附件表

3. act_hi_comment：历史意见表

4. act_hi_identitylink：历史流程人员表

5. act_hi_detail ：历史详情表，提供历史变量的查询

6. act_hi_procinst：历史流程实例表

7. act_hi_taskinst：历史任务实例表

8. act_hi_varinst：历史变量表

组织机构表

1. act_id_group ：用户组信息表

2. act_id_info：用户扩展信息表

3. act_id_membership：用户与用户组对应信息表

4. act_id_user：用户信息表

这四张表很常见，基本的组织机构管理，关于用户认证方面建议还是自己开发一套，组件自带的功能太简单，使用中有很多需求难以满足。

通用数据表

1. act_ge_bytearray：二进制数据表

2. act_ge_property：属性数据表存储整个流程引擎级别的数据，初始化表结构时会默认插入三条记录

2）加载bpmn文件

// 获得一个部署构建器对象，用于加载流程定义文件（test1.bpmn,test.png）完成流程定义的部署

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

DeploymentBuilder builder= processEngine.getRepositoryService().createDeployment();

// 加载流程定义文件

builder.addClasspathResource(“MyProcess.bpmn”);

builder.addClasspathResource(“MyProcess.png”);

// 部署流程定义

Deployment deployment = builder.deploy();

System.out.println(deployment.getId());

到此，Activiti之HelloWorld便已完成了。大家可以试着查阅资料编写其他案例。

activiti中的几个对象

• 几个和流程相关的对象

1. Deployment：部署对象，和部署表(act_re_deployment)对应

2. ProcessDefinition：流程定义对象，和流程定义表(act_re_procdef)对应

3. ProcessInstance：流程实例对象，和流程实例表(act_ru_execution)对应

4. Task：任务对象，和任务表(act_ru_task)对应

• 几个Service对象

1. RepositoryService：操作部署、流程定义等静态资源信息

2. RuntimeService：操作流程实例，启动流程实例、查询流程实例、删除流程实例等动态信息

3. TaskService：操作任务，查询任务、办理任务等和任务相关的信息

4. HistoryService：操作历史信息的，查询历史信息

5. IdentityService：操作用户和组

• 几个Query对象

1. DeploymentQuery：对应查询部署表(act_re_deployment)

2. ProcessDefinitionQuery：对应查询流程定义表(act_re_procdef)

3. ProcessInstanceQuery：对应查询流程实例表(act_ru_execution)

4. TaskQuery：对应查询任务表(act_ru_task)