flowable入门-创建第一个flowable流程
一、flowable定义
flowable 是一个使用Java编写的轻量级业务流程引擎。基于BPMN2.0协议,实现对流程的创建、查询、流转、报结等操作的管理。
二、创建一个flowable流程
创建一个flowable流程按照先后顺序一般分为4个步骤,分别是
1.创建流程引擎实例(ProcessEngine)
2.部署创建一个流程定义(ProcessDefinition)
3.启动一个流程实例(ProcessInstance)
4.创建一个流程任务(Task)
开始创建任务之前,先引入代码依赖,这里使用的是6.3.0版本的flowable.
org.flowable
flowable-engine
6.3.0
com.h2database
h2
1.3.176
1.创建流程引擎实例
创建一个flowable流程之前,首先要做的是创建一个流程引擎实例(ProcessEngine)。这是一个线程安全的对象,一个应用只需要初始化一次。该实例可以配置和与调整流程引擎的配置。如数据库配置、邮件配置等。下图的代码中创建的是一个独立的配置对象(
StandaloneProcessEngineConfiguration),这里的独立是指的流程引擎实例不依赖Spring环境。(如果使用spring环境中使用flowable,可以添加flowable-engine依赖吧,里面的
SpringProcessEngineConfiguration类的实现)。
package org.flowable;
import org.flowable.engine.ProcessEngine;
import org.flowable.engine.ProcessEngineConfiguration;
import org.flowable.engine.impl.cfg.StandaloneProcessEngineConfiguration;
public class HolidayRequest {
public static void main(String[] args) {
ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
.setJdbcUrl("jdbc:h2:mem:flowable;DB_CLOSE_DELAY=-1")
.setJdbcUsername("sa")
.setJdbcPassword("")
.setJdbcDriver("org.h2.Driver")
.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE)
ProcessEngine processEngine = cfg.buildProcessEngine();
}
}
2.部署创建一个流程定义
Flowable流程引擎支持BPMN2.0定义的流程定义,这个也是业界广泛接受的XML标准协议。一个流程引擎可以创建多个流程定义。使用idea的小伙伴们可以搜索“actiBPM”插件,来绘制bpmn业务流程图。这里不针对BPMN流程图进行展开描述。
下图是个平常工作中很场景的一个场景,当员工有事情的时候,在系统中提交请假流程,会经过部门经理审批,如果同意流程结束,如果驳回,员工修改意见可以在此提交(该场景不做正式业务场景的例子)。其实“员工”“部门经理”是用户任务(userTask),“同意”“驳回”是有互斥网关来承载的。
当业务流程画好后,会生成以bpmn20.xml为后缀的文件,如果“员工请假流程.bpmn20.xml”。下面我们就可以通过代码来部署这个流程。使用流程引擎实例(ProcessEngine)获取RepositoryService,通过RepositoryService的API获取部署对象Deployment,并调用deploy方法发布流程。(如果使用flowable modeler设计器提交bpmn部署的,只是将流程部署在数据库中,后面海需要自行调用deploy方法将流程发布,才可以创建流程实例)。
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("员工请假流程.bpmn20.xml") -- 将流程保存到数据库中
.deploy(); -- 发布流程
流程定义创建可以通过RepositoryService对象查询。
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
.deploymentId(deployment.getId())
.singleResult();
System.out.println("Found process definition : " + processDefinition.getName());
3.启动一个流程实例
创建一个流程定义,相当于已经有个流程执行的“蓝图”。当时要想让流程真正的走下去,还需要为流程启动一个流程实例,一个流程定义可以启动多个流程实例。
启动一个流程实例,需要调用RuntimeService类的startProcessInstanceByXXX的方法,xxx可以是流程定义的KEY,ID,当有多个租户的时候可以是KeyAndTenantId。
流程启动的时候,需要为流程的变量设置对应的值,如“员工”的节点设置了处理人(assignee)变量设置为${employee},那么在创建流程的时候,需要将参数以Map
RuntimeService runtimeService = processEngine.getRuntimeService();
Map variables = new HashMap();
variables.put("employee", "Tom");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("EMP_PROC",variables)
在流程实例启动后,会创建一个实例执行(execution),并将其放在启动事件上。从这里开始,这个execution沿着顺序流执行,当执行到每一个用户任务(userTask)节点的时候,流程会处于等待状态(wait),直到用户做出相应的行为,使得流程流向下一个处理节点。
4.创建一个流程任务
任务(Task)是流程在执行顺序流的时候最小的执行单位,每一个用户任务都有对应的处理人。我们可以通过使用TaskService来创建我们的任务,然后通过调用taskCandidateGroup,可以查询“managers”组下所有的待办任务。
TaskService taskService = processEngine.getTaskService();
List tasks = taskService.createTaskQuery().taskCandidateGroup("managers").list();
当用户查询到自己的待办的任务后,可以选择处理任务,这个时候可以调用taskService类的complete方法来流传任务到下一个节点。其中variables为下一个节点需要的参数Map
taskService.complete(task.getId(), variables);
小结
这篇讲了从流程的部署、流程定义到启动一个流程实例、流程任务。