最新Flowable工作流教程

lecture:邓澎波

一、Flowable介绍

  Flowable是BPMN的一个基于java的软件实现,不过Flowable不仅仅包括BPMN,还有DMN决策表和CMMN Case管理引擎,并且有自己的用户管理、微服务API等一系列功能,是一个服务平台。

二、Flowable基础

官方手册:https://tkjohn.github.io/flowable-userguide/#_introduction

1.创建ProcessEngine

  创建一个基本的maven工程,可以是Eclipse也可以是其他IDEA。然后添加两个依赖

  • Flowable流程引擎。使我们可以创建一个ProcessEngine流程引擎对象,并访问Flowable API。
  • 一个是MySQL的数据库驱动

pom.xml文件中添加下列行:

  1. <dependency>
  2. <groupId>org.flowable</groupId>
  3. <artifactId>flowable-engine</artifactId>
  4. <version>6.3.0</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>mysql</groupId>
  8. <artifactId>mysql-connector-java</artifactId>
  9. <version>8.0.21</version>
  10. </dependency>

  然后创建一个普通的Java类,添加对应的main方法,首先要做的是初始化ProcessEngine流程引擎实例。这是一个线程安全的对象,因此通常只需要在一个应用中初始化一次。 ProcessEngineProcessEngineConfiguration实例创建。该实例可以配置与调整流程引擎的设置。 通常使用一个配置XML文件创建ProcessEngineConfiguration,但是(像在这里做的一样)也可以编程方式创建它。 ProcessEngineConfiguration所需的最小配置,是数据库JDBC连接:

  1. public static void main(String[] args) {
  2. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  3. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC")
  4. .setJdbcUsername("root")
  5. .setJdbcPassword("123456")
  6. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  7. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  8. ProcessEngine processEngine = cfg.buildProcessEngine();
  9. }

  注意在mysql8.0中执行可能出现如下的错误

Flowable学习一(基础) - 图1

  出现这种情况只需要在mysql的连接字符串中添加上nullCatalogMeansCurrent=true,设置为只查当前连接的schema库即可。

  1. public static void main(String[] args) {
  2. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  3. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn1?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  4. .setJdbcUsername("root")
  5. .setJdbcPassword("123456")
  6. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  7. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  8. ProcessEngine processEngine = cfg.buildProcessEngine();
  9. }

  然后应用运行没有问题,但也没有在控制台提供有用的信息,只有一条消息提示日志没有正确配置。Flowable使用SLF4J作为内部日志框架。在这个例子中,我们使用log4j作为SLF4J的实现。因此在pom.xml文件中添加下列依赖:

  1. <dependency>
  2. <groupId>org.slf4j</groupId>
  3. <artifactId>slf4j-api</artifactId>
  4. <version>1.7.21</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.slf4j</groupId>
  8. <artifactId>slf4j-log4j12</artifactId>
  9. <version>1.7.21</version>
  10. </dependency>

  Log4j需要一个配置文件。在src/main/resources文件夹下添加log4j.properties文件,并写入下列内容:

  1. log4j.rootLogger=DEBUG, CA
  2. log4j.appender.CA=org.apache.log4j.ConsoleAppender
  3. log4j.appender.CA.layout=org.apache.log4j.PatternLayout
  4. log4j.appender.CA.layout.ConversionPattern= %d{hh:mm:ss,SSS} [%t] %-5p %c %x - %m%n

  重新运行应用。应该可以看到关于引擎启动与创建数据库表结构的提示日志:

Flowable学习一(基础) - 图2

  同时可以看到创建了相关的表结构在数据库中

Flowable学习一(基础) - 图3

  这样就得到了一个启动可用的流程引擎。接下来为它提供一个流程!

2.部署流程定义

  接下来我们构建一个非常简单的请假流程,Flowable引擎需要流程定义为BPMN 2.0格式,这是一个业界广泛接受的XML标准。 在Flowable术语中,我们将其称为一个流程定义(process definition)。一个流程定义可以启动多个流程实例(process instance)流程定义可以看做是重复执行流程的蓝图。 在这个例子中,流程定义定义了请假的各个步骤,而一个流程实例对应某个雇员提出的一个请假申请。

  BPMN 2.0存储为XML,并包含可视化的部分:使用标准方式定义了每个步骤类型(人工任务,自动服务调用,等等)如何呈现,以及如何互相连接。这样BPMN 2.0标准使技术人员与业务人员能用双方都能理解的方式交流业务流程。

  我们要使用的流程定义为:

Flowable学习一(基础) - 图4

  流程定义说明:

  • 我们假定启动流程需要提供一些信息,例如雇员名字、请假时长以及说明。当然,这些可以单独建模为流程中的第一步。 但是如果将它们作为流程的“输入信息”,就能保证只有在实际请求时才会建立一个流程实例。否则(将提交作为流程的第一步),用户可能在提交之前改变主意并取消,但流程实例已经创建了。 在某些场景中,就可能影响重要的指标(例如启动了多少申请,但还未完成),取决于业务目标。
  • 左侧的圆圈叫做启动事件(start event)。这是一个流程实例的起点。
  • 第一个矩形是一个用户任务(user task)。这是流程中用户操作的步骤。在这个例子中,经理需要批准或驳回申请
  • 取决于经理的决定,排他网关(exclusive gateway) (带叉的菱形)会将流程实例路由至批准或驳回路径
  • 如果批准,则需要将申请注册至某个外部系统,并跟着另一个用户任务,将经理的决定通知给申请人。当然也可以改为发送邮件。
  • 如果驳回,则为雇员发送一封邮件通知他。

  一般来说,这样的流程定义使用可视化建模工具建立,如Flowable Designer(Eclipse)或Flowable Web Modeler(Web应用)。但在这里我们直接撰写XML,以熟悉BPMN 2.0及其概念。

  与上面展示的流程图对应的BPMN 2.0 XML在下面显示。请注意这只包含了“流程部分”。如果使用图形化建模工具,实际的XML文件还将包含“可视化部分”,用于描述图形信息,如流程定义中各个元素的坐标(所有的图形化信息包含在XML的BPMNDiagram标签中,作为definitions标签的子元素)。

  将下面的XML保存在src/main/resources文件夹下名为holiday-request.bpmn20.xml的文件中。

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xmlns:xsd="http://www.w3.org/2001/XMLSchema"
  5. xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
  6. xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
  7. xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
  8. xmlns:flowable="http://flowable.org/bpmn"
  9. typeLanguage="http://www.w3.org/2001/XMLSchema"
  10. expressionLanguage="http://www.w3.org/1999/XPath"
  11. targetNamespace="http://www.flowable.org/processdef">
  12. <process id="holidayRequest" name="Holiday Request" isExecutable="true">
  13. <startEvent id="startEvent"/>
  14. <sequenceFlow sourceRef="startEvent" targetRef="approveTask"/>
  15. <userTask id="approveTask" name="Approve or reject request"/>
  16. <sequenceFlow sourceRef="approveTask" targetRef="decision"/>
  17. <exclusiveGateway id="decision"/>
  18. <sequenceFlow sourceRef="decision" targetRef="externalSystemCall">
  19. <conditionExpression xsi:type="tFormalExpression">
  20. <![CDATA[
  21. ${approved}
  22. ]]>
  23. </conditionExpression>
  24. </sequenceFlow>
  25. <sequenceFlow sourceRef="decision" targetRef="sendRejectionMail">
  26. <conditionExpression xsi:type="tFormalExpression">
  27. <![CDATA[
  28. ${!approved}
  29. ]]>
  30. </conditionExpression>
  31. </sequenceFlow>
  32. <serviceTask id="externalSystemCall" name="Enter holidays in external system"
  33. flowable:class="org.flowable.CallExternalSystemDelegate"/>
  34. <sequenceFlow sourceRef="externalSystemCall" targetRef="holidayApprovedTask"/>
  35. <userTask id="holidayApprovedTask" name="Holiday approved"/>
  36. <sequenceFlow sourceRef="holidayApprovedTask" targetRef="approveEnd"/>
  37. <serviceTask id="sendRejectionMail" name="Send out rejection email"
  38. flowable:class="org.flowable.SendRejectionMail"/>
  39. <sequenceFlow sourceRef="sendRejectionMail" targetRef="rejectEnd"/>
  40. <endEvent id="approveEnd"/>
  41. <endEvent id="rejectEnd"/>
  42. </process>
  43. </definitions>

  现在我们已经有了流程BPMN 2.0 XML文件,下来需要将它部署(deploy)*到引擎中。部署*一个流程定义意味着:

  • 流程引擎会将XML文件存储在数据库中,这样可以在需要的时候获取它
  • 流程定义转换为内部的、可执行的对象模型,这样使用它就可以启动流程实例

Flowable学习一(基础) - 图5

  将流程定义部署至Flowable引擎,需要使用RepositoryService,其可以从ProcessEngine对象获取。使用RepositoryService,可以通过XML文件的路径创建一个新的部署(Deployment),并调用deploy()方法实际执行:

  1. /**
  2. * 部署流程
  3. */
  4. @Test
  5. public void testDeploy(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. // 部署流程 获取RepositoryService对象
  16. RepositoryService repositoryService = processEngine.getRepositoryService();
  17. Deployment deployment = repositoryService.createDeployment()// 创建Deployment对象
  18. .addClasspathResource("holiday-request.bpmn20.xml") // 添加流程部署文件
  19. .name("请求流程") // 设置部署流程的名称
  20. .deploy(); // 执行部署操作
  21. System.out.println("deployment.getId() = " + deployment.getId());
  22. System.out.println("deployment.getName() = " + deployment.getName());
  23. }

  然后执行该方法日志操作成功:

Flowable学习一(基础) - 图6

  在后台表结构也可以看到相关的信息

act_re_deployment: 流程定义部署表,每部署一次就增加一条记录

Flowable学习一(基础) - 图7

act_re_procdef :流程定义表,部署每个新的流程定义都会在这张表中增加一条记录

Flowable学习一(基础) - 图8

act_ge_bytearray :流程资源表,流程部署的 bpmn文件和png图片会保存在该表中

Flowable学习一(基础) - 图9

  我们现在可以通过API查询验证流程定义已经部署在引擎中(并学习一些API)。通过RepositoryService创建的ProcessDefinitionQuery对象实现。

  1. /**
  2. * 查看流程定义
  3. */
  4. @Test
  5. public void testDeployQuery(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. // 部署流程 获取RepositoryService对象
  16. RepositoryService repositoryService = processEngine.getRepositoryService();
  17. // 获取流程定义对象
  18. ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
  19. .deploymentId("2501")
  20. .singleResult();
  21. System.out.println("processDefinition.getId() = " + processDefinition.getId());
  22. System.out.println("processDefinition.getName() = " + processDefinition.getName());
  23. System.out.println("processDefinition.getDeploymentId() = " + processDefinition.getDeploymentId());
  24. System.out.println("processDefinition.getDescription() = " + processDefinition.getDescription());
  25. }

输出结果为:

  1. processDefinition.getId() = holidayRequest:2:2503
  2. processDefinition.getName() = Holiday Request
  3. processDefinition.getDeploymentId() = 2501
  4. processDefinition.getDescription() = null

3.启动流程实例

  现在已经在流程引擎中部署了流程定义,因此可以使用这个流程定义作为“模板”启动流程实例

Flowable学习一(基础) - 图10

  要启动流程实例,需要提供一些初始化流程变量。一般来说,可以通过呈现给用户的表单,或者在流程由其他系统自动触发时通过REST API,来获取这些变量。在这个例子里,我们简化直接在代码中定义了,我们使用RuntimeService启动一个流程实例

  1. /**
  2. * 启动流程实例
  3. */
  4. @Test
  5. public void testRunProcess(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. // 启动流程实例通过 RuntimeService 对象
  16. RuntimeService runtimeService = processEngine.getRuntimeService();
  17. // 构建流程变量
  18. Map<String,Object> variables = new HashMap<>();
  19. variables.put("employee","张三") ;// 谁申请请假
  20. variables.put("nrOfHolidays",3); // 请几天假
  21. variables.put("description","工作累了,想出去玩玩"); // 请假的原因
  22. // 启动流程实例,第一个参数是流程定义的id
  23. ProcessInstance processInstance = runtimeService
  24. .startProcessInstanceByKey("holidayRequest", variables);// 启动流程实例
  25. // 输出相关的流程实例信息
  26. System.out.println("流程定义的ID:" + processInstance.getProcessDefinitionId());
  27. System.out.println("流程实例的ID:" + processInstance.getId());
  28. System.out.println("当前活动的ID:" + processInstance.getActivityId());
  29. }

启动成功,输出结果如下:

  1. 流程定义的IDholidayRequest:2:2503
  2. 流程实例的ID5001
  3. 当前活动的IDnull

对应的流程实例ID为:5001

启动流程实例涉及到的表结构:

  • act_hi_actinst 流程实例执行历史
  • act_hi_identitylink 流程的参与用户的历史信息
  • act_hi_procinst 流程实例历史信息
  • act_hi_taskinst 流程任务历史信息
  • act_ru_execution 流程执行信息
  • act_ru_identitylink 流程的参与用户信息
  • act_ru_task 任务信息

4.查看任务

  上面员工发起了一个请假流程,接下来就会流转到总经理这儿来处理,之前我们没有指定经理这的处理人,我们可以加一个

Flowable学习一(基础) - 图11

  然后我们来查看下lisi的任务

  1. /**
  2. * 查看任务
  3. */
  4. @Test
  5. public void testQueryTask(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. TaskService taskService = processEngine.getTaskService();
  16. List<Task> list = taskService.createTaskQuery()
  17. .processDefinitionKey("holidayRequestNew")
  18. .taskAssignee("lisi")
  19. .list();
  20. for (Task task : list) {
  21. System.out.println("task.getProcessDefinitionId() = " + task.getProcessDefinitionId());
  22. System.out.println("task.getId() = " + task.getId());
  23. System.out.println("task.getAssignee() = " + task.getAssignee());
  24. System.out.println("task.getName() = " + task.getName());
  25. }
  26. }

输出结果为:

  1. task.getProcessDefinitionId() = holidayRequestNew:1:10003
  2. task.getId() = 12508
  3. task.getAssignee() = lisi
  4. task.getName() = Approve or reject request

5.完成任务

  现在李四这个角色可以来完成当前的任务了

Flowable学习一(基础) - 图12

  在此处我们直接解决掉这个请假,然后会走发送拒绝邮件的流程,这块我们需要用到JavaDelegate来触发。

Flowable学习一(基础) - 图13

我们定义这样一个Java类

  1. public class SendRejectionMail implements JavaDelegate {
  2. /**
  3. * 触发发送邮件的操作
  4. * @param delegateExecution
  5. */
  6. @Override
  7. public void execute(DelegateExecution delegateExecution) {
  8. System.out.println("请假被拒绝,,,安心工作吧");
  9. }
  10. }

然后来完成任务

  1. /**
  2. * 完成任务
  3. */
  4. @Test
  5. public void testCompleteTask(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. TaskService taskService = processEngine.getTaskService();
  16. Task task = taskService.createTaskQuery()
  17. .processDefinitionKey("holidayRequestNew")
  18. .taskAssignee("lisi")
  19. .singleResult();
  20. // 添加流程变量
  21. Map<String,Object> variables = new HashMap<>();
  22. variables.put("approved",false); // 拒绝请假
  23. // 完成任务
  24. taskService.complete(task.getId(),variables);
  25. }

然后可以看到JavaDelegate触发了

Flowable学习一(基础) - 图14

6.流程的删除

  有些流程已经没有用了,我们需要删除掉,其实也非常简单

  1. /**
  2. * 删除流程
  3. */
  4. @Test
  5. public void testDeleteProcess(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. RepositoryService repositoryService = processEngine.getRepositoryService();
  16. // 删除流程定义,如果该流程定义已经有了流程实例启动则删除时报错
  17. // repositoryService.deleteDeployment("1");
  18. // 设置为TRUE 级联删除流程定义,及时流程有实例启动,也可以删除,设置为false 非级联删除操作。
  19. repositoryService.deleteDeployment("2501",true);
  20. }

7.查看历史信息

  选择使用Flowable这样的流程引擎的原因之一,是它可以自动存储所有流程实例的审计数据历史数据。这些数据可以用于创建报告,深入展现组织运行的情况,瓶颈在哪里,等等。

  例如,如果希望显示流程实例已经执行的时间,就可以从ProcessEngine获取HistoryService,并创建历史活动(historical activities)的查询。在下面的代码片段中,可以看到我们添加了一些额外的过滤条件:

  • 只选择一个特定流程实例的活动
  • 只选择已完成的活动

  结果按照结束时间排序,代表其执行顺序。

  1. /**
  2. * 查看历史
  3. */
  4. @Test
  5. public void testQueryHistory(){
  6. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  7. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  8. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  9. .setJdbcUsername("root")
  10. .setJdbcPassword("123456")
  11. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  12. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  13. // 获取流程引擎对象
  14. ProcessEngine processEngine = cfg.buildProcessEngine();
  15. HistoryService historyService = processEngine.getHistoryService();
  16. List<HistoricActivityInstance> list = historyService.createHistoricActivityInstanceQuery()
  17. .processDefinitionId("holidayRequestNew:1:10003")
  18. .finished()
  19. .orderByHistoricActivityInstanceEndTime().asc()
  20. .list();
  21. for (HistoricActivityInstance historicActivityInstance : list) {
  22. System.out.println(historicActivityInstance.getActivityId() + " took "
  23. + historicActivityInstance.getDurationInMillis() + " milliseconds");
  24. }
  25. }

输出结果

  1. startEvent took 1 milliseconds
  2. approveTask took 837735 milliseconds
  3. decision took 13 milliseconds
  4. sendRejectionMail took 2 milliseconds
  5. rejectEnd took 1 milliseconds

好了~flowable的基本应用我们就先介绍到这里了。

三、Flowable流程设计器

1.Eclipse Designer

  Flowable提供了名为Flowable Eclipse Designer的Eclipse插件,可以用于图形化地建模、测试与部署BPMN 2.0流程。

1.1 下载安装Eclipse

  去Eclipse官网下载即可:https://www.eclipse.org/downloads/packages/release 注意2020-09后的版本不再支持jdk8

Flowable学习一(基础) - 图15

 解压缩就可以了,然后进入解压缩的目录

Flowable学习一(基础) - 图16

  直接启动即可

Flowable学习一(基础) - 图17

Flowable学习一(基础) - 图18

1.2 安装Flowable插件

  然后我们再安装下Flowable的插件,选择Help → Install New Software。在下图面板中,点击Add按钮,并填写下列字段

Flowable学习一(基础) - 图19

  这种在线更新的方式已经被官网移除了,操作不了

Flowable学习一(基础) - 图20

  这时我们就只能通过离线安装的方式来实现了,下载对应的离线文件

Flowable学习一(基础) - 图21

  安装步骤来操作,

Flowable学习一(基础) - 图22

然后继续:选择Help → Install New Software

Flowable学习一(基础) - 图23

Flowable学习一(基础) - 图24

下一步

Flowable学习一(基础) - 图25

再下一步

Flowable学习一(基础) - 图26

然后finish。弹出如下窗口

Flowable学习一(基础) - 图27

重启即可

1.3 创建项目

  然后我们就可以创建一个Flowable Project了

Flowable学习一(基础) - 图28

  然后我们可以在src/mian/resources/ 的目录下创建对应的流程图了

Flowable学习一(基础) - 图29

  看到如下的界面说明插件安装成功了

Flowable学习一(基础) - 图30

1.4 创建流程图

使用滑板来绘制流程,通过从右侧把图标拖拽到左侧的面板,最终的效果

Flowable学习一(基础) - 图31

指定流程的主键

Flowable学习一(基础) - 图32

指定任务的负责人

在Properties视图中指定每个任务节点的负责人

Flowable学习一(基础) - 图33

创建请假单:zhangsan

审批请假单:lisi

当我们设置完成后保存文件,会同时生成png图片

Flowable学习一(基础) - 图34

注意:生成图片需要如下配置

Flowable学习一(基础) - 图35

1.5 部署流程

  首先在Eclipse中生成bar文件,选中项目然后鼠标右击

Flowable学习一(基础) - 图36

然后会发现在项目的根目录下多了一个deployment文件夹,里面多了一个MyProcess.bar文件

Flowable学习一(基础) - 图37

然后我们就可以把这个bar文件拷贝到IDEA中,继续部署的流程

Flowable学习一(基础) - 图38

而部署的代码和前面没啥区别

  1. @Test
  2. public void testDeploy(){
  3. // 1.获取 ProcessEngine 对象
  4. ProcessEngine processEngine = configuration.buildProcessEngine();
  5. // 2.获取RepositoryService
  6. RepositoryService repositoryService = processEngine.getRepositoryService();
  7. InputStream in = this.getClass().getClassLoader().getResourceAsStream("MyHoliday.bar");
  8. ZipInputStream zipInputStream = new ZipInputStream(in);
  9. // 3.完成流程的部署操作 ZIP 或者 Bar文件
  10. Deployment deploy = repositoryService.createDeployment()
  11. // .addClasspathResource("MyHoliday.bar")// 关联要部署的流程文件
  12. .addZipInputStream(zipInputStream)
  13. .name("XXX公司请求流程")
  14. .deploy() ;// 部署流程
  15. System.out.println("deploy.getId() = " + deploy.getId());
  16. System.out.println("deploy.getName() = " + deploy.getName());
  17. }

执行后查看表结构,相关的信息就进去了

Flowable学习一(基础) - 图39

完整的案例代码:

  1. package com.bobo.flowable.test;
  2. import org.flowable.engine.*;
  3. import org.flowable.engine.history.HistoricActivityInstance;
  4. import org.flowable.engine.impl.cfg.StandaloneProcessEngineConfiguration;
  5. import org.flowable.engine.repository.Deployment;
  6. import org.flowable.engine.runtime.ProcessInstance;
  7. import org.flowable.task.api.Task;
  8. import org.junit.Before;
  9. import org.junit.Test;
  10. import java.io.InputStream;
  11. import java.util.HashMap;
  12. import java.util.List;
  13. import java.util.Map;
  14. import java.util.zip.ZipInputStream;
  15. public class Test02 {
  16. ProcessEngineConfiguration configuration = null;
  17. @Before
  18. public void before(){
  19. // 获取 ProcessEngineConfiguration 对象
  20. configuration = new StandaloneProcessEngineConfiguration();
  21. // 配置 相关的数据库的连接信息
  22. configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
  23. configuration.setJdbcUsername("root");
  24. configuration.setJdbcPassword("123456");
  25. configuration.setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true");
  26. // 如果数据库中的表结构不存在就新建
  27. configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  28. }
  29. /**
  30. * 部署流程
  31. *
  32. */
  33. @Test
  34. public void testDeploy(){
  35. // 1.获取 ProcessEngine 对象
  36. ProcessEngine processEngine = configuration.buildProcessEngine();
  37. // 2.获取RepositoryService
  38. RepositoryService repositoryService = processEngine.getRepositoryService();
  39. InputStream in = this.getClass().getClassLoader().getResourceAsStream("MyHoliday.bar");
  40. ZipInputStream zipInputStream = new ZipInputStream(in);
  41. // 3.完成流程的部署操作 ZIP 或者 Bar文件
  42. Deployment deploy = repositoryService.createDeployment()
  43. // .addClasspathResource("MyHoliday.bar")// 关联要部署的流程文件
  44. .addZipInputStream(zipInputStream)
  45. .name("XXX公司请求流程")
  46. .deploy() ;// 部署流程
  47. System.out.println("deploy.getId() = " + deploy.getId());
  48. System.out.println("deploy.getName() = " + deploy.getName());
  49. }
  50. /**
  51. * 启动流程实例
  52. */
  53. @Test
  54. public void testRunProcess(){
  55. ProcessEngine processEngine = configuration.buildProcessEngine();
  56. // 我们需要通过RuntimeService来启动流程实例
  57. RuntimeService runtimeService = processEngine.getRuntimeService();
  58. // 启动流程实例
  59. ProcessInstance holidayRequest = runtimeService.startProcessInstanceById("myProcess:1:25004");
  60. System.out.println("holidayRequest.getProcessDefinitionId() = " + holidayRequest.getProcessDefinitionId());
  61. System.out.println("holidayRequest.getActivityId() = " + holidayRequest.getActivityId());
  62. System.out.println("holidayRequest.getId() = " + holidayRequest.getId());
  63. }
  64. /**
  65. * 测试任务查询
  66. */
  67. @Test
  68. public void testQueryTask(){
  69. ProcessEngine processEngine = configuration.buildProcessEngine();
  70. TaskService taskService = processEngine.getTaskService();
  71. List<Task> list = taskService.createTaskQuery()
  72. .processDefinitionKey("myProcess") // 指定查询的流程编程
  73. .taskAssignee("zhangsan") // 查询这个任务的处理人
  74. .list();
  75. for (Task task : list) {
  76. System.out.println("task.getProcessDefinitionId() = " + task.getProcessDefinitionId());
  77. System.out.println("task.getName() = " + task.getName());
  78. System.out.println("task.getAssignee() = " + task.getAssignee());
  79. System.out.println("task.getDescription() = " + task.getDescription());
  80. System.out.println("task.getId() = " + task.getId());
  81. }
  82. }
  83. /**
  84. * 完成当前任务
  85. */
  86. @Test
  87. public void testCompleteTask(){
  88. ProcessEngine processEngine = configuration.buildProcessEngine();
  89. TaskService taskService = processEngine.getTaskService();
  90. Task task = taskService.createTaskQuery()
  91. .processDefinitionKey("myProcess")
  92. .taskAssignee("lisi")
  93. .singleResult();
  94. // 创建流程变量
  95. if(task != null){
  96. // 完成任务
  97. taskService.complete(task.getId());
  98. }
  99. }
  100. /**
  101. * 获取流程任务的历史数据
  102. */
  103. @Test
  104. public void testHistory(){
  105. ProcessEngine processEngine = configuration.buildProcessEngine();
  106. HistoryService historyService = processEngine.getHistoryService();
  107. List<HistoricActivityInstance> list = historyService.createHistoricActivityInstanceQuery()
  108. .processDefinitionId("myProcess:1:25004")
  109. .finished() // 查询的历史记录的状态是已经完成
  110. .orderByHistoricActivityInstanceEndTime().asc() // 指定排序的字段和顺序
  111. .list();
  112. for (HistoricActivityInstance history : list) {
  113. System.out.println(history.getActivityName()+":"+history.getAssignee()+"--"
  114. +history.getActivityId()+":" + history.getDurationInMillis()+"毫秒");
  115. }
  116. }
  117. }

2.Flowable UI应用

  Flowable提供了几个web应用,用于演示及介绍Flowable项目提供的功能:

  • Flowable IDM: 身份管理应用。为所有Flowable UI应用提供单点登录认证功能,并且为拥有IDM管理员权限的用户提供了管理用户、组与权限的功能。
  • Flowable Modeler: 让具有建模权限的用户可以创建流程模型、表单、选择表与应用定义。
  • Flowable Task: 运行时任务应用。提供了启动流程实例、编辑任务表单、完成任务,以及查询流程实例与任务的功能。
  • Flowable Admin: 管理应用。让具有管理员权限的用户可以查询BPMN、DMN、Form及Content引擎,并提供了许多选项用于修改流程实例、任务、作业等。管理应用通过REST API连接至引擎,并与Flowable Task应用及Flowable REST应用一同部署。

  所有其他的应用都需要Flowable IDM提供认证。每个应用的WAR文件可以部署在相同的servlet容器(如Apache Tomcat)中,也可以部署在不同的容器中。由于每个应用使用相同的cookie进行认证,因此应用需要运行在相同的域名下。

2.1 安装部署

下载Tomcat:https://tomcat.apache.org/download-80.cgi 官网下载后解压缩到非中文目录即可,然后是下载FlowableUI的文件,在Flowable6.6之后把FlowableUI中提供的四个功能合并到了一起。

Flowable学习一(基础) - 图40

然后把解压缩后的两个war包拷贝到Tomcat的解压缩的webapps目录下

Flowable学习一(基础) - 图41

Tomcat目录:

Flowable学习一(基础) - 图42

2.2 启动服务

  启动Tomcat服务,执行startup.bat文件

Flowable学习一(基础) - 图43

如果启动中出现乱码修改Tomcat的conf目录下的 logging.properties 文件中的编码

Flowable学习一(基础) - 图44

如果一闪而过则检查jdk的环境变量配置。启动成功后,在浏览器中访问 http://localhost:8080/flowable-ui, 默认的账号密码是 admin/test

Flowable学习一(基础) - 图45

2.3 用户管理

  我们先在 身份管理应用程序 中创建用户并授权

Flowable学习一(基础) - 图46

创建用户

Flowable学习一(基础) - 图47

填写详细信息

Flowable学习一(基础) - 图48

授权管理

Flowable学习一(基础) - 图49

2.4 绘制流程

创建新的流程

Flowable学习一(基础) - 图50

流程图界面

Flowable学习一(基础) - 图51

创建流程,分配处理人

Flowable学习一(基础) - 图52

Flowable学习一(基础) - 图53

继续完成流程图的创建

Flowable学习一(基础) - 图54

2.5 部署流程

  绘制好的流程图,我们只需要一键导出即可

Flowable学习一(基础) - 图55

下载下来后拷贝到项目的resource目录下即可

Flowable学习一(基础) - 图56

然后就是正常的操作流程了

2.6 FlowableUI 演示

2.6.1 部署流程

  在FlowableUI中提供了演示程序

Flowable学习一(基础) - 图57

创建一个新的应用程序,并指定相关的信息

Flowable学习一(基础) - 图58

创建应用后需要指定对应的流程图

Flowable学习一(基础) - 图59

Flowable学习一(基础) - 图60

Flowable学习一(基础) - 图61

发布应用程序

Flowable学习一(基础) - 图62

2.6.2 启动流程

  发布了应用程序后我们就可以来启动流程了

Flowable学习一(基础) - 图63

Flowable学习一(基础) - 图64

Flowable学习一(基础) - 图65

Flowable学习一(基础) - 图66

点击显示图:

Flowable学习一(基础) - 图67

也就是可以看到当前是user1来处理,user1登录后可以看到要处理的流程,user2登录是看不到的。

Flowable学习一(基础) - 图68

点击完成后流程就向下一步流转了

Flowable学习一(基础) - 图69

这时再通过user2登录,就可以看到对应的代办的信息

Flowable学习一(基础) - 图70

Flowable学习一(基础) - 图71

然后点击完成,那么整个流程就介绍了

四、Flowable基础表结构

1.表结构讲解

  工作流程的相关操作都是操作存储在对应的表结构中,为了能更好的弄清楚Flowable的实现原理和细节,我们有必要先弄清楚Flowable的相关表结构及其作用。在Flowable中的表结构在初始化的时候会创建五类表结构,具体如下:

  • ACT_RE :’RE’表示 repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。
  • ACT_RU:’RU’表示 runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Flowable只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。
  • ACT_HI:’HI’表示 history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。
  • ACT_GE: GE 表示 general。 通用数据, 用于不同场景下
  • ACT_ID: ’ID’表示identity(组织机构)。这些表包含标识的信息,如用户,用户组,等等。

具体的表结构的含义:

表分类 表名 解释
一般数据
[ACT_GE_BYTEARRAY] 通用的流程定义和流程资源
[ACT_GE_PROPERTY] 系统相关属性
流程历史记录
[ACT_HI_ACTINST] 历史的流程实例
[ACT_HI_ATTACHMENT] 历史的流程附件
[ACT_HI_COMMENT] 历史的说明性信息
[ACT_HI_DETAIL] 历史的流程运行中的细节信息
[ACT_HI_IDENTITYLINK] 历史的流程运行过程中用户关系
[ACT_HI_PROCINST] 历史的流程实例
[ACT_HI_TASKINST] 历史的任务实例
[ACT_HI_VARINST] 历史的流程运行中的变量信息
流程定义表
[ACT_RE_DEPLOYMENT] 部署单元信息
[ACT_RE_MODEL] 模型信息
[ACT_RE_PROCDEF] 已部署的流程定义
运行实例表
[ACT_RU_EVENT_SUBSCR] 运行时事件
[ACT_RU_EXECUTION] 运行时流程执行实例
[ACT_RU_IDENTITYLINK] 运行时用户关系信息,存储任务节点与参与者的相关信息
[ACT_RU_JOB] 运行时作业
[ACT_RU_TASK] 运行时任务
[ACT_RU_VARIABLE] 运行时变量表
用户用户组表
[ACT_ID_BYTEARRAY] 二进制数据表
[ACT_ID_GROUP] 用户组信息表
[ACT_ID_INFO] 用户信息详情表
[ACT_ID_MEMBERSHIP] 人与组关系表
[ACT_ID_PRIV] 权限表
[ACT_ID_PRIV_MAPPING] 用户或组权限关系表
[ACT_ID_PROPERTY] 属性表
[ACT_ID_TOKEN] 记录用户的token信息
[ACT_ID_USER] 用户表

2.ProcessEngine讲解

2.1 硬编码的方式

  我们前面讲解案例的时候是通过ProcessEngineConfiguration这个配置类来加载的。

  1. // 配置数据库相关信息 获取 ProcessEngineConfiguration
  2. ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
  3. .setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn2?serverTimezone=UTC&nullCatalogMeansCurrent=true")
  4. .setJdbcUsername("root")
  5. .setJdbcPassword("123456")
  6. .setJdbcDriver("com.mysql.cj.jdbc.Driver")
  7. .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
  8. // 获取流程引擎对象
  9. ProcessEngine processEngine = cfg.buildProcessEngine();

  这种方式会调用buildProcessEngine()方法,里面的核心代码为:

Flowable学习一(基础) - 图72

Flowable学习一(基础) - 图73

2.2 配置文件

  除了上面的硬编码的方式外,我们还可以在resources目录下创建一个flowable.cfg.xml文件,注意这个名称是固定的哦。内容如下:

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
  4. <bean id="processEngineConfiguration"
  5. class="org.flowable.engine.impl.cfg.StandaloneProcessEngineConfiguration">
  6. <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/flow1?allowMultiQueries=true&amp;useUnicode=true&amp;characterEncoding=UTF-8&amp;useSSL=false&amp;serverTimezone=UTC&amp;nullCatalogMeansCurrent=true" /><property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver" />
  7. <property name="jdbcUsername" value="root" />
  8. <property name="jdbcPassword" value="123456" />
  9. <property name="databaseSchemaUpdate" value="true" />
  10. <property name="asyncExecutorActivate" value="false" />
  11. </bean>
  12. </beans>

  在上面的配置文件中配置相关的信息。我们在Java代码中就可以简化为:

  1. @Test
  2. public void test01(){
  3. // 获取流程引擎对象
  4. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  5. System.out.println("processEngine = " + processEngine);
  6. }

  可以看下getDefaultProcessEngine的源码,在里面最终还是执行了和硬编码一样的代码

  1. public static ProcessEngine getProcessEngine(String processEngineName) {
  2. if (!isInitialized()) {
  3. init(); // 完成初始化操作
  4. }
  5. return processEngines.get(processEngineName);
  6. }

  进入init方法

  1. public static synchronized void init() {
  2. if (!isInitialized()) {
  3. if (processEngines == null) {
  4. // Create new map to store process-engines if current map is null
  5. processEngines = new HashMap<>();
  6. }
  7. ClassLoader classLoader = ReflectUtil.getClassLoader();
  8. Enumeration<URL> resources = null;
  9. try {
  10. resources = classLoader.getResources("flowable.cfg.xml"); // 加载flowable.cfg.xml配置文件
  11. } catch (IOException e) {
  12. throw new FlowableIllegalArgumentException("problem retrieving flowable.cfg.xml resources on the classpath: " + System.getProperty("java.class.path"), e);
  13. }
  14. // Remove duplicated configuration URL's using set. Some
  15. // classloaders may return identical URL's twice, causing duplicate
  16. // startups
  17. Set<URL> configUrls = new HashSet<>();
  18. while (resources.hasMoreElements()) {
  19. configUrls.add(resources.nextElement());
  20. }
  21. for (Iterator<URL> iterator = configUrls.iterator(); iterator.hasNext();) {
  22. URL resource = iterator.next();
  23. LOGGER.info("Initializing process engine using configuration '{}'", resource.toString());
  24. initProcessEngineFromResource(resource); // 初始化ProcessEngine
  25. }
  26. try {
  27. resources = classLoader.getResources("flowable-context.xml"); // 在整合Spring的情况下加载该文件
  28. } catch (IOException e) {
  29. throw new FlowableIllegalArgumentException("problem retrieving flowable-context.xml resources on the classpath: " + System.getProperty("java.class.path"), e);
  30. }
  31. while (resources.hasMoreElements()) {
  32. URL resource = resources.nextElement();
  33. LOGGER.info("Initializing process engine using Spring configuration '{}'", resource.toString());
  34. initProcessEngineFromSpringResource(resource); // 从Spring的资源文件中完成ProcessEngine的初始化
  35. }
  36. setInitialized(true);
  37. } else {
  38. LOGGER.info("Process engines already initialized");
  39. }
  40. }

  在源码中提供了单独使用好整合Spring的配置加载方式。再进入到initProcessEngineFromResource(resource)方法中:

Flowable学习一(基础) - 图74

Flowable学习一(基础) - 图75

Flowable学习一(基础) - 图76

而且我们也可以看到ProcessEngine最终的实现是 ProcessEngineImpl对象。

2.3 自定义配置文件

  最后我们如果要加载自定义名称的配置文件可以通过ProcessEngineConfiguration中的对应构造方法来实现

  1. @Test
  2. public void test2() throws Exception{
  3. ProcessEngineConfiguration configuration = ProcessEngineConfiguration
  4. .createProcessEngineConfigurationFromResource("flowable.cfg.xml");
  5. ProcessEngine processEngine = configuration.buildProcessEngine();
  6. System.out.println("processEngine = " + processEngine);
  7. }

3. Servcie服务接口

Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口,我们使用这些接口可以就是操作服务对应的数据表

Flowable学习一(基础) - 图77

3.1 Service创建方式

通过ProcessEngine创建Service

方式如下:

  1. RuntimeService runtimeService = processEngine.getRuntimeService();
  2. RepositoryService repositoryService = processEngine.getRepositoryService();
  3. TaskService taskService = processEngine.getTaskService();
  4. // ...

3.2 Service总览

service名称 service作用
RepositoryService Flowable的资源管理类
RuntimeService Flowable的流程运行管理类
TaskService Flowable的任务管理类
HistoryService Flowable的历史管理类
ManagerService Flowable的引擎管理类

简单介绍:

RepositoryService

是activiti的资源管理类,提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的业务流程图需要使用此service将流程定义文件的内容部署到计算机。

除了部署流程定义以外还可以:查询引擎中的发布包和流程定义。

暂停或激活发布包,对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了,激活是对应的反向操作。获得多种资源,像是包含在发布包里的文件, 或引擎自动生成的流程图。

获得流程定义的pojo版本, 可以用来通过java解析流程,而不必通过xml。

RuntimeService

Activiti的流程运行管理类。可以从这个服务类中获取很多关于流程执行相关的信息

TaskService

Activiti的任务管理类。可以从这个类中获取任务的信息。

HistoryService

Flowable的历史管理类,可以查询历史信息,执行流程时,引擎会保存很多数据(根据配置),比如流程实例启动时间,任务的参与者, 完成任务的时间,每个流程实例的执行路径,等等。 这个服务主要通过查询功能来获得这些数据。

ManagementService

Activiti的引擎管理类,提供了对Flowable 流程引擎的管理和维护功能,这些功能不在工作流驱动的应用程序中使用,主要用于 Flowable 系统的日常维护。

4.图标介绍

  BPMN 2.0是业务流程建模符号2.0的缩写。它由Business Process Management Initiative这个非营利协会创建并不断发展。作为一种标识,BPMN 2.0是使用一些符号来明确业务流程设计流程图的一整套符号规范,它能增进业务建模时的沟通效率。目前BPMN2.0是最新的版本,它用于在BPM上下文中进行布局和可视化的沟通。接下来我们先来了解在流程设计中常见的 符号。

BPMN2.0的基本符合主要包含:

4.1 事件图标

  在Flowable中的事件图标启动事件,边界事件,中间事件和结束事件.

Flowable学习一(基础) - 图78

4.2 活动(任务)图标

  活动是工作或任务的一个通用术语。一个活动可以是一个任务,还可以是一个当前流程的子处理流程; 其次,你还可以为活动指定不同的类型。常见活动如下:

Flowable学习一(基础) - 图79

4.3 结构图标

  结构图标可以看做是整个流程活动的结构,一个流程中可以包括子流程。常见的结构有:

4.4 网关图标

  网关用来处理决策,有几种常用网关需要了解:

Flowable学习一(基础) - 图80

5.流程部署详解

5.1 部署实现

  我们先来看下流程部署的具体过程。代码实现

  1. /**
  2. * 部署流程
  3. */
  4. @Test
  5. public void test3(){
  6. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  7. RepositoryService repositoryService = processEngine.getRepositoryService();
  8. Deployment deploy = repositoryService.createDeployment()
  9. .addClasspathResource("holiday-request-new.bpmn20.xml")
  10. .name("请假流程...")
  11. .category("请假") // 分类
  12. .tenantId("dpb") // 租户id
  13. .deploy();
  14. System.out.println("deploy.getId() = " + deploy.getId());
  15. System.out.println("deploy.getName() = " + deploy.getName());
  16. System.out.println("deploy.getCategory() = " + deploy.getCategory());
  17. }

5.2 部署涉及表结构

涉及到的三张表:

部署资源表:act_ge_bytearray

字段 名称 备注
ID_ 主键
REV_ 版本号
NAME_ 名称 部署的文件名称,如:holiday-request-new.bpmn20.xml、holiday-request-new.bpmn20.png
DEPLOYMENTID 部署ID
BYTES_ 字节(二进制数据)
GENERATED_ 是否系统生成 0为用户上传,
1为系统自动生成, 比如系统会 自动根据xml生 成png

部署ID表:act_re_deployment

字段 名称 备注
ID_ 主键
NAME_ 名称
CATEGORY_ 分类
TENANTID 租户ID
DEPLOYTIME 部署时间
DERIVEDFROM 来源于
DERIVEDFROM_ROOT 来源于
ENGINEVERSION 流程引擎的版本

流程表:act_re_procdef

字段 名称 备注
ID_ 主键
REV_ 版本号
CATEGORY_ 分类 流程定义的Namespace就是类别
NAME_ 名称
KEY_ 标识
VERSION_ 版本
DEPLOYMENTID 部署ID
RESOURCENAME 资源名称 流程bpmn文件名称
DGRMRESOURCE_NAME 图片资源名称
DESCRIPTION_ 描述
HASSTART_FORM_KEY 拥有开始表单标识 start节点是否存在formKey 0否 1是
HASGRAPHICAL_NOTATION 拥有图形信息
SUSPENSIONSTATE 挂起状态 暂停状态 1激活 2暂停
TENANTID 租户ID

注意:

业务流程定义数据表。此表和ACTRE_DEPLOYMENT是多对一的关系,即,一个部署的bar包里可能包含多个流程定义文件,每个流程定义文件都会有一条记录在ACT_REPROCDEF表内,每个流程定义的数据,都会对于ACT_GE_BYTEARRAY表内的一个资源文件和PNG图片文件。和ACT_GE_BYTEARRAY的关联是通过程序用ACT_GE_BYTEARRAY.NAME与ACT_RE_PROCDEF.NAME完成的

5.3 挂起和激活

  部署的流程默认的状态为激活,如果我们暂时不想使用该定义的流程,那么可以挂起该流程。当然该流程定义下边所有的流程实例全部暂停。

流程定义为挂起状态,该流程定义将不允许启动新的流程实例,同时该流程定义下的所有的流程实例都将全部挂起暂停执行。

  1. /**
  2. * 挂起流程
  3. */
  4. @Test
  5. public void test05(){
  6. // 获取流程引擎对象
  7. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  8. RepositoryService repositoryService = processEngine.getRepositoryService();
  9. ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
  10. .processDefinitionId("holiday:1:4")
  11. .singleResult();
  12. // 获取流程定义的状态
  13. boolean suspended = processDefinition.isSuspended();
  14. System.out.println("suspended = " + suspended);
  15. if(suspended){
  16. // 表示被挂起
  17. System.out.println("激活流程定义");
  18. repositoryService.activateProcessDefinitionById("holiday:1:4",true,null);
  19. }else{
  20. // 表示激活状态
  21. System.out.println("挂起流程");
  22. repositoryService.suspendProcessDefinitionById("holiday:1:4",true,null);
  23. }
  24. }

具体的实现其实就是更新了流程定义表中的字段

Flowable学习一(基础) - 图81

而且通过REV_字段来控制数据安全,也是一种乐观锁的体现了,如果要启动一个已经挂起的流程就会出现如下的错误

Flowable学习一(基础) - 图82

6.启动流程实例

  然后我们来看看启动流程实例的过程。实现代码如下:

  1. /**
  2. * 启动流程实例
  3. */
  4. @Test
  5. public void testRunProcess(){
  6. // 获取流程引擎对象
  7. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  8. // 启动流程实例通过 RuntimeService 对象
  9. RuntimeService runtimeService = processEngine.getRuntimeService();
  10. // 构建流程变量
  11. Map<String,Object> variables = new HashMap<>();
  12. variables.put("employee","张三") ;// 谁申请请假
  13. variables.put("nrOfHolidays",3); // 请几天假
  14. variables.put("description","工作累了,想出去玩玩"); // 请假的原因
  15. // 启动流程实例,第一个参数是流程定义的id
  16. ProcessInstance processInstance = runtimeService
  17. .startProcessInstanceById("holiday:1:4", variables);// 启动流程实例
  18. // 输出相关的流程实例信息
  19. System.out.println("流程定义的ID:" + processInstance.getProcessDefinitionId());
  20. System.out.println("流程实例的ID:" + processInstance.getId());
  21. System.out.println("当前活动的ID:" + processInstance.getActivityId());
  22. }

  当我们启动了一个流程实例后,会在ACTRU*对应的表结构中操作,运行时实例涉及的表结构共10张:

  • ACT_RU_DEADLETTER_JOB 正在运行的任务表
  • ACT_RU_EVENT_SUBSCR 运行时事件
  • ACT_RU_EXECUTION 运行时流程执行实例
  • ACT_RU_HISTORY_JOB 历史作业表
  • ACT_RU_IDENTITYLINK 运行时用户关系信息
  • ACT_RU_JOB 运行时作业表
  • ACT_RU_SUSPENDED_JOB 暂停作业表
  • ACT_RU_TASK 运行时任务表
  • ACT_RU_TIMER_JOB 定时作业表
  • ACT_RU_VARIABLE 运行时变量表

  启动一个流程实例的时候涉及到的表有

  • ACT_RU_EXECUTION 运行时流程执行实例
  • ACT_RU_IDENTITYLINK 运行时用户关系信息
  • ACT_RU_TASK 运行时任务表
  • ACT_RU_VARIABLE 运行时变量表

ACT_RU_EXECUTION表结构

字段 名称 备注
ID_ 主键
REV_ 版本号
PROCINST_ID 流程实例ID
BUSINESSKEY 业务主键ID
PARENTID 父执行流的ID
PROCDEF_ID 流程定义的数据ID
SUPEREXEC
ROOTPROC_INST_ID 流程实例的root流程id
ACTID 节点实例ID
ISACTIVE 是否存活
ISCONCURRENT 执行流是否正在并行
ISSCOPE
ISEVENT_SCOPE
ISMI_ROOT
SUSPENSIONSTATE 流程终端状态
CACHEDENT_STATE
TENANTID 租户编号
NAME_
STARTTIME 开始时间
STARTUSER_ID 开始的用户编号
LOCKTIME 锁定时间
ISCOUNT_ENABLED
EVTSUBSCR_COUNT
TASKCOUNT
JOBCOUNT
TIMERJOB_COUNT
SUSPJOB_COUNT
DEADLETTERJOB_COUNT
VARCOUNT
IDLINK_COUNT

创建流程实例后对应的表结构的数据

Flowable学习一(基础) - 图83

Flowable学习一(基础) - 图84

ACT_RU_TASK 运行时任务表

字段 名称 备注
ID_ 主键
REV_ 版本号
EXECUTIONID 任务所在的执行流ID
PROCINST_ID 流程实例ID
PROCDEF_ID 流程定义数据ID
NAME_ 任务名称
PARENTTASK_ID 父任务ID
DESCRIPTION_ 说明
TASKDEF_KEY 任务定义的ID值
OWNER_ 任务拥有人
ASSIGNEE_ 被指派执行该任务的人
DELEGATION_ 委托人
PRIORITY_ 优先级
CREATETIME 创建时间
DUEDATE 耗时
CATEGORY_ 类别
SUSPENSIONSTATE 是否挂起 1代表激活 2代表挂起
TENANTID 租户编号
FORMKEY
CLAIMTIME 拾取时间

创建流程实例后对应的表结构的数据

Flowable学习一(基础) - 图85

Flowable学习一(基础) - 图86

ACT_RU_VARIABLE 运行时变量表

字段 名称 备注
ID_ 主键
REV_ 版本号
TYPE_ 参数类型 可以是基本的类型,也可以用户自行扩展
NAME_ 参数名称
EXECUTIONID 参数执行ID
PROCINST_ID 流程实例ID
TASKID 任务ID
BYTEARRAYID 资源ID
DOUBLE_ 参数为double,则保存在该字段中
LONG_ 参数为long,则保存在该字段中
TEXT_ 用户保存文本类型的参数值
TEXT2_ 用户保存文本类型的参数值

创建流程实例后对应的表结构的数据

Flowable学习一(基础) - 图87

Flowable学习一(基础) - 图88

ACT_RU_IDENTITYLINK 运行时用户关系信息

字段 名称 备注
ID_ 主键
REV_ 版本号
GROUPID 用户组ID
TYPE_ 关系数据类型 assignee支配人(组)、candidate候选人(组)、owner拥有人,participant参与者
USERID 用户ID
TASKID 任务ID
PROCINST_ID 流程定义ID
PROCDEF_ID 属性ID

创建流程实例后对应的表结构的数据:

Flowable学习一(基础) - 图89

7.处理流程

  上面的流程已经流转到了zhangsan这个用户这里,然后可以开始审批了

  1. // 获取流程引擎对象
  2. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
  3. TaskService taskService = processEngine.getTaskService();
  4. Task task = taskService.createTaskQuery()
  5. .processDefinitionId("holiday:1:4")
  6. .taskAssignee("zhangsan")
  7. .singleResult();
  8. // 添加流程变量
  9. Map<String,Object> variables = new HashMap<>();
  10. variables.put("approved",false); // 拒绝请假
  11. // 完成任务
  12. taskService.complete(task.getId(),variables);

  在正常处理流程中涉及到的表结构

  • ACT_RU_EXECUTION 运行时流程执行实例
  • ACT_RU_IDENTITYLINK 运行时用户关系信息
  • ACT_RU_TASK 运行时任务表
  • ACT_RU_VARIABLE 运行时变量表

ACT_RU_TASK 运行时任务表 :会新生成一条记录

Flowable学习一(基础) - 图90

Flowable学习一(基础) - 图91

ACT_RU_VARIABLE 运行时变量表:会记录新的流程变量

Flowable学习一(基础) - 图92

当然流程实例也可以挂起

  1. // 1.获取ProcessEngine对象
  2. ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
  3. // 2.获取RuntimeService
  4. RuntimeService runtimeService = engine.getRuntimeService();
  5. // 3.获取流程实例对象
  6. ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
  7. .processInstanceId("25001")
  8. .singleResult();
  9. // 4.获取相关的状态操作
  10. boolean suspended = processInstance.isSuspended();
  11. String id = processInstance.getId();
  12. if(suspended){
  13. // 挂起--》激活
  14. runtimeService.activateProcessInstanceById(id);
  15. System.out.println("流程定义:" + id + ",已激活");
  16. }else{
  17. // 激活--》挂起
  18. runtimeService.suspendProcessInstanceById(id);
  19. System.out.println("流程定义:" + id + ",已挂起");
  20. }

启动第二个流程实例后再查看相关的表结构时,对他们的关系理解会更加的清楚一些

启动一个新的流程实例对应的就会产生两条记录

Flowable学习一(基础) - 图93

IDENTITYLINK中会记录每次流程操作的信息

Flowable学习一(基础) - 图94

Flowable学习一(基础) - 图95

流程变量数据,及时key 相同,但是属于不同的流程实例相互间也是隔离的

Flowable学习一(基础) - 图96

8.完成一个流程

  然后我们把第一个流程处理完成

  1. ProcessEngine processEngine = cfg.buildProcessEngine();
  2. TaskService taskService = processEngine.getTaskService();
  3. Task task = taskService.createTaskQuery()
  4. .processDefinitionId("holiday:1:4")
  5. .taskAssignee("lisi")
  6. .singleResult();
  7. // 添加流程变量
  8. Map<String,Object> variables = new HashMap<>();
  9. variables.put("approved",false); // 拒绝请假
  10. // 完成任务
  11. taskService.complete(task.getId(),variables);

处理完了一个工作流程后,我们来看看相关的表结构信息

首先我们会发现

  • ACT_RU_EXECUTION 运行时流程执行实例
  • ACT_RU_IDENTITYLINK 运行时用户关系信息
  • ACT_RU_TASK 运行时任务表
  • ACT_RU_VARIABLE 运行时变量表

这四张表中对应的数据都没有了,也就是这个流程已经不是运行中的流程了。然后在对应的历史表中我们可以看到相关的信息

  • ACT_HI_ACTINST 历史的流程实例
  • ACT_HI_ATTACHMENT 历史的流程附件
  • ACT_HI_COMMENT 历史的说明性信息
  • ACT_HI_DETAIL 历史的流程运行中的细节信息
  • ACT_HI_IDENTITYLINK 历史的流程运行过程中用户关系
  • ACT_HI_PROCINST 历史的流程实例
  • ACT_HI_TASKINST 历史的任务实例
  • ACT_HI_VARINST 历史的流程运行中的变量信息

在我们上面的处理流程的过程中设计到的历史表有

ACT_HI_ACTINST 历史的流程实例

字段 名称 备注
ID_ 主键
PROCDEF_ID 流程定义ID
PROCINST_ID 流程实例ID
EXECUTIONID 执行ID
ACTID 节点实例ID
TASKID 任务ID
CALLPROC_INST_ID 调用外部的流程实例ID
ACTNAME 节点名称
ACTTYPE 节点类型
ASSIGNEE_ 处理人
STARTTIME 开始时间
ENDTIME 结束时间
DURATION_ 耗时
DELETEREASON 删除原因
TENANTID 租户编号

Flowable学习一(基础) - 图97

Flowable学习一(基础) - 图98

ACT_HI_IDENTITYLINK 历史的流程运行过程中用户关系

字段 名称 备注
ID_ 主键
GROUPID 组编号
TYPE_ 类型
USERID 用户编号
TASKID 任务编号
CREATETIME 创建时间
PROCINST_ID 流程实例编号
SCOPEID
SCOPETYPE
SCOPEDEFINITION_ID

Flowable学习一(基础) - 图99

ACT_HI_PROCINST 历史的流程实例

字段 名称 备注
ID_ 主键
PROCINST_ID 流程实例ID
BUSINESSKEY 业务主键
PROCDEF_ID 属性ID
STARTTIME 开始时间
ENDTIME 结束时间
DURATION_ 耗时
STARTUSER_ID 起始人
STARTACT_ID 起始节点
ENDACT_ID 结束节点
SUPERPROCESS_INSTANCE_ID 父流程实例ID
DELETEREASON 删除原因
TENANTID 租户编号
NAME_ 名称

Flowable学习一(基础) - 图100

Flowable学习一(基础) - 图101

ACT_HI_TASKINST 历史的任务实例

字段 名称 备注
ID_ 主键
PROCDEF_ID 流程定义ID
TASKDEF_KEY 任务定义的ID值
PROCINST_ID 流程实例ID
EXECUTIONID 执行ID
PARENTTASK_ID 父任务ID
NAME_ 名称
DESCRIPTION_ 说明
OWNER_ 实际签收人 任务的拥有者 签收人(默认为空,只有在委托时才有值)
ASSIGNEE_ 被指派执行该任务的人
STARTTIME 开始时间
CLAIMTIME 任务拾取时间
ENDTIME 结束时间
DURATION_ 耗时
DELETEREASON 删除原因
PRIORITY_ 优先级别
DUEDATE 过期时间
FORMKEY 节点定义的formkey
CATEGORY_ 类别
TENANTID 租户

Flowable学习一(基础) - 图102

Flowable学习一(基础) - 图103

ACT_HI_VARINST 历史的流程运行中的变量信息:流程变量虽然在任务完成后在流程实例表中会删除,但是在历史表中还是会记录的

字段 名称 备注
ID_ 主键
PROCINST_ID 流程实例ID
EXECUTIONID 指定ID
TASKID 任务ID
NAME_ 名称
VARTYPE 参数类型
REV_ 数据版本
BYTEARRAYID 字节表ID
DOUBLE_ 存储double类型数据
LONG_ 存储long类型数据
…..

Flowable学习一(基础) - 图104

好了一个相对简单的流程处理涉及到的相关表结构内容就介绍完了