activiti 源码笔记之startProcess

简介:

 

rumtimeService.startProcessInstanceByXX方法将启动流程的任务委派给StartProcessInstanceCmd,此时会根据rumtimeService.startProcessInstanceByXX的XX来用不同的变量构造StartProcessInstanceCmd实例然后执行execute方法,StartProcessInstanceCmd的构造器如下.

(1) processDefinitionKey
         在bpmn20.xml中定义流程元素的id
       < process id ="loanReuqest" name ="Process to handle a loan request">
 
(2)processDefinitionId
        对应流程数据库中act_re_procdef中的主键
(3)businessKey
        关联的业务主键,用于自定义扩展,引擎本身没有用到.
 
(4)variables
        流程变量
 
execute的执行逻辑如下
(1) 根据processDefinitionKey或proceeDefinitionId在已发布的流程定义中查找,它是先查找缓冲中的流程定义然后再去数据库中查找以便提高效率,如果找不到或找到的流程定义被挂起将抛出运行时异常ActivitiException.
deploymentCache.findDeployedProcessDefinitionById?Key( processDefinitionId?Key);
(2)创建流程实例
ExecutionEntity processInstance = processDefinition.createProcessInstance(businessKey);
创建流程实例的过程是比较复杂的。
首先流程在创建时必须有一个类型为ActivityImpl的initial变量.
这里为了方便理解暂且可以把ActivityImpl理解为流程中的每个节点元素(除了任务外整个一个流程也可理解为一个节点)的抽象.
它有如下属性:
public  class ActivityImpl  extends ScopeImpl  implements PvmActivity, HasDIBounds {
 
   private  static  final  long serialVersionUID = 1L;
   protected List< TransitionImpl> outgoingTransitions =  new ArrayList<TransitionImpl>();
   protected Map<String, TransitionImpl> namedOutgoingTransitions =  new HashMap<String, TransitionImpl>();
   protected List< TransitionImpl> incomingTransitions =  new ArrayList<TransitionImpl>();
   protected ActivityBehavior activityBehavior;
   protected ScopeImpl parent;
   protected  boolean isScope ;
   protected  boolean isAsync ;
   protected  boolean isExclusive ;
 
  // Graphical information
   protected  int x = -1;
   protected  int y = -1;
   protected  int width = -1;
   protected  int height = -1;
 
...........................................
}
比较重要的属性包括此流程元素的进入、离开路径和此活动对应的行为(有了这些我们甚至可以在运行时改变流程的运转和行为),每种不同的流程元素都有不同的行为,actityBehavior实现了当流转到此节点时对应的处理逻辑.
 
创建流程时initial一般指各种开始事件,我这里单步调试时用了最简单的StartEvent,下面是它activitiBehavior类,
public  class NoneStartEventActivityBehavior  extends FlowNodeActivityBehavior {
 
  // Nothing to see here.
  // The default behaviour of the BpmnActivity is exactly what
  // a none start event should be doing.
}
它只是为了语义而定义的类,它没在父类FlowNodeActivityBehavior的基础上添加任何额外属性和方法.FlowNodeActivityBehavior是所有bpmn元素的超类,FlowNodeActivityBehavior的默认只是离开此节点,而不做任何额外处理.
ProcessDefinitionImpl的newProcessInstance是真正创建流程实例的地方,它使用下面这个以activityImpl为参数的构造器创建ExecutionEntity对象.这里和ProcessInstance的继承关系可以看到一个流程实例实际上也是一个执行实例,从逻辑上理解一个流程实例也就是一个可执行的路径.当然反过来说就不对了,执行实例不仅仅单指流程实例.
public ExecutionEntity(ActivityImpl activityImpl) {
     this. startingExecution =  new StartingExecution(activityImpl);
}
在创建流程后会在流程数据库中插入一条ExecutionEntity数据,在act_ru_execution表中可以看到这个execution的id和proc_inst_id的值是一样的
 
在完成流程实基本例化后,对此流程实例的变量再进行一些初始化
   processInstance.setProcessDefinition(  this);
  processInstance.setProcessInstance(processInstance);
  processInstance.initialize();
前两行代码的操作很简单,第三行的initialize方法又是有些复杂的.它负责设置流程的变量、任务、调度任务、订阅事件等,它这涉及到流程引擎的范围体系,需要另开文章好好分析.
(3)启动流程
processInstance.start();
 
public  void start() {
     if( startingExecution ==  null && isProcessInstanceType()) {
      startingExecution =  new StartingExecution(processDefinition .getInitial());
    }
    performOperation (AtomicOperation. PROCESS_START);
}
在activiti里一个动作都将对应一种行为,启动流程的动作将执行PROCESS_START的原子操作
   if(executionOperation.isAsync(  this )) {
      scheduleAtomicOperationAsync(executionOperation);
    }  else {
      performOperationSync(executionOperation);
    }   
如果是异步的就在调度线程池中拿到线程执行,否则就在当前线程内执行
 
以下是activiti原子操作的类型
 
 
 
AtomicOperationProcessStart做的事情不多,它只是触发了所有它范围内绑定的所有监听,这也是所有原子操作的基本默认行为

 

本文转自二郎三郎博客园博客,原文链接:http://www.cnblogs.com/haore147/p/5213413.html,如需转载请自行联系原作者
相关文章
|
缓存 NoSQL Java
Spring Boot如何优雅实现动态灵活可配置的高性能数据脱敏功能
在当下互联网高速发展的时代下,涉及到用户的隐私数据安全越发重要,一旦泄露将造成不可估量的后果。所以现在的业务系统开发中都会对用户隐私数据加密之后存储落库,同时还要求后端返回数据给前台之前进行数据脱敏。所谓脱敏处理其实就是将数据进行混淆隐藏,如将用户的手机号脱敏展示为`178****5939,采用 * 进行隐藏,以免泄露个人隐私信息
1535 0
|
XML SQL 数据库
Error getting generated key or setting result to parameter object.必须执行该语句才能获得结果。
Error getting generated key or setting result to parameter object.必须执行该语句才能获得结果。
3128 47
|
XML 关系型数据库 MySQL
【MySQL异常】ExecutorException: Error getting generated key or setting result to parameter object
【MySQL异常】ExecutorException: Error getting generated key or setting result to parameter object
860 0
|
人工智能 小程序 API
【最佳实践系列】阿里云百炼「音视频实时互动」功能上线:几分钟实现模型到应用!
阿里云百炼推出「音视频实时互动」功能,支持0代码搭建并集成到Web、iOS和安卓应用。用户可轻松创建AI应用并分享。具体步骤包括新建智能体应用、配置模型(如通义千问-VL)、编写提示词、设置API-KEY及发布应用。平台提供多种渠道支持,如API、网页、小程序等,帮助用户快速构建成熟的AI应用。欢迎体验并在评论区交流反馈。
706 0
|
10月前
|
人工智能 算法 计算机视觉
昇腾AI行业案例(三):基于 AI 图像处理的铝板缺陷检测
欢迎学习《基于 AI 图像处理的铝板缺陷检测》实验。在本实验中,你将深入了解如何运用计算机视觉(CV)领域的 AI 模型,搭建一个高效精准的铝板缺陷检测系统,并利用开源数据集和昇腾 AI 芯片对模型效果加以验证。
466 0
|
机器学习/深度学习 存储 人工智能
深度学习之不遗忘训练
基于深度学习的不遗忘训练(也称为抗遗忘训练或持久性学习)是针对模型在学习新任务时可能会忘记已学习内容的一种解决方案。该方法旨在使深度学习模型在不断接收新信息的同时,保持对旧知识的记忆。
308 4
Windows中如何查看被占用的端口、杀掉对应的进程
这篇文章介绍了在Windows系统中如何查看被占用的端口号以及如何杀掉占用端口的进程,包括使用命令提示符的`netstat -ano | findstr 端口号`命令查找进程PID,然后通过任务管理器或`taskkill /PID PID号`命令来结束进程。
Windows中如何查看被占用的端口、杀掉对应的进程
|
负载均衡 安全 网络虚拟化
CCE集群VPC网络模式下几种访问场景
【8月更文挑战第13天】在CCE(Cloud Container Engine)集群的VPC网络模式下,支持多样化的访问场景:容器应用可直接利用VPC访问外部资源;通过ELB负载均衡或VPN/专线配置,实现外部网络对容器应用的安全访问;容器间通过内部IP或服务发现机制相互通信;跨VPC访问则可通过VPC对等连接或云连接服务实现。这些方案确保了应用内外部通信的安全与高效。
571 3
|
存储 安全 数据安全/隐私保护
kali工具 -- setoolkit(克隆网站及利用)
kali工具 -- setoolkit(克隆网站及利用)
1118 1
|
机器学习/深度学习 测试技术 开发者
最新PyCharm下载安装以及Python环境搭建教程(含Python入门教程)
最新PyCharm下载安装以及Python环境搭建教程(含Python入门教程)
2390 1