Springboot整合Flowable流程引擎

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群版 2核4GB 100GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用版 2核4GB 50GB
简介: Springboot整合Flowable流程引擎

文章目录

前言

Flowable是一个开源的工作流引擎,它基于Activiti引擎进行发展,Flowable主要用于为业务流程管理(BPM)和工作流的设计、操作、监控提供支持。

1. Flowable的主要表结构

1.1 通用数据表(通用表)

这类表在Flowable中主要提供存储通用类型数据的功能,如流程名称,创建时间等。如下是通用表的主要成员:

  • act_ge_bytearray:存储二进制数据,如流程定义文件,流程图等。
  • act_ge_property:存储系统全局属性,如数据库版本信息等。

1.2运行时数据表(runtime表)

这类表主要用于在流程运行过程中,存储实时的流程数据。如下是运行时数据表的主要成员:

act_ru_event_subscr:存储运行时事件订阅数据,如boundary事件等。

act_ru_execution:存储运行时流程实例,包括当前状态,子流程引用等。

act_ru_identitylink:存储运行时任务的参与者(用户与组)的关联关系。

act_ru_job:存储工作任务的相关数据,如执行时间,重试次数等。

act_ru_task:存储运行时任务数据,如所属流程实例,任务名称等。

act_ru_variable:存储运行时的流程变量数据。

1.3.历史数据表(history表)

这类表主要用于在流程完成后,存储历史的流程数据,如流程实例,任务,变量等。如下是历史数据表的主要成员:

act_hi_attachment:存储附件相关历史数据。

act_hi_comment:存储评论相关历史数据。

act_hi_detail:存储流程变量修改相关历史数据。

act_hi_identitylink:存储任务参与者相关历史数据。

act_hi_procinst:存储流程实例相关历史数据。

act_hi_actinst:存储活动节点相关历史数据。

act_hi_taskinst:存储任务实例相关历史数据。

act_hi_varinst:存储流程变量相关历史数据。

1.4. 身份数据表(identity表)

这类表主要用于存储组织机构和用户权限相关的数据。如下是身份数据表的主要成员:

  • act_id_group:存储用户组相关数据。
  • act_id_membership:存储用户与用户组的关联关系。
  • act_id_user:存储用户相关数据。

1.5. 流程定义数据表(repository表)

这类表主要用于存储流程定义相关的数据。如下是流程定义数据表的主要成员:

act_re_deployment:存储流程部署相关数据。

act_re_model:存储流程设计模型相关数据。

act_re_procdef:存储流程定义相关数据。

2.springboot整合flowable

2.1 流程定义

. 流程定义(Process Definition):流程定义是包含所有流程与审批步骤(任务节点、网关等)的XML文件,通常使用BPMN(Business Process Model and Notation) 2.0语言编写。这些文件在部署到Flowable引擎时会存储到数据库中,以便在运行时创建实例。

数据库表:Flowable使用关系型数据库来存储审批流相关的信息。其中的相关表格如下:

ACT_RE_PROCDEF: 存储流程定义信息

ACT_RE_DEPLOYMENT: 存储部署信息

ACT_RU_TASK: 存储运行时任务信息

ACT_RU_EXECUTION: 存储运行时流程实例

ACT_HI_PROCINST: 存储历史流程实例

ACT_HI_ACTINST: 存储历史活动实例

ACT_HI_TASKINST: 存储历史任务实例

ACT_HI_DETAIL: 存储历史明细数据

ACT_HI_COMMENT: 存储审批评论数据

2.2 引入依赖

 

 <properties>

   <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

   <maven.compiler.source>1.8</maven.compiler.source>

   <maven.compiler.target>1.8</maven.compiler.target>

   <flowable.version>6.7.2</flowable.version>

 </properties>

 <dependency>

    <groupId>org.flowable</groupId>

    <artifactId>flowable-spring-boot-starter</artifactId>

    <version>${flowable.version}</version>

  </dependency>

<dependency>

     <groupId>org.springframework.boot</groupId>

     <artifactId>spring-boot-starter-web</artifactId>

   </dependency>

    <!--flowable引擎自动配置-->

   <dependency>

     <groupId>org.flowable</groupId>

     <artifactId>flowable-spring-boot-starter</artifactId>

     <version>${flowable.version}</version>

   </dependency>

   <dependency>

     <groupId>mysql</groupId>

     <artifactId>mysql-connector-java</artifactId>

     <version>8.0.22</version>

   </dependency>

2.3 启动类

/**

* 启动类

*

*/

@SpringBootApplication

public class FlowableApplication

{

   public static void main( String[] args )

   {

       System.out.println("流程系统启动.................");

       SpringApplication.run(FlowableApplication.class,args);

       System.out.println("流程系统启动成功.................");

   }

}

2.4 启动服务

启动服务会在数据库自动创建flowable的表,可能会出现下边的错误。

2.4.1 启动错误,数据库驱动版本问题

nested exception is org.flowable.common.engine.api.FlowableException: Could not update Flowable database schema: unknown version from database: ‘6.8.0.0’

解决方法:

修改mysql驱动的版本为8.0.22

2.4.2 启动报错

Caused by: java.sql.SQLSyntaxErrorException: Specified key was too long; max key length is 767 bytes atcom.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[mysql-connector-java-8.0.22.jar:8.0.22] at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[mysql-connector-java-8.0.22.jar:8.0.22]

项目mysql的版本5.6.51

导致上面报错的原因是由于InnoDB表的索引长度限制,在MySQL5.6版本后引入了参数innodb_large_prefix可以解决这个问题。该参数控制是否允许单列的索引长度超过767字节,有ON和OFF两个取值:

ON :Innodb表的行记录格式是Dynamic或Compressed的前提下,单列索引长度上限扩展到3072个字节

OFF:Innodb表的单例索引长度最多为767个字节,索引长度超出后,主键索引会创建失败,辅助索引会被截断成为前缀索引。

进行如下设置,重启mysql:

set global innodb_large_prefix = ON;

SET GLOBAL innodb_file_format=Barracuda;

SET GLOBAL innodb_file_per_table=ON;

2.4 下载BPMN插件

f50b1fbae11f4258a639de673dc84dfb.png

ed15cf475a1e475dbae161b475a9a8d5.png

4ffd98627b8a49dd9d49ca73b8a3d21b.png

文件的后缀名字 demo.bpmn20.xml

demo.bpmn20.xml

<?xml version="1.0" encoding="UTF-8"?>

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:flowable="http://flowable.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.flowable.org/processdef">

 <process id="DemoProcess" name="DemoProcess">

   <startEvent id="start"/>

   <sequenceFlow id="flow1" sourceRef="start" targetRef="userTask"/>

   <userTask id="userTask" name="User Task" flowable:assignee="${creator}"/>

   <sequenceFlow id="flow2" sourceRef="userTask" targetRef="end"/>

   <endEvent id="end"/>

 </process>

</definitions>

2.5 部署流程

/**

* 流程部署

*/

@Component

public class ProcessDeployer {

   @Autowired

   private RepositoryService repositoryService;

   @PostConstruct

   public void init() {

       repositoryService.createDeployment()

               .addClasspathResource("demo.bpmn20.xml")

               .deploy();

   }

}

启动完成之后数据库表存储流程定义:=>ACT_RE_PROCDEF

c699b655ecb84d498471d8362b676fae.png

存储部署表

1d6491f9fa484514bce409c16b6901bb.png

2.6 启动流程

   //查询指定流程所有启动的实例列表

   @Autowired

   private RuntimeService runtimeService;

 /**

    * 启动

    * @param creator

    */

   public void startProcess(String creator) {

       Map<String, Object> variables = new HashMap<>();

       variables.put("creator", creator);

       runtimeService.startProcessInstanceByKey("demoProcess", variables);

   }

2.7 完成流程

根据用户获取用户任务以及审批流

   @Autowired

   TaskService taskService;

   //获取用户ID获取的任务列表

   public List<Task> getTasksAssignedToUser(String userId) {

       TaskQuery taskQuery = taskService.createTaskQuery().taskAssignee(userId);

       return taskQuery.list();

   }

   //用户处理流程列表

   public void completeTask(String taskId, boolean approved) {

       Task task = taskService.createTaskQuery().taskId(taskId).singleResult();

       if (task != null) {

           Map<String, Object> variables = new HashMap<>();

           variables.put("approved", approved);

           taskService.complete(taskId, variables);

       }

   }

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
9月前
|
数据可视化 前端开发 Java
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)(一)
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)
503 0
|
17天前
|
数据可视化 Java 数据库
手把手实现springboot整合flowable,非常简单【附源码.视频】
手把手实现springboot整合flowable,非常简单【附源码.视频】
42 2
|
2月前
|
XML Java 数据库
springboot集成flowable
springboot集成flowable
|
2月前
|
开发框架 Java API
Spring Boot与Flowable的完美整合
【4月更文挑战第20天】
373 2
|
2月前
|
监控 Java API
|
9月前
|
数据可视化 安全 前端开发
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)(三)
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)
240 0
|
9月前
|
XML 数据可视化 Java
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)(二)
SpringBoot 集成 Flowable + Flowable Modeler 流程配置可视化(图解)
287 0
|
存储 消息中间件 JavaScript
Spring Boot + flowable 快速实现工作流
Spring Boot + flowable 快速实现工作流
Spring Boot + flowable 快速实现工作流
|
SQL Java 关系型数据库
手把手教大家在 Spring Boot 中处理 flowable 中的用户和组
手把手教大家在 Spring Boot 中处理 flowable 中的用户和组
|
XML 前端开发 JavaScript
SpringBoot+Vue+Flowable,模拟一个请假审批流程
SpringBoot+Vue+Flowable,模拟一个请假审批流程