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

逃离我推掉我的手 2024-03-30 11:49 103阅读 0赞

1. 启动分析

源码版本是 7.1.0.M6

首先从 ProcessEngineAutoConfiguration 开始

> ![449fcefa272d7541c6b335e0af6c96bb.png][]

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

> ![881e1c8d319fc927013722473c895005.png][]

> ![c58724cbf5995f1216d3c2feae0ca265.png][]

主要是配置了自动部署

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

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

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

> ![a2938df5c5320b8d526317b99addccec.png][]

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

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

initAgendaFactory()

> ![d0d1b3466c4b96d4bddd3c2dfff6a498.png][]
> 
> ![3077b391597eecbea6ca67f5fd1c3a79.png][]

initCommandContextFactory()

> ![35588943d5b432e6501f4ea49b8c0324.png][]
> 
> ![a575d912d6ed843168f640742a1c5ee1.png][]

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

initCommandExecutors()

> ![20681a7a460f5af839945ec8d2f6fd33.png][]
> 
> ![06222d3b1f5304d299c57b11acc2b80d.png][]

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

> ![1d5b784036b22a182661fe11d8fe6a52.png][]

initServices()

> ![80a48bd2f8a61dcb61bf4e715eeb3239.png][]

initBehaviorFactory()

> ![fe7a4284dbaa0bdd659b0e9147e6f234.png][]

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

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

> ![86a25f1f75997144c3b383537bd15a36.png][]

2. CommandContextInterceptor

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

> ![3ef99f9e2cb88da7183cd095175591ea.png][]

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

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

> ![fe06587b0cd8b498254fc8ddba0a023b.png][]

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

那么，CommandContext中到底有什么呢？继续看

> ![eaeeb5dcf49ef16fdff749e93e1b19d2.png][]

CommandContext中有命令（Command）,还有agenda（ActivitiEngineAgenda）

3. Command

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

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

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

> ![559cbf041210b2d93ca95141a545ade1.png][]

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

![aa32099b48d092546ee8fb578b43550c.png][]

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

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

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

> ![3adae74198d077a504d000e5e2dfdc53.png][]

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

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

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

> ![63a599c878f115bfa0e5bbb59237eadd.png][]
> 
> ![608095b6abf92cfd4486b15cef5f84d8.png][]

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

4. CommandInvoker

![21a537b4c647e7f08309b9afbf9f21d5.png][]

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

> ![b068627ebffbce903d4d23d4ac23874f.png][]

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

5. Agenda

![33cf630204548ec05ac05183bca6de75.png][]

> ![5580bebc43ed94c27137f3c12f1f2f70.png][]

agenda （译：议程，待议事项，议事日程）的意思是“议程”，“会议议程”，“待议事项”

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

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

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

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

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

> ![83a22e502ed181063083d7aabdd1fa87.png][]

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

命令执行的结果放到会议室（CommandContext）

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

6. CompleteTaskCmd

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

> ![28e4b0d8f27b8c0bbc1534f1af652be3.png][]

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

> ![0a89356e76e1b8e062f0d68ada9be50f.png][]
> 
> ![71256348047dcc649291b246b2c39d54.png][]
> 
> ![c5f064bece9f519459955130a1fc3e3d.png][]

7. ActivityBehavior

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

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

![30e9c92126c9e34904ad2c7b73f039df.png][]

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

> ![f367bc9d67ecac4bc242c471a041e3dc.png][]
> 
> ![8f616ad2104c40f02a59f37fa3bf4087.png][]

8. 回顾

Command：命令

ActivitiEngineAgendaFactory：用于创建ActivitiEngineAgenda

ActivitiEngineAgenda：议程，待议事项，用于循环执行Operation

AbstractOperation：事项/操作，它实现了Runnable接口

CommandContextFactory：用于创建CommandContext

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

CommandExecutor：执行Command，从拦截器链的第一个拦截器开始执行

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

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

![a05754162c55d4509845ea4efb6ec9b9.png][]

[449fcefa272d7541c6b335e0af6c96bb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/7792e938ecde42d8b89bf6c79ad9992e.png
[881e1c8d319fc927013722473c895005.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/0acc05b48fc74e75b2075ba167905bf8.png
[c58724cbf5995f1216d3c2feae0ca265.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/e0d6d9c3202348c984463cc8f737224e.png
[a2938df5c5320b8d526317b99addccec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/0c21d58e30d5411e8615a6a34f2684a7.png
[d0d1b3466c4b96d4bddd3c2dfff6a498.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/90a057ff92204440a6545e3d2dff01b4.png
[3077b391597eecbea6ca67f5fd1c3a79.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/80fd20c7691e449298670b480cc592f6.png
[35588943d5b432e6501f4ea49b8c0324.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/8827577f3cf64f318248ee3d24c486f1.png
[a575d912d6ed843168f640742a1c5ee1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/409ee2c18b0140da9bd66e6bbd411bc5.png
[20681a7a460f5af839945ec8d2f6fd33.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/7d14fdfb4a7240d7adde7a767aefbf0c.png
[06222d3b1f5304d299c57b11acc2b80d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/33ef73df93f54aeb82b77c75010a4c29.png
[1d5b784036b22a182661fe11d8fe6a52.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/406710beef9b4fcf8cde9e0a5c4a5650.png
[80a48bd2f8a61dcb61bf4e715eeb3239.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ffca792fdc0f49c8b7f62061e2c8d306.png
[fe7a4284dbaa0bdd659b0e9147e6f234.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/1e7481e5750c4bb59da4bf52005dbf8c.png
[86a25f1f75997144c3b383537bd15a36.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/9f26c89bbde54a82aad2ac5174e64d34.png
[3ef99f9e2cb88da7183cd095175591ea.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/cc485b500d5c4253b13e9cc6ec66ceb1.png
[fe06587b0cd8b498254fc8ddba0a023b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/5f29330642f34216a3efd3647e87382b.png
[eaeeb5dcf49ef16fdff749e93e1b19d2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/f890c4858d6e4a3f941809103811e44f.png
[559cbf041210b2d93ca95141a545ade1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/192e0a9408984054bd7a302f1267eca0.png
[aa32099b48d092546ee8fb578b43550c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/5b4115d278bb491f9470305e19bca816.png
[3adae74198d077a504d000e5e2dfdc53.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/eec5ad0d987c48aca68fe5f55872ccc0.png
[63a599c878f115bfa0e5bbb59237eadd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/fafadf026e1441aaaa8fc8d73373dfa6.png
[608095b6abf92cfd4486b15cef5f84d8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/6f26b46ee52a4bb383c50cc2e1c12ded.png
[21a537b4c647e7f08309b9afbf9f21d5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/0b0b95e0e67346f28e13bc1e7aaf1e77.png
[b068627ebffbce903d4d23d4ac23874f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/620016c9e1e04a64b46120270b0d566c.png
[33cf630204548ec05ac05183bca6de75.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/8cbd18744acb41d089840b47b73996e2.png
[5580bebc43ed94c27137f3c12f1f2f70.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/b5841a19b89c4c4eb60124432017cc47.png
[83a22e502ed181063083d7aabdd1fa87.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/c97c4e1588aa41929c66ca1bb19ac842.png
[28e4b0d8f27b8c0bbc1534f1af652be3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/1c144888c07c4fc9a9f0e7ff6b159741.png
[0a89356e76e1b8e062f0d68ada9be50f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/a42f7c632ff646b9b669348c5bb6dd79.png
[71256348047dcc649291b246b2c39d54.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/17694c03c1fd45f19c07b6183111181b.png
[c5f064bece9f519459955130a1fc3e3d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/7eeeffa4a0eb4636a0cb8577f8f03056.png
[30e9c92126c9e34904ad2c7b73f039df.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/2ab02e3dddb0467491ed1cc4904522f2.png
[f367bc9d67ecac4bc242c471a041e3dc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/baed0cd674284fc3b825143d23dbcf85.png
[8f616ad2104c40f02a59f37fa3bf4087.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/dac694521e614b27b1b3bb675e3417ad.png
[a05754162c55d4509845ea4efb6ec9b9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/61ff6c71210246d988140fbab150112d.png