Flowable入门

创建流程定义

1. 添加maven依赖包

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

• Flowable流程引擎，它允许我们创建ProcessEngine对象并访问Flowable API
• 数据库作为Flowable引擎需要一个数据库来存储执行和历史数据，同时运行流程实例

2. Flowable在内部使用SLF4J作为其日志框架

部署流程定义

1. Flowable引擎期望以BPMN2.0格式定义流程

   • 从流程定义中，可以启动许多流程实例
     image
     （1）每个步骤（活动）都有一个id属性，在XML文件中为其提供唯一标识符
     （2）活动之间由一个序列流连接
     （3）离开网关（带X的菱形）的序列流两者都具有以表达式形式定义的条件
     • 批准的变量称为过程变量

2. 将流程定义部署到引擎

• 流程引擎将XML文件存储在数据库中，因此可以需要时检索它
• 流程定义被解析为内部可执行对象模型，以便可以中启动流程实例

RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
  .addClasspathResource("holiday-request.bpmn20.xml")
  .deploy();

• API查询引擎

ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
  .deploymentId(deployment.getId())
  .singleResult();
System.out.println("Found process definition : " + processDefinition.getName());

启动流程实例

<process id="holidayRequest" name="Holiday Request" isExecutable="true">

RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("employee", employee);
variables.put("nrOfHolidays", nrOfHolidays);
variables.put("description", description);
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("holidayRequest", variables);

• 启动流程实例，将创建执行并将其放入start事件中
• 执行用户任务行为，此行为将在数据库中创建一个任务，以便查询

后续流程分析

1. 数据库事务在保证数据一致性和解决并发问题方面起着至关重要的作用

• 默认情况下，所有的内容都是同步的，并且是同一个事务的一部分

2. 查看任务列表

• 检查存储为流程变量的流程实例数据 ---> 决定对任务执行的操作
• 为用户任务配置分配：
  id="approveTask" 的userTask标签增加lowable:candidateGroups="managers"
  id="holidayApprovedTask"增加flowable:assignee="${employee}"
• 获取实际的任务列表，通过TaskService创建TaskQuery

  TaskService taskService = processEngine.getTaskService();
  List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("managers").list();
  System.out.println("You have " + tasks.size() + " tasks:");
  for (int i=0; i<tasks.size(); i++) {
      System.out.println((i+1) + ") " + tasks.get(i).getName());
  }
  

• 使用任务标识符，可以获取特定的流程实例变量

int taskIndex = Integer.valueOf(scanner.nextLine());
Task task = tasks.get(taskIndex - 1);
//对比查看启动流程实例的参数
Map<String, Object> processVariables = taskService.getVariables(task.getId());
System.out.println(processVariables.get("employee") + " wants " +
    processVariables.get("nrOfHolidays") + " of holidays. Do you approve this?");

• 用户提交表单，然后将表单中的数据作为流程变量传递

boolean approved = scanner.nextLine().toLowerCase().equals("y");
variables = new HashMap<String, Object>();
variables.put("approved", approved);
taskService.complete(task.getId(), variables);

该任务现在已完成，并且基于批准的过程变量选择离开专用网关的两个路径之一

3. 编写JavaDelegate

• 问题：没有实现在批准请求时执行的自动逻辑。在BPMN 2.0 XML中是一项服务任务

<serviceTask id="externalSystemCall" name="Enter holidays in external system"
    flowable:class="org.flowable.CallExternalSystemDelegate"/>

创建类org.flowable.CallExternalSystemDelegate实现JavaDelegate接口并实现execute方法

4. 使用历史数据

• Flowable会自动存储所有流程实例的审计数据或历史数据

HistoryService historyService = processEngine.getHistoryService();
List<HistoricActivityInstance> activities =
  historyService.createHistoricActivityInstanceQuery()
   .processInstanceId(processInstance.getId())
   .finished()
   .orderByHistoricActivityInstanceEndTime().asc()
   .list();
for (HistoricActivityInstance activity : activities) {
  System.out.println(activity.getActivityId() + " took "
    + activity.getDurationInMillis() + " milliseconds");
}

演示代码的地址：https://github.com/yehuali/holidayRequest

主要参考Flowable的官方文档：https://www.flowable.org