flowable之三 启动一个流程并跟踪

1. 背景介绍

当我们部署一个流程并启动后，Flowable会按照既定流程定义及进行节点处理以及自动流转，从一个节点执行到下一个节点，直至结束。在此过程中，系统如何处理BPMN XML文件？节点如何进行流转？本文对flowable内部源码进行解析，挖掘其引擎原理。

2. 系统原理

2.1. 总览图

总览图

在这里插入图片描述

如上图所示为流程启动关键节点图，主要由以下几部分组成：

1. 启动命令封装（橙色部分）

主要功能：通过将bpmnXML格式文件解析为程序可执行的内存对象：Process。 类似于 saga 事件驱动中的 event 。。

a. 获取流程定义 ProcessDefinition（通过入参<流程key or 流程id>找到对应的流程定义）

b. 加载解析bpmn.xml文件（工作流原始文件）

c. 生成bpmnModel（工作流描述）

d. 生成Process（工作流执行）

2. 命令执行器（蓝色部分）

主要功能：流程执行过程中会添加各种拦截器，其中最为核心的是CommandInvokerInterceptor

a. LogInterceptor：当日志级别为debug时，会输出启动日志

b. SpringTransactionInterceptor

  Spring事务管理，用户事务的doTransaction、commit、rollback

c. CommandContextInterceptor：执行SqlSession close方法，将数据进行持久化

d. TransactionContextInterceptor

e. BpmnOverrideContextInterceptor

f. CommandInvokerInterceptor：真正执行启动流程命令的拦截器

3. 节点流转（绿色部分）

主要功能：完成对流程节点的执行，及找到下一个可执行的节点，直至流程运行完成。其最核心的包括DefaulFlowableEngineAgenda，该类持有operations，通过对节点操作封装为不同的Operation，进行节点的流转。

2.2. 命令执行器（CommandExecutor）

Flowable是通过命令模式 + 责任链模式完成对操作的执行，flowable启动代码中，构造ProcessEngine时会调用 init()方法进行引擎初始化，如下图所示：

2.3 启动命令封装

启动命令通过入参的流程key or 流程定义id加载对应的流程定义数据后，初始化了启动operation操作，其核心源码如下：

  1. 调用new StartProcessInstanceCmd 生成启动命令
    在这里插入图片描述

  2. StartProcessInstanceCmd.execute() 方法定义如下：其首先获取流程定义ProcessDefinition，之后通过调用startProcessInstance启动流程。

流程定义数据来源于数据表：ACT_RE_PROCDEF，其是在流程部署时写入的，注意其字段deploymentId，在作为数据表ACT_GE_BYTEARRAY的外键，关联了 流程XML原始文件。
在这里插入图片描述

  1. 在得到流程定义后，通过调用 ProcessInstanceHelper#createProcessInstance方法进行流程启动，注意在该方法中，通过调用 ProcessDefinitionUtil.getProcess 得到流程 Process

注意在之后，通过 process.getInitialFlowElement 方法得到流程初始节点。在之后构造 Execution 实体时，设置该初始节点。
在这里插入图片描述
在这里插入图片描述

4）在方法 ProcessInstanceHelper.startProcessInstance 中，通过调用CommandContextUtil.getAgenda(commandContext).planContinueProcessOperation(execution) 将当前实例添加到操作堆栈operations中。

       至此：完成了启动命令的初始化过程

在这里插入图片描述

2.4流程节点流转（重点）

2.4.1 节点流转核心节点图

在这里插入图片描述

重点：上图为节点流转图，节点流转的核心是AbstractAgenda，其默认的实现是 DefaultFlowableEngineAgenda

该类持有变量operations，operations是个一个堆栈，在流转过程中，通过DefaultFlowableEngineAgenda一系列操作可以

将不同的操作压入栈中，然后运转过程中，将每一个操作弹出栈进行命令的执行。这里的operation指默认实现了AbstractOperation的操作类，AbstractOperation的实现类如下所示：

比如要继续流转，则压入ContinueProcessOperation，需要结束流程则需要压入 EndExecutionOperation。

在这里插入图片描述

2.4.2. ContinueProcessOperation操作

ContinueProcessOperation操作对节点和顺序流分别作了处理，如下图所示：

在这里插入图片描述
像极了 saga 中的 router 和 handler

当前元素为节点时，执行如下主要操作:

1）标记节点开始

2）执行节点监听器

3）获取节点对应行为器

4）执行行为器

当无对应的行为器时，则创建 takeOutgoingSequenceFlowsOperation 操作

在这里插入图片描述
当前元素为顺序流时，执行如下主要操作:

1）找到当前元素后置元素，设置为当前执行元素

2）如果后置元素是节点，则直接执行

3）如果后置元素是顺序流，则构造ContinueProcessOperation操作

在这里插入图片描述

2.4.2.1. 节点行为器ActivityBehavior

如下图所示为行为器的实现类，从图中可以看到我们熟悉的StartEvent、NoneEvent及ServiceTask的实现类。
在这里插入图片描述
在行为器执行完成对应操作后，由行为器决定是否继续向后流转节点FlowNodeActivityBehavior默认提供了leave()方法，其内部主要是构造 TakeOutgoingSequenceFlowsOperation 继续流转节点

2.4.3. TakeOutgoingSequenceFlowsOperation操作

TakeOutgoingSequenceFlowsOperation的实现分别对节点和顺序流进行了操作，如下图所示：
在这里插入图片描述

当前元素为节点时：
1）首先标记当前节点执行完成

2）遍历后置顺序流元素，并计算顺序流表达式属性

3）当无有效的后置顺序流元素时，则构建EndExecutionOperation，压入栈中

4）存在有效的后置顺序流元素时，则遍历顺序流并且构造 ContinueProcessOperation操作，压入栈中

在这里插入图片描述
当前元素为顺序流时：

1）标记当前元素结束，构造ContinueProcessOperation操作，压入栈中
在这里插入图片描述

2.5 Example

下面以该流程为例，详细列出操作流转步骤：
在这里插入图片描述

其节点流转图如下：

详细步骤如下：

Step 1： 在流程启动初期，operations堆栈中压入ContinueProcessOperation操作，传入的execution的当前节点为开始节点

在这里插入图片描述

Step 2： 取出栈顶操作元素开始节点并执，首先进行节点开始持久化操作，之后调用节点行为类执行，开始节点的行为类是 NoneStartEventActivityBehavior，如下图所示为空操作，

其并没有实现execute()方法，还是复用了父类FlowNodeActivityBehavior的execute()方法，执行leave方法，压入TakeOutgoingSequenceOperation操作，此时execution的当前节点为开始节点

Step 3： 弹出栈顶TakeOutgoingSequenceOperation(开始节点)，首先进行节点结束持久化操作，之后获取开始节点的后置可用分支，压入ContinueProcessOperation堆栈，

此时execution的当前节点为 开始节点-创建变量节点顺序流

Step 4： 取出栈顶ContinueProcessOperation(开始节点-创建变量节点顺序流) 并执行，其目标节点为 创建变量节点，开始执行，首先执行节点开始持久化操作，接着执行其行为类JavaDelegate，

执行完成后，压入TakeOutgoingSequenceOperation操作，此时execution的当前节点为创建变量节点

计算节点后置节点以及其他逻辑后，压入操作类，此时execution的当前节点为开始节点–>创建变量的连线。

Step 5： 弹出栈顶TakeOutgoingSequenceOperation(创建变量节点)，首先进行节点结束持久化操作，之后获取创建变量节点的可用分支，压入ContinueProcessOperation堆栈，

此时此时execution的当前节点为创建变量节点-结束事件顺序流

Step 6： 弹出栈顶ContinueProcessOperation(创建变量节点-结束事件)，其目标节点为结束事件，开始执行，首先进行节点开始持久化操作，接着执行其行为类 NoneEndEventActivityBehavior，如下图可得，

在这里插入图片描述

结束事件行为器构造了TakeOutgoingSequenceOperation操作，此时execution的当前节点为

结束事件节点

Step 7： 弹出栈顶TakeOutgoingSequenceOperation(结束节点)，首先进行节点结束持久化操作，之后获取创建变量节点的可用分支，无可用分支，则构造 EndExecutionOperation，此时execution的当前节点为结束节点
在这里插入图片描述

Step 8： 弹出栈顶EndExecutionOperation(结束节点)，执行相关结束操作

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/247874.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

「Swift」Xcode多Target创建

「Swift」Xcode多Target创建

前言&#xff1a;我们日常开发中会使用多个环境&#xff0c;如Dev、UAT&#xff0c;每个环境对应的业务功能都不同&#xff0c;但每个环境之间都只存在较小的差异&#xff0c;所以此时可以使用创建多个Target来实现&#xff0c;每个Target对应这个一个App&#xff0c;可以实现一…
阅读更多...
离散型概率密度函数的分布列⇔分布函数

离散型概率密度函数的分布列⇔分布函数

目录 一、super误区 1.分布函数的定义 二、分布列⇒分布函数 二、分布列⇐分布函数 一、super误区 我在读定义的时候陷入了一个误区&#xff0c;与大家分享一下。 1.分布函数的定义 由于是离散型的概率密度函数&#xff0c;我把他抽象到数轴上理解&#xff1a; 如下分布…
阅读更多...
【教3妹学编程-算法题】反转二叉树的奇数层

【教3妹学编程-算法题】反转二叉树的奇数层

插&#xff1a; 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站。 坚持不懈&#xff0c;越努力越幸运&#xff0c;大家一起学习鸭~~~ 3妹&#xff1a;“你不是真正的快乐&#xff0c; 你的…
阅读更多...
Python求小于m的最大10个素数

Python求小于m的最大10个素数

为了找到小于m的最大10个素数&#xff0c;我们首先需要确定m的值。然后&#xff0c;我们可以使用一个简单的算法来检查每一个小于m的数字是否是素数。 下面是一个Python代码示例&#xff0c;可以找到小于m的最大10个素数&#xff1a; def is_prime(n): if n < 1: …
阅读更多...
JAVA 反射

JAVA 反射

JAVA 反射 动态语言 动态语言&#xff0c;是指程序在运行时可以改变其结构&#xff1a;新的函数可以引进&#xff0c;已有的函数可以被删除等结构上的变化。比如常见的 JavaScript 就是动态语言&#xff0c;除此之外 Ruby,Python 等也属于动态语言&#xff0c;而 C、C则不属于…
阅读更多...
【Idea】SpringBoot项目中，jar包引用冲突异常的排查 / SM2算法中使用bcprov-jdk15to18的报错冲突问题

【Idea】SpringBoot项目中，jar包引用冲突异常的排查 / SM2算法中使用bcprov-jdk15to18的报错冲突问题

问题描述以及解决方法&#xff1a; 项目中使用了bcprov-jdk15to18 pom依赖&#xff0c;但是发现代码中引入的版本不正确。 追溯代码发现版本引入的是bcprov-jdk15on&#xff0c;而不是bcprov-jdk15to18&#xff0c;但是我找了半天pom依赖也没有发现有引入bcprov-jdk15on依赖。…
阅读更多...
JMeter下载与安装

JMeter下载与安装

文章目录 前言一、安装java环境&#xff08;JDK下载与安装&#xff09;二、JMeter下载三、JMeter安装1.解压缩2.配置环境变量 四、JMeter启动&#xff08;启动成功则代表JMeter安装成功&#xff09;五、JMeter汉化&#xff08;将JMeter修改成中文&#xff09;1.方法一&#xff…
阅读更多...
MFC画折线图，基于x64系统

MFC画折线图，基于x64系统

由于项目的需要&#xff0c;需要画一个折线图。 传统的Teechart、MSChart、HighSpeedChart一般是只能配置在x86系统下&#xff0c;等到使用x64系统下运行就是会报出不知名的错误&#xff0c;这个地方让人很苦恼。 我在进行配置的过程之中&#xff0c;使用Teechart将x86配置好…
阅读更多...
卫星影像5天一更新的地图网站

卫星影像5天一更新的地图网站

如果全球影像每5天一更新&#xff0c;并集多种地图数据源于一体的PB级海量地图数据该怎样去管理呢&#xff1f; 这是当我了解到SOAR网站之后&#xff0c;思考过的一个问题。 全球最大的在线地图网站 在SOAR的官方网站&#xff0c;据称它是世界上最大的在线地图网站。 它是集…
阅读更多...
大数据Doris（三十六）：Duplicate 模型（冗余模型）介绍

大数据Doris（三十六）：Duplicate 模型（冗余模型）介绍

文章目录 Duplicate 模型（冗余模型）介绍 一、创建doris表 二、插入数据
阅读更多...
Unity中Batching优化的GPU实例化整理总结

Unity中Batching优化的GPU实例化整理总结

文章目录 前言一、GPU Instancing的支持1、硬件支持2、Shader支持3、脚本支持 二、我们来顺着理一下GPU实例化的使用步骤1、GPU实例化前的C#代码准备2、在 appdata 和 v2f 中定义GPU实例化ID3、在顶点着色 和 片元着色器 设置GPU Instance ID&#xff0c;使实例化对象顶点位置正…
阅读更多...
05-详解Nacos配置管理中心,配置拉取的方式,热更新,配置共享(优先级)的步骤

05-详解Nacos配置管理中心,配置拉取的方式,热更新,配置共享(优先级)的步骤

Nacos配置管理 新建配置文件 当微服务部署的实例越来越多时,如果需要修改微服务的配置就需要逐个修改配置文件并且还要重启关联的微服务十分繁琐还易出错 项目中的配置文件分为每个项目特有的配置,项目所公用的配置 每个项目特有的配置: 有些项目中需要但有些项目中又不需要…
阅读更多...
7. 异常、断言及日志

7. 异常、断言及日志

1.异常 1).什么是异常 异常&#xff0c;就是不正常的意思。指的是程序在执行过程中&#xff0c;出现的非正常的情况&#xff0c;最终会导致JVM的非正常停止。 在Java等面向对象的编程语言中&#xff0c;异常本身是一个类&#xff0c;产生异常就是创建异常对象并抛出了一个异常…
阅读更多...
软件测试职业规划

软件测试职业规划

软件测试人员的发展误区【4】 公司开发的产品专业性较强&#xff0c;软件测试人员需要有很强的专业知识&#xff0c;现在软件测试人员发展出现了一种测试管理者不愿意看到的景象&#xff1a; 1、开发技术较强的软件测试人员转向了软件开发(非测试工具开发)&#xff1b; 2、业务…
阅读更多...
采埃孚4D成像雷达拆解

采埃孚4D成像雷达拆解

1 基本信息 品牌&#xff1a;海外Tier1采埃孚 • 应用&#xff1a;上汽飞凡中高端纯电平台 • 数量&#xff1a;单车2个&#xff0c;安装在前后保内部 • 最远探测距离&#xff1a;350米 拆解来看&#xff0c;4D雷达主要可以分为4个部分&#xff0c;分别为数字接口板及结构件…
阅读更多...
mac视频调色 DaVinci Resolve Studio 18 中文 for Mac

mac视频调色 DaVinci Resolve Studio 18 中文 for Mac

DaVinci Resolve Studio 18是一款功能强大、专业可靠的视频编辑软件&#xff0c;适用于各种规模的媒体项目制作。无论是独立制片人还是大型制片公司&#xff0c;都可以借助该软件进行高质量的视频创作和后期制作。 得编辑工作更加高效和灵活。 调色和色彩校正&#xff1a;软件…
阅读更多...
CSS的盒子模型(重点)

CSS的盒子模型(重点)

网页布局的三大核心&#xff1a;盒子模型、浮动、定位 网页布局的过程&#xff1a; 1. 先准备好相关的网页元素&#xff0c;网页元素基本都是盒子 Box 。 2. 利用 CSS 设置好盒子样式&#xff0c;然后摆放到相应位置。 3. 往盒子里面装内容.网页布局的核心本质&#xff1a; 就…
阅读更多...
或许是全网最全的延迟队列

或许是全网最全的延迟队列

什么是延迟队列 作用&#xff1a;用来存储延迟消息延迟消息&#xff1a;生产者发送一个消息给mq&#xff0c;然后mq会经过一段时间&#xff08;延迟时间&#xff09;&#xff0c;然后在把这个消息发送给消费者 应用场景 预定会议后&#xff0c;需要在预定的时间点前十分钟通…
阅读更多...
深拷贝、浅拷贝 react的“不可变值”

深拷贝、浅拷贝 react的“不可变值”

知识获取源–晨哥&#xff08;现实中的人 嘿嘿&#xff09; react中如果你想让一个值始终不变 或者说其他操作不影响该值 它只是作用初始化的时候 使用了浅拷贝–改变了初始值 会改变初始值(selectList1) 因为使用浅拷贝都指向同一个地址 const selectList1 { title: 大大, …
阅读更多...
RabbitMQ入门案例

RabbitMQ入门案例

RabbitMQ 是目前比较主流的MQ消息队列中间件&#xff0c;下面简单总结RabbitMQ入门时所做的一些笔记 1.RabbitMQ 入门案例 需求&#xff1a;用 Java 编写两个程序。发送单个消息的生产者和接收消息并打印出来的消费者 1.1 添加依赖 <!--rabbitmq 依赖客户端--> <de…
阅读更多...
最新文章

Copyright @ 2022~2023