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

yumo6662个月前 (03-20)技术文章16

一、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);

小结

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

相关文章

10分钟教你写一个数据库

今天教大家借助一款框架快速实现一个数据库,这个框架就是Calcite,下面会带大家通过两个例子快速教会大家怎么实现,一个是可以通过 SQL 语句的方式可以直接查询文件内容,第二个是模拟 Mysql 查...

Mybatis操作数据库执行流程的先后顺序是怎样的?

MyBatis是一个支持普通SQL查询、存储及高级映射的持久层框架,它几乎消除了JDBC的冗余代码。使Java开发人员可以使用面向对象的编程思想来操作数据库。对于MyBatis的工作原理和操作流程的理...

鸿博档案:档案数字化基本流程是什么

一、术语和定义1、数字化:用计算机技术将模拟信号转换为数字信号的处理过程。2、纸质档案数字化:采用扫描仪或数码相机等数码设备对纸质档案进行数字加工,将其转化为存储在磁带、磁盘、光盘等载体上并能被计算机...

软件测试流程之数据库基础点

扼要:1、了解当前流行的数据库有哪些;2、掌握基本的数据库命令;数据库,对测试人员来说,是必须要懂得的技能,不需要太精通,但要了解其大的概念、分类,掌握基本操作命令即可。甚至在一些公司中,测试人员还要...

详细教程:SQL2008数据库备份与还原全流程!

数据的安全性至关重要,无论是操作系统、重要文件、磁盘存储,还是企业数据库,备份都是保障其安全和完整性的关键手段。拥有备份意味着即使发生误删、系统崩溃或病毒攻击等问题,也能迅速通过恢复功能解决,避免数据...