【工作流Activiti7】6、Activiti 7 源码学习

news2024/11/25 3:02:26

1.  启动分析

源码版本是 7.1.0.M6

首先从 ProcessEngineAutoConfiguration 开始

ProcessEngineAutoConfiguration 是activiti-spring-boot-starter 7.1.0.M6自动配置的入口类,在这里主要看 SpringProcessEngineConfiguration

主要是配置了自动部署

最最最重要的是 buildProcessEngine() 方法,将来根据配置构建 ProcessEngine 的时候它就派上用场了

ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResourceDefault().buildProcessEngine();

下面重点看一下如何构建 ProcessEngine

在父类(ProcessEngineConfigurationImpl)的 buildProcessEngine() 里调用了一个非常重要的方法 init()

可以看到在init()方法里初始化了很多组件,接下来挑几个来重点看一下

initAgendaFactory()

initCommandContextFactory()

new了一个CommandContextFactory,重要的是CommandContextFactory中持有当前processEngineConfiguration的引用

initCommandExecutors()

初始化拦截器interceptor要重点说下,这里构造了一个拦截器链,而且拦截器链的最后是CommandInvoker,并且将第一个拦截器放到CommandExecutor里面,姑且先记下,后面有用到

initServices()

initBehaviorFactory()

在初始化各个组件以后,new了一个ProcessEngineImpl,并将当前的配置 ProcessEngineConfigurationImpl 赋值给它

因此,这个代表流程引擎的ProcessEngine就变成了一个基础的入口类,它提供了对工作流操作的所有服务的访问。

2.  CommandContextInterceptor

在默认的拦截器中有一个 CommandContextInterceptor 特别重要

在其execute()方法中设置上下文CommandContext

  1. 查找栈顶部的元素,如果为空,则新new一个CommandContext,如果不为空,则将获取到的CommandContext的熟悉reused设为true
  2. 将刚才获取到的CommandContext压入栈中
  3. 将当前processEngineConfiguration压入另一个栈中
  4. 调用下一个拦截器

也就是说,每个命令在经过CommandContextInterceptor后都有了自己的上下文

那么,CommandContext中到底有什么呢?继续看

CommandContext中有命令(Command),还有agenda(ActivitiEngineAgenda)

3.  Command

Activiti这里采用命令模式,将操作以及与之相关的信息都封装成命令。

下面以完成任务为例来看一下命令是如何被完成的

前面初始化services的时候说过了,会将创建好的CommandExecutor设置到各个Service中,因此TaskService中commandExecutor的出现就不足为奇了

可以看到,完成任务的时候,直接new了一个CompleteTaskCmd,然后交由commandExecutor去执行

CompleteTaskCmd主要有两个属性:任务ID 和 流程变量

既然命令交给了CommandExecutor执行,那么接下来看下它是如何执行的。

在前面 initCommandExecutor() 的时候我们指定,它其实是 CommandExecutorImpl,并且我们还知道它持有默认的命令配置,以及拦截器链中的第一个拦截器

从代码中可以看到 CommandExecutorImpl#execute() 直接从拦截器链中的第一个拦截器开始往后依次调用。可以预见到,它肯定会经过CommandContextInterceptor,于是在当前请求线程的局部变量中就会有一个栈(Stack),在栈的顶部放了一个CommandContext,在这个CommandContext中有待执行的Command,有processEngineConfiguration,还有agenda。

它这个CommandContext被设计成是每个线程私有的,就是每个线程都有自己的一个CommandContext

在线程局部变量中存放这栈,栈里面放着对象

拦截器链的最后一个拦截器是 CommandInvoker

4.  CommandInvoker

重头戏来了,接下来 CommandInvoker 的每个方法都要仔细看了

可以看到,真正去执行命令是在CommandInvoker中触发的

5.  Agenda

agenda (译:议程,待议事项,议事日程)的意思是“议程”,“会议议程”,“待议事项”

可以把 agenda 想象成是一个会议,首先每个命令请求都有一个 CommandContext,CommandContext里面有Agenda

这样的话,CommandContext 相当于会议室,Agenda 相当于这次会议的议程,就是这次会议要商议的事项有哪些,每个 Operation 相当于一个待议事项,在会议进行期间会不断产生很多新的事项,然后一个一个事项的过,直到所有的事项都处理完了。

也可以把 agenda 想象成线程池,不断有新的任务被丢进线程池,工作线程就不断从工作队列中取任务执行

还是 “会议室 --> 会议 --> 议程 --> 事项 --> 处理事项”更加形象生动

每个命令请求就相当于发起一次会议,会议的目的是处理这次的命令请求。为了开会讨论解决问题,需要有个会议室,然后发起会议,会议上有很多要解决的问题,一个一个解决问题,直到所有问题都被解决,会议结束

每个待议事项都是一个 Runnable 类型的对象,注意别搞混了,Runnable 本身不是线程。我个人猜测,之所以设计成Runnable类型的主要是为了方便异步处理,我们可以配置Activiti的活动是同步还是异步执行,而直接调用Runnable的run()方法就是同步执行,把它放到线程池就是异步执行,业务处理的逻辑都在run()方法里,完全不用关心是同步还是异步执行,这种设计太绝了,妙啊。。。(PS:纯属个人猜测,没有求证过,O(∩_∩)O哈哈~)

命令执行的结果放到会议室(CommandContext)

活动结束后,会调用planContinueProcessOperation(),流程继续执行,进入下一个活动节点

6.  CompleteTaskCmd

回到最初的完成任务命令,我们指定任务执行调用的Runnable的run()方法,run()方法里面是调用命令的execute方法

所以,接下来看完成任务这个命令具体做了什么

7.  ActivityBehavior

要理解 Behavior 必须要和流程图联系起来,流程图上的一些元素比如 网关、用户任务、子流程、事件等等都有对应的行为,每种行为的处理方式都不同

ActivityBehavior 的实现类比较多,层级也比较深,不一一列举,以其中一个为例看看就行了

继续回到完成任务,刚才看到往agenda中放了一个 TriggerExecutionOperation,该操作触发等待状态并继续该流程,并离开该活动。

8.  回顾

Command:命令

ActivitiEngineAgendaFactory:用于创建ActivitiEngineAgenda

ActivitiEngineAgenda:议程,待议事项,用于循环执行Operation

AbstractOperation:事项/操作,它实现了Runnable接口

CommandContextFactory:用于创建CommandContext

CommandContext:每个命令执行线程都有自己的CommandContext,其内部有对Command和Agenda的引用

CommandExecutor:执行Command,从拦截器链的第一个拦截器开始执行

CommandInvoker:拦截器链上的最后一个拦截器,负责将命令封装成Operation,在Agenda中执行Operation的时候就会调用具体命令的execute方法

ActivityBehavior:代表活动的行为,这是真正底层的驱动流程流转的核心

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

后渗透攻击(三)

目录 1、创建新账户 2、获取账号密码 3、远程屏幕控制 在进行提权后我们的操作空间就会大很多,可以进行一系列的创建新账户、获取账号密码、远程操控屏幕等等的操作。该文章就对一些常用的操作进行了整理。 1、创建新账户 查看目标靶机已存在用户 可以在meter…

[Jule CTF 2022] 部分WP

这个比赛参加的人极少,比赛有一星期那么长,快结束的时候来了个大牛,一下上到12000,我这6K只能排到第二了。不过题还是挺不错的。只是入口不是人链接,得自己输才能进,可能很多人因为这个没参加。 Crypto E…

【工作流Activiti7】5、Activiti7 多实例子流程

顾名思义,子流程是一个包含其他活动、网关、事件等的活动,这些活动本身形成了一个流程,该流程是更大流程的一部分。 使用子流程确实有一些限制: 一个子流程只能有一个none类型的启动事件,不允许有其他类型的启动事件…

C语言—结构体

结构体&#xff1a;将不同数据类型组合成一个新的数据类型&#xff1b; #include <stdio.h> struct Person {char name[50];int age;bool gender; }; int main() {} 定义了一个结构体Person&#xff0c;它包含一个字符数组成员name&#xff0c;int类型的age和bool类型的…

【生信原理】初探芯片表达谱分析

初探芯片表达谱分析 文章目录初探芯片表达谱分析实验目的实验内容实验题目实验过程数据的获取、解压与读取数据预处理&#xff08;背景纠正、标准化和探针信号汇总等&#xff09;数据过滤&#xff08;探针过滤&#xff09;探针注释&#xff08;添加基因注释信息&#xff09;lim…

Excel之INDIRECT函数实现某列元素上下翻转

Excel之INDIRECT函数实现某列元素上下翻转方法1&#xff1a;降序按钮1.0 使用条件1.1 选中元素序号列->排序和筛选->降序1.2 排序提醒对话框->排序1.3 处理后结果方法2&#xff1a;Indirect函数2.0 方法一的不足。2.1 INDIRECT函数处理及结果2.2 空白单元格的恢复及结…

客快物流大数据项目(一百):ClickHouse的使用

文章目录 ClickHouse的使用 一、使用Java操作ClickHouse 1、构建maven工程

用HTML+CSS构建一个绚丽的登录页面

用HTMLCSS构建一个绚丽的登录页面 参考文章&#xff1a; 动态水滴页面 自动切换背景的登录页面 登录页面代码 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" c…

[~/vulhub]/log4j/CVE-2021-44228-20221225

[~/vulhub]/log4j/CVE-2021-44228 ┌──(kwkl㉿kwkl)-[~/vulhub] └─$ cd log4j/CVE-2021-44228 ┌──(kwkl㉿kwkl)-[~/vulhub/log4j/CVE-2021-44228] └─$ dir 1.png 2.png docker-compose.yml README.md README.zh-cn.md┌──(kwkl㉿kwkl)-[~/vulhub/log4j/CVE-2021…

JSP ssh学生信息管理系统myeclipse开发mysql数据库MVC模式java编程计算机网页设计

一、源码特点 JSP ssh 学生信息管理系统是一套完善的web设计系统&#xff08;系统采用ssh框架进行设计开发&#xff09;&#xff0c;对理解JSP java编程开发语言有帮助&#xff0c;系统具有完整的源代码和数据库&#xff0c;系统主要采用 B/S模式开发。开发环境为TOMCAT7.…

TCP 报文段的格式(计算机网络-运输层)

目录 TCP 报文段的格式 TCP 报文段的格式 TCP虽然是面向字节流的&#xff0c;但TCP传送的数据单元却是报文段 TCP 报文段分为首部和数据两部分。TCP 的全部功能都体现在它首部中各字段的作用 TCP 报文段首部的前 20个 字节是固定的&#xff0c;后面有 4N 字节是根据需要而增加…

在linux上安装CMake

在linux上安装CMake一、下载CMake安装包二、配置环境变量三、验证是否能执行CMake四、CMake官方文档一、下载CMake安装包 本文演示环境为Linux系统&#xff0c;Redhat7 64位。 CMake提供了两种安装方式&#xff0c;一种是预编译好的二进制包&#xff0c;还有一种就是源码方式…

GateWay网关

GateWay 1. 什么是网关 网关是微服务最边缘的服务&#xff0c;直接暴露给用户&#xff0c;用来做用户和微服务的桥梁 没有网关&#xff1a;客户端直接访问我们的微服务&#xff0c;会需要在客户端配置很多的ip&#xff1a;port&#xff0c;如果user-service并发比较大&#x…

Unity URP 曲面细分

Unity URP 曲面细分 我终于变得不像我 文章目录Unity URP 曲面细分1 曲面细分与镶嵌1.1 外壳着色器 Hull Shader1.2 镶嵌器阶段 Tessellator1.3 域着色器阶段 Domain Shader2 具体实现2.2 不同的细分策略2.2.1 Flat Tessellation2.2.2 PN Tessellation2.2.3 Phone Tessellation…

Redis分布式锁的实现方式

目录一、分布式锁是什么1、获取锁2、释放锁二、代码实例上面代码存在锁误删问题&#xff1a;三、基于SETNX实现的分布式锁存在下面几个问题1、不可重入2、不可重试3、超时释放4、主从一致性四、Redisson实现分布式锁1、pom2、配置类3、测试类五、探索tryLock源码1、tryLock源码…

微软发布 Entity Framework EF Core 8 或 EF8

Entity Framework 现已被广泛使用&#xff0c;微软首席软件工程经理 Arthur Vickers 日前在一个在线社区会议上的发言。 Entity Framework Core 8.0&#xff08;也称为 EF Core 8 或 EF8&#xff09;的未来规划。EF Core 8 是 EF Core 7 之后的下一个版本&#xff0c;这将是一个…

链表的实现:无头单向非循环链表的实现

笔者在上篇博客书写了一个名为&#xff1a;链式存储之&#xff1a;链表的引出及其简介原文链接为&#xff1a;https://blog.csdn.net/weixin_64308540/article/details/128374876?spm1001.2014.3001.5501对于此篇博客&#xff0c;在一写出来&#xff0c;便引起了巨大反响&…

Golang 【basic_leaming】函数详解

阅读目录1、函数定义2、函数的调用3、函数参数4、函数返回值5、函数变量作用域全局变量局部变量6、函数类型与变量定义函数类型函数类型变量7、高阶函数函数作为参数函数作为返回值8、匿名函数和闭包匿名函数闭包闭包进阶示例1闭包进阶示例2闭包进阶示例39、defer 语句defer 执…

Windows-试用phpthink发现原来可这样快速搭建mysql、redis等环境、xdebug

一、前言 最近在简单学习 php 国人框架 phpthink&#xff0c;不得不说牛&#xff0c;我在 github 上既然搜不到此项目… 但是发现搭建依赖环境不会&#xff0c;于是百度一下&#xff0c;几乎都是各种集成工具什么宝塔、小皮面板等等。有固然是方便&#xff0c;但为什么其它语言…

DAY5 Recommended system cold startup problem

推荐系统的冷启动问题 推荐系统冷启动概念 ⽤户冷启动&#xff1a;如何为新⽤户做个性化推荐物品冷启动&#xff1a;如何将新物品推荐给⽤户&#xff08;协同过滤&#xff09;系统冷启动&#xff1a;⽤户冷启动物品冷启动本质是推荐系统依赖历史数据&#xff0c;没有历史数据⽆…