flowable入门-创建第一个flowable流程

一、flowable定义

flowable 是一个使用Java编写的轻量级业务流程引擎。基于BPMN2.0协议，实现对流程的创建、查询、流转、报结等操作的管理。

二、创建一个flowable流程

创建一个flowable流程按照先后顺序一般分为4个步骤，分别是

1.创建流程引擎实例（ProcessEngine）

2.部署创建一个流程定义（ProcessDefinition）

3.启动一个流程实例（ProcessInstance）

4.创建一个流程任务（Task）

开始创建任务之前，先引入代码依赖，这里使用的是6.3.0版本的flowable.

<dependencies>
  <dependency>
    <groupId>org.flowable</groupId>
    <artifactId>flowable-engine</artifactId>
    <version>6.3.0</version>
  </dependency>
  <dependency>
    <groupId>com.h2database</groupId>
    <artifactId>h2</artifactId>
    <version>1.3.176</version>
  </dependency>
</dependencies>

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<String, Object>的形式将参数传递过去。

RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> variables = new HashMap<String, Object>();
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<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("managers").list();

当用户查询到自己的待办的任务后，可以选择处理任务，这个时候可以调用taskService类的complete方法来流传任务到下一个节点。其中variables为下一个节点需要的参数Map<String, Object>。

taskService.complete(task.getId(), variables);

小结

这篇讲了从流程的部署、流程定义到启动一个流程实例、流程任务。