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

逃离我推掉我的手 2024-03-30 11:49 105阅读 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 的时候它就派上用场了

  1. 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

  1. 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)

  1. 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

  1. CommandInvoker

21a537b4c647e7f08309b9afbf9f21d5.png

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

b068627ebffbce903d4d23d4ac23874f.png

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

  1. 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(),流程继续执行,进入下一个活动节点

  1. CompleteTaskCmd

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

28e4b0d8f27b8c0bbc1534f1af652be3.png

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

0a89356e76e1b8e062f0d68ada9be50f.png

71256348047dcc649291b246b2c39d54.png

c5f064bece9f519459955130a1fc3e3d.png

  1. ActivityBehavior

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

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

30e9c92126c9e34904ad2c7b73f039df.png

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

f367bc9d67ecac4bc242c471a041e3dc.png

8f616ad2104c40f02a59f37fa3bf4087.png

  1. 回顾

Command:命令

ActivitiEngineAgendaFactory:用于创建ActivitiEngineAgenda

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

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

CommandContextFactory:用于创建CommandContext

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

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

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

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

a05754162c55d4509845ea4efb6ec9b9.png

发表评论

表情:
评论列表 (有 0 条评论,105人围观)

还没有评论,来说两句吧...

相关阅读

    相关 Activiti工作学习(一)

    工作流主要解决问题: 为了实现某个业务目标,利用计算机在多个参与者之间按某种预定规则自动传递文档、信息或者任务。 意义: 虽然工作流实现的功能也可以不用工作流就能

    相关 Activiti工作学习(五)

    前言 工作流中会带有参数跟着流程走,例如我们的请假例子,请假一定要有请假天数、请假原因和开始时间等参数,这些参数要跟着流程走让经理和老板看到你请假的具体信息。今天就讲这些