全部标签
写点什么
学习MySQL开源云计算行业资讯算法Python人工智能区块链Linux前端个人成长面试架构师编程企业动态新基建敏捷安全读书笔记高效工作团队管理创业活动专区生涯规划知识管理运维产品经理 查看更多

不了解工作流框架 Activiti 中的流程事件？这篇工作流流程元素详解，带你详细分析工作流流程执行过程中的各种事件

用户头像
攻城狮Chova
关注
发布于: 2021 年 06 月 02 日
不了解工作流框架Activiti中的流程事件？这篇工作流流程元素详解，带你详细分析工作流流程执行过程中的各种事件

自定义扩展

  • BPMN 2.0 标准对于各方都是一个好东西

  • 用户不用担心会绑死在供应商提供的专有解决方案上

  • 框架,特别是 activiti 这样的开源框架,可以提供相同功能,甚至是更好的实现,足以和大的供应商媲美

  • 按照 BPMN 2.0 标准,从大供应商的解决方案迁移到 activiti 只要经过一个简单而平滑的过程

  • BPMN 2.0 标准不好的一点是

  • 它常常是不同公司之间大量讨论和妥协的结果

  • 作为开发者去阅读流程定义的 BPMN 2.0xml 时,有时会感觉用这种结构和方法去做事太麻烦了

  • 因此 activiti 把简化开发作为最优先的事情,使用一些被称为 Activiti BPMN 扩展的功能,这些扩展是新的结构或方法来简化对应的结构,并不属于 BPMN 2.0 规范

  • 根据 BPMN 2.0 标准开发自定义扩展的注意点:

  • 自定义扩展的前提是总有简单的方法转换成标准方法. 所以使用自定义扩展时,可以及时撤销自定义扩展

  • 当使用自定义扩展时 ,总会清楚的指明使用了新的 XML 元素,属性... 比如会使用 activiti:命名空间前缀

  • 扩展的目标是最终加入到下一版本的 BPMN 规范,或者至少可以引起对特定 BPMN 结构的讨论

事件

  • 事件用来表明流程的生命周期中发生了什么事. 事件总是画成一个圆圈

  • 在 BPMN 2.0 中,事件有两大分类:捕获(catching)事件 或触发(throwing)事件:

  • 捕获(catching): 当流程执行到事件,会等待被触发.触发的类型是由内部图表或 XML 中的类型声明来决定的.捕获事件与触发事件在显示方面是根据内部图表是否被填充来区分的(白色)

  • 触发(throwing): 当流程执行到事件,会触发一个事件.触发的类型是由内部图表或 XML 中的类型声明来决定的.触发事件与捕获事件在显示方面是根据内部图表是否被填充来区分的(黑色)

事件定义

  • 事件定义决定了事件的语义. 如果没有事件定义,这个事件就不做什么特别的事情.没有设置事件定义的开始事件不会在启动流程时做任何事情

  • 如果给开始事件添加了一个事件定义(比如定时器事件定义)我们就声明了开始流程的事件类型(这时定时器事件监听器会在某个时间被触发)

定时器事件定义

  • 定时器事件是根据指定的时间触发的事件

  • 定时器事件可以用于开始事件,中间事件和边界事件

  • ==定时器定义元素:==

  • timeDate: 触发事件的时间. 使用 ISO8601 格式指定的一个确定的时间:


<timerEventDefinition>    <timeDate>2011-03-11T12:13:14</timeDate></timerEventDefinition>
复制代码


  • timeDuration: 指定定时器之前要等待多长时间. timeDuration 可以设置为 timerEventDefinition 的子元素,使用 ISO8601 规定的格式


<timerEventDefinition>  <!--等待10天-->    <timeDuration>P10D</timeDuration></timerEventDefinition>
复制代码


  • timeCycle: 指定重复执行的间隔. 可以用来定期启动流程实例,或为超时时间发送多个提醒.timeCycle 元素可以使用两种格式:

  • ISO8601 标准的格式

  • cron 表达式


<timerEventDefinition>  <!--重复3次，每次间隔10小时-->    <timeCycle>R3/PT10H</timeCycle></timerEventDefinition>
复制代码


  • 从整点开始,每 5 分钟执行一次:


0 0/5 * * * ?
复制代码


  • ==注意:==

  • 第一个数字表示秒, 而不是像通常 Unix cron 中那样表示分钟

  • 重复的时间周期能更好的处理相对时间, 可以计算一些特定的时间点:用户任务的开始时间

  • cron 表达式可以处理绝对时间, 这对定时启动事件特别有用

  • 在定时器事件定义中使用表达式,可以通过流程变量来影响那个定时器定义: 流程定义必须包含 ISO8601(或者 cron)格式的字符串,以匹配对应的时间类型


  <boundaryEvent id="escalationTimer" cancelActivity="true" attachedToRef="firstLineSupport">     <timerEventDefinition>        <timeDuration>${duration}</timeDuration>     </timerEventDefinition>  </boundaryEvent>
复制代码


只有启用 job 执行器之后,定时器才会被触发.activiti.cfg.xml 中的 jobExecutorActivate 需要设置为 true, 默认 job 执行器是关闭的

错误事件定义

  • 错误事件是由指定错误触发的

  • ==注意:==

  • BPMN 错误与 Java 异常完全不一样:

  • BPMN 错误事件是为了对业务异常建模

  • Java 异常是要用特定方式处理

  • 错误事件定义会引用一个 error 元素,引用相同 error 元素的错误事件处理器会捕获这个错误


<endEvent id="myErrorEndEvent">  <!--引用一个错误声明-->  <errorEventDefinition errorRef="myError" /></endEvent>
复制代码

信号事件定义

  • 信号事件会引用一个已命名的信号

  • 信号全局范围的事件(广播语义).会发送给所有激活的处理器

  • 信号事件定义使用 signalEventDefinition 元素 .signalRef 属性会引用 definitions 根节点里定义的 signal 子元素(signalEventDefinition 引用相同的 signal 元素)


<!--流程实例,其中会抛出一个信号,并被中间事件捕获--><definitions... >        <!-- declaration of the signal -->        <signal id="alertSignal" name="alert" />
        <process id="catchSignal">                <intermediateThrowEvent id="throwSignalEvent" name="Alert">                        <!-- signal event definition -->                        <signalEventDefinition signalRef="alertSignal" />                </intermediateThrowEvent>                ...                <intermediateCatchEvent id="catchSignalEvent" name="On Alert">                        <!-- signal event definition -->                        <signalEventDefinition signalRef="alertSignal" />                </intermediateCatchEvent>                ...        </process></definitions>
复制代码
触发信号事件

  • 可以通过 bpmn 节点由流程实例触发一个信号.也可以通过 API 触发

  • org.activiti.engine.RuntimeService 中的方法可以用来手工触发一个信号:


RuntimeService.signalEventReceived(String signalName);RuntimeService.signalEventReceived(String signalName, String executionId);
复制代码


  • signalEventReceived(String signalName): 把信号发送给全局所有订阅的处理(广播语义)

  • signalEventReceived(String signalName, String executionId): 把信号发送给指定的执行

捕获信号事件

  • 信号事件可以被中间信号事件或边界信息事件捕获

查询信号事件的订阅

  • 查询所有订阅特定信号事件的执行


 List<Execution> executions = runtimeService.createExecutionQuery()      .signalEventSubscriptionName("alert")      .list();
复制代码


  • 使用 signalEventReceived(String signalName, String executionId) 把信号发送给这些执行

信号事件范围

  • 默认情况下,信号会在流程引擎范围内进行广播: 在一个流程实例中抛出一个信号事件,其他不同流程定义的流程实例都可以监听到这个事件

  • 有时只要在同一个流程实例中响应这个信号事件:流程实例中的同步机制,如果两个或更多活动是互斥的

  • 要想限制信号事件的范围, 可以使用信号事件定义的 scope 属性:


<signal id="alertSignal" name="alert" activiti:scope"processInstance"/>
复制代码


默认情况下,scope 的属性为 global

信号事件实例

  • 不同流程使用信号交互:

  • 流程在保险规则更新或改变时启动.在修改被参与者处理时,会触发一个信号,通知规则改变:

  • 这个事件会被所有相关的流程实例捕获

  • 订阅这个事件的流程实例:

  • 信号事件是广播给所有激活的处理器的

  • 在上面的例子中,所有流程实例都会接收到这个事件,这就是我们想要的.

  • 然而,有的情况下并不想要这种广播行为,考虑下面的流程:

  • 上述流程描述的模式 activiti 并不支持.这种想法是:

  • 执行[do something]任务时出现的错误

  • 被边界错误事件捕获

  • 然后使用信号传播给并发路径上的分支

  • 进而中断[do something inparallel]任务

  • 目前,activiti 实际运行的结果与期望一致.信号会传播给边界事件并中断任务.但是,根据信号的广播含义,也会传播给所有其他订阅了信号事件的流程实例.所以,这就不是我们想要的结果

  • ==注意:==

  • 信号事件不会执行任何与特定流程实例的联系

  • 如果只想把一个信息发给指定的流程实例,需要手工关联,再使用 signalEventReceived(String signalName, String executionId) 和对应的查询机制

消息事件定义

  • 消息事件会引用一个命名的消息,每个消息都有名称和内容

  • 消息事件总会直接发送给一个接受者

  • 消息事件定义使用 messageEventDefinition 元素.messageRef 属性引用了 definitions 根节点下的一个 message 子元素:


<!--使用两个消息事件的流程例子,开始事件和中间捕获事件分别声明和引用了两个消息事件--><definitions id="definitions"  xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"  xmlns:activiti="http://activiti.org/bpmn"  targetNamespace="Examples"  xmlns:tns="Examples">
  <message id="newInvoice" name="newInvoiceMessage" />  <message id="payment" name="paymentMessage" />
  <process id="invoiceProcess">
    <startEvent id="messageStart" >        <messageEventDefinition messageRef="newInvoice" />    </startEvent>    ...    <intermediateCatchEvent id="paymentEvt" >        <messageEventDefinition messageRef="payment" />    </intermediateCatchEvent>    ...  </process>
</definitions>
复制代码
触发消息事件

  • 作为一个嵌入式的流程引擎,activiti 不能真正接收一个消息

  • 这些环境相关,与平台相关的活动:比如连接到 JMS(Java 消息服务)队列或主题或执行 WebService 或 REST 请求. 这个消息的接收是你要在应用或架构的一层实现的,流程引擎则内嵌其中

  • 在应用接收一个消息之后,必须决定如何处理它:

  • 如果消息应该触发启动一个新流程实例,在下面的 RuntimeService 的两个方法中选择一个执行:


ProcessInstance startProcessInstanceByMessage(String messageName);ProcessInstance startProcessInstanceByMessage(String messageName, Map<String, Object> processVariables);ProcessInstance startProcessInstanceByMessage(String messageName, String businessKey, Map<String, Object> processVariables);
复制代码


这些方法允许使用对应的消息系统流程实例


  • 如果消息需要被运行中的流程实例处理:

  • 首先要根据消息找到对应的流程实例

  • 然后触发这个等待中的流程

  • RuntimeService 提供了可以基于消息事件的订阅来触发流程继续执行:


void messageEventReceived(String messageName, String executionId);void messageEventReceived(String messageName, String executionId, HashMap<String, Object> processVariables);
复制代码
查询消息事件订阅

  • Activiti 支持开始消息事件和中间消息事件

  • 消息开始事件: 消息事件订阅分配给一个特定的 process definition. 这个消息订阅可以使用 ProcessDefinitionQuery 查询到


ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()      .messageEventSubscription("newCallCenterBooking")      .singleResult();
复制代码


因为同时只能有一个流程定义关联到消息的订阅点,查询总是返回 0 或一个结果.如果流程定义更新了,那么只有最新版本的流程定义会订阅到消息事件上


  • 中间捕获消息事件: 消息事件订阅会分配给特定的执行,这个消息事件订阅可以使用 ExecutionQuery 查询到:


Execution execution = runtimeService.createExecutionQuery()      .messageEventSubscriptionName("paymentReceived")      .variableValueEquals("orderId", message.getOrderId())      .singleResult();
复制代码


这个查询可以调用对应的查询,通常是流程相关的信息 :最多只能有一个流程实例对应着 orderId

消息事件实例

  • 使用两个不同消息启动的流程实例:

  • 消息事件可以用于流程需要不同的方式来区分开始事件时,最终会进入同样的路径

开始事件

  • 开始事件用来指明流程在哪里开始

  • 开始事件的类型(流程在接收事件时启动,还是在指定时间启动...),定义了流程如何启动, 这通过事件中不同的小图表来展示.在 XML 中,这些类型是通过声明不同的子元素来区分

  • 开始事件都是捕获事件: 最终这些事件都是一直等待着,直到对应的触发时机出现

  • 在开始事件中,可以设置 activiti 特定属性:

  • initiator: 当流程启动时,把当前登录的用户保存到指定的变量名中:


  <startEvent id="request" activiti:initiator="initiator" />
复制代码


  • 登录的用户必须使用 IdentityService.setAuthenticatedUserId(String) 方法设置,并包含在 try-finally 代码中:


  try {  identityService.setAuthenticatedUserId("bono");  runtimeService.startProcessInstanceByKey("someProcessKey");} finally {  identityService.setAuthenticatedUserId(null);}
复制代码

空开始事件

描述

  • 空开始事件技术上意味着没有指定启动流程实例的触发条件

  • 引擎不能预计什么时候流程实例会启动

  • 空开始事件用于: 当流程实例要通过 API 启动的场景,通过调用 startProcessInstanceByXXX 方法

  • 子流程都有一个空开始事件


ProcessInstance processInstance = runtimeService.startProcessInstanceByXXX();
复制代码
图形标记

  • 空开始事件显示成一个圆圈.没有内部图表,即没有触发类型

XML 结构

  • 空开始事件的 XML 结构是普通的开始事件定义 ,没有任何子元素

  • 其他开始事件类型都有一个子元素来声明自己的类型


<startEvent id="start" name="my start event" />
复制代码
空开始事件的自定义扩展

  • formKey: 引用用户在启动新流程实例时需要填写的表单模板


<startEvent id="request" activiti:formKey="org/activiti/examples/taskforms/request.form" />
复制代码

定时开始事件

描述

  • 定时开始事件用来在指定的时间创建流程实例: 可以同时用于只启动一次的流程和应该在特定时间间隔启动多次的流程

  • ==注意:==

  • 子流程不能使用定时开始事件

  • 定时开始事件在流程发布后就会开始计算时间

  • 不需要调用 startProcessInstanceByXXX, 虽然也可以调用启动流程的方法,但是那会导致调用 startProcessInstanceByXXX 时启动过多的流程

  • 当包含定时开始事件的新版本流程部署时, 对应的上一个定时器就会被删除. 这是因为通常不希望自动启动旧版本流程的流程实例

图形标记

  • 定时开始事件显示为一个圆圈,内部是一个表:

XML 内容

  • 定时开始事件的 XML 内容是普通开始事件的声明**,包含一个定时定义子元素**


    <startEvent id="theStart">            <timerEventDefinition>              <!--流程会启动4次,每次间隔5分钟,从2011年3月11日,12:13开始计时-->                <timeCycle>R4/2011-03-11T12:13/PT5M</timeCycle>            </timerEventDefinition>        </startEvent>
复制代码


    <startEvent id="theStart">            <timerEventDefinition>              <!--流程会根据选中的时间启动一次-->                <timeDate>2011-03-11T12:13:14</timeDate>            </timerEventDefinition>        </startEvent>
复制代码

消息开始事件

描述

  • 消息开始事件可以使用一个命名的消息来启动流程实例,这样可以使用消息名称来选择正确的开始事件

  • 在发布包含一个或多个消息开始事件的流程定义时:

  • 消息开始事件的名称在给定流程定义中不能重复:

  • 流程定义不能包含多个名称相同的消息开始事件

  • 如果两个或以上消息开始事件应用了相同的事件

  • 或两个或以上消息事件引用的消息名称相同

  • activiti 会在发布流程定义时抛出异常

  • 消息开始事件的名称在所有已发布的流程定义中不能重复:

  • 如果一个或多个消息开始事件引用了相同名称的消息

  • 而这个消息开始事件已经部署到不同的流程定义中

  • activiti 就会在发布时抛出一个异常

  • 在发布新版本的流程定义时,之前订阅的消息订阅会被取消:

  • 如果新版本中没有消息事件也会这样处理

  • 启动流程实例,消息开始事件可以使用 RuntimeService 中的方法来触发:


ProcessInstance startProcessInstanceByMessage(String messageName);ProcessInstance startProcessInstanceByMessage(String messageName, Map<String, Object> processVariables);ProcessInstance startProcessInstanceByMessage(String messageName, String businessKey, Map<String, Object< processVariables);
复制代码


  • 这里的 messageName 是 messageEventDefinition 的 messageRef 属性引用的 message 元素的 name 属性

  • 启动流程实例时,要考虑以下因素:

  • 消息开始事件只支持顶级流程,消息开始事件不支持内嵌子流程

  • 如果流程定义有多个消息开始事件, runtimeService.startProcessInstanceByMessage(...) 会选择对应的开始事件

  • 如果流程定义有多个消息开始事件和一个空开始事件. runtimeService.startProcessInstanceByKey(...)和 runtimeService.startProcessInstanceById(...)会使用空开始事件启动流程实例

  • 如果流程定义有多个消息开始事件,但是没有空开始事件, runtimeService.startProcessInstanceByKey(...)和 runtimeService.startProcessInstanceById(...)会抛出异常

  • 如果流程定义只有一个消息开始事件, runtimeService.startProcessInstanceByKey(...)和 runtimeService.startProcessInstanceById(...)会使用这个消息开始事件启动流程实例

  • 如果流程被调用环节(callActivity)启动,消息开始事件只支持如下情况:

  • 在消息开始事件以外,还有一个单独的空开始事件

  • 流程只有一个消息开始事件,没有空开始事件

图形标记

  • 消息开始事件是一个圆圈,中间是一个消息事件图标.图标是白色未填充的,来表示捕获(接收)行为

XML 内容

  • 消息开始事件的 XML 内容在普通开始事件中,包含一个 messageEventDefinition 子元素:


<definitions id="definitions"  xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"  xmlns:activiti="http://activiti.org/bpmn"  targetNamespace="Examples"  xmlns:tns="Examples">
  <message id="newInvoice" name="newInvoiceMessage" />
  <process id="invoiceProcess">
    <startEvent id="messageStart" >        <messageEventDefinition messageRef="tns:newInvoice" />    </startEvent>    ...  </process>
</definitions>
复制代码

信号开始事件

描述

  • 信号开始事件可以通过一个已命名的信号(signal)来启动一个流程实例

  • 信号可以在流程实例内部使用中间信号抛出事务触发

  • 也可以通过 API(runtimService.signalEventReceivedXXX)触发

  • 两种情况下,所有流程实例中拥有相同名称的 signalStartEvent 都会启动

  • 两种情况下,都可以选择同步或异步的方式启动流程实例

  • 必须向 API 传入 signalName, 这是 signal 元素的 name 属性值,它会被 signalEventDefinition 的 signalRef 属性引用

图形标记

  • 信号开始事件显示为一个中间包含信号事件图标的圆圈.标记是无填充的,表示捕获(接收)行为

XML 格式

  • signalStartEvent 的 XML 格式是标准的 startEvent 声明,其中包含一个 signalEventDefinition 子元素


 <signal id="theSignal" name="The Signal" />
    <process id="processWithSignalStart1">        <startEvent id="theStart">          <signalEventDefinition id="theSignalEventDefinition" signalRef="theSignal"  />        </startEvent>        <sequenceFlow id="flow1" sourceRef="theStart" targetRef="theTask" />        <userTask id="theTask" name="Task in process A" />        <sequenceFlow id="flow2" sourceRef="theTask" targetRef="theEnd" />        <endEvent id="theEnd" />    </process>
复制代码

错误开始事件

描述

  • 错误开始事件可以用来触发一个事件子流程.错误开始事件不能用来启动流程实例

  • 错误开始事件都是中断事件

图形标记

  • 错误开始事件是一个圆圈,包含一个错误事件标记.标记是白色未填充的,来表示捕获(接收)行为

XML 内容

  • 错误开始事件的 XML 内容是普通开始事件定义中,包含一个 errorEventDefinition 子元素


<startEvent id="messageStart" >        <errorEventDefinition errorRef="someError" /></startEvent>
复制代码

结束事件

  • 结束事件表示(子)流程(分支)的结束

  • 结束事件都是触发事件:

  • 流程达到结束事件,会触发一个结果

  • 结果的类型是通过事件的内部黑色图标表示的

  • 在 XML 内容中,通过包含的子元素声明

空结束事件

描述

  • 空结束事件意味着到达事件时不会指定抛出的结果

  • 引擎会直接结束当前执行的分支,不会做其他事情

图形标记

  • 空结束事件是一个粗边圆圈, 内部没有小图标(无结果类型)

XML 内容

  • 空结束事件的 XML 内容是普通结束事件定义

  • 不包含子元素,其他结束事件类型都会包含声明类型的子元素


<endEvent id="end" name="my end event" />
复制代码

错误结束事件

描述

  • 当流程执行到错误结束事件 ,流程的当前分支就会结束,并抛出一个错误

  • 这个错误可以被对应的中间边界错误事件捕获.如果找不到匹配的边界错误事件,就会抛出一个异常

图形标记

  • 错误结束事件是一个标准的结束事件 -粗边圆圈, 内部有错误图标, 错误图标是全黑的,表示触发语法

XML 内容

  • 错误结束事件的内容是一个错误事件, 子元素为 errorEventDefinition


<endEvent id="myErrorEndEvent">  <errorEventDefinition errorRef="myError" /></endEvent>
复制代码


  • errorRef 属性引用定义在流程外部的 error 元素:


<error id="myError" errorCode="123" />...<process id="myProcess">...
复制代码


  • error 的 errorCode 用来查找匹配的捕获边界错误事件

  • 如果 errorRef 与任何 error 都不匹配,就会使用 errorRef 来作为 errorCode 的缩写. 这是 activiti 特定的缩写:


<error id="myError" errorCode="error123" />...<process id="myProcess">...  <endEvent id="myErrorEndEvent">    <errorEventDefinition errorRef="myError" />  </endEvent>
复制代码


等同于


<endEvent id="myErrorEndEvent">  <errorEventDefinition errorRef="error123" /></endEvent>
复制代码


  • 注意 errorRef 必须与 BPMN 2.0 格式相符,必须是一个合法的 QName

取消结束事件

描述

  • 取消结束事件只能与 BPMN 事务子流程结合使用

  • 当到达取消结束事件时,会抛出取消事件 ,它必须被取消边界事件捕获

  • 取消边界事件会取消事务，并触发补偿机制

图形标记

  • 取消结束事件显示为标准的结束事件-粗边圆圈,包含一个取消图标.取消图标是全黑的,表示触发语法

XML 内容

  • 取消结束事件内容是一个结束事件, 包含 cancelEventDefinition 子元素


<endEvent id="myCancelEndEvent">  <cancelEventDefinition /></endEvent>
复制代码

边界事件

  • 边界事件都是捕获事件,它会附在一个环节上

  • 边界事件是捕获事件,不可能触发事件:

  • 当节点运行时,事件会监听对应的触发类型

  • 当事件被捕获,节点就会中断,同时执行事件的后续连线

  • 边界事件的定义方式都一样:


<boundaryEvent id="myBoundaryEvent" attachedToRef="theActivity">      <XXXEventDefinition/></boundaryEvent>
复制代码


  • 边界事件使用如下方式进行定义:

  • 唯一标识:流程范围

  • 使用 caught 属性引用事件的节点,注意边界事件和它们附加的节点在同一级别上:比如,边界事件不是包含在节点内的

  • 格式为 XXXEventDefinition 的 XML 子元素 (比如,TimerEventDefinition，ErrorEventDefinition...)定义了边界事件的类型

定时边界事件

描述

  • 定时边界事件就是一个暂停等待警告的时钟

  • 当流程执行到绑定了边界事件的环节,会启动一个定时器

  • 当定时器触发时(一定时间之内),环节就会中断,并沿着定时边界事件的外出连线继续执行

图形标记

  • 定时边界事件是一个标准的边界事件(边界上的一个圆圈),内部是一个定时器小图标

XML 内容

  • 定时器边界任务定义是一个标准的边界事件,指定类型的子元素是 timerEventDefinition 元素


<boundaryEvent id="escalationTimer" cancelActivity="true" attachedToRef="firstLineSupport">   <timerEventDefinition>    <timeDuration>PT4H</timeDuration>  </timerEventDefinition></boundaryEvent>
复制代码


  • 在流程图中,圆圈边线是虚线:

  • 经典应用场景: 发送通知邮件,但是不打断正常流程的执行

  • 中断和非中断的事件还是有区别的

  • 默认是中断事件

  • 非中断事件的情况,不会中断原始环节,那个环节还停留在原地

  • 对应的,会创建一个新分支,并沿着事件的流向继续执行.在 XML 内容中,要把 cancelActivity 属性设置为 false


    <boundaryEvent id="escalationTimer" cancelActivity="false" attachedToRef="firstLineSupport"/>
复制代码


  • ==注意:== 边界定时事件只能在 job 执行器启用时使用

  • 比如:把 activiti.cfg.xml 中的 jobExecutorActivate 设置为 true,默认 job 执行器是禁用的

边界事件的问题

  • 同步问题: 边界事件后面不能有多条外出连线

  • 解决这个问题的方法是在一个连线后使用并发网关

错误边界事件

描述

  • 错误边界事件: 节点边界上的中间捕获错误事件,会捕获节点范围内抛出的错误

  • 定义一个边界错误事件,大多用于内嵌子流程或者调用节点

  • 对于子流程的情况,它会为所有内部的节点创建一个作用范围

  • 错误是由错误结束事件抛出的.这个错误会传递给上层作用域,直到找到一个错误事件定义相匹配的边界错误事件

  • 当捕获了错误事件时 ,边界任务绑定的节点就会销毁,也会销毁内部所有的执行分支(同步节点,内嵌子流程...).流程执行会继续沿着边界事件的外出连线继续执行

图形标记

  • 错误边界事件显示成一个普通的中间事件(圆圈内部有一个小圆圈)放在节点的标记上,内部有一个错误小图标.错误小图标是白色的,表示它是一个捕获事件

XML 内容

  • 边界错误事件定义为普通的边界事件:


<boundaryEvent id="catchError" attachedToRef="mySubProcess">  <errorEventDefinition errorRef="myError"/></boundaryEvent>
复制代码


  • 和错误结束事件一样 ,errorRef 引用了 process 元素外部的一个错误定义


<error id="myError" errorCode="123" />...<process id="myProcess">...
复制代码


  • errorCode 用来匹配捕获的错误:

  • 如果没有设置 errorRef,边界错误事件会捕获所有错误事件,无论错误的 errorCode 是什么

  • 如果设置了 errorRef,并引用了一个已存在的错误,边界事件就只捕获错误代码与之相同的错误

  • 如果设置了 errorRef,但是 BPMN 2.0 中没有定义错误,errorRef 就会当做 errorCode 使用

错误边界事件实例

  • 如何使用错误结束事件的流程实例

  • 当完成审核盈利这个用户任务时,如果没有提供足够的信息,就会抛出错误

  • 错误会被子流程的边界任务捕获,所有回顾销售子流程中的所有节点都会销毁,即使审核客户比率还没有完成,并创建一个提供更多信息的用户任务

信号边界事件

描述

  • 节点边界的中间捕获信号,会捕获信号定义引用的相同信号名的信号

  • 与其他事件(比如边界错误事件)不同,边界信号事件不只捕获绑定方位的信号.信号事件是一个全局的范围(广播语义),就是说信号可以在任何地方触发,即便是不同的流程实例

  • 和其他事件(比如边界错误事件)不同 ,捕获信号后,不会停止信号的传播. 如果有两个信号边界事件,捕获相同的信号事件,两个边界事件都会被触发,即使在不同的流程实例中

图形标记

  • 边界信号事件显示为普通的中间事件(圆圈里有个小圆圈),位置在节点的边缘, 内部有一个信号小图标.信号图标是白色的(未填充),表示捕获的意思

XML 内容

  • 边界信号事件定义为普通的边界事件:


<boundaryEvent id="boundary" attachedToRef="task" cancelActivity="true">          <signalEventDefinition signalRef="alertSignal"/></boundaryEvent>
复制代码

消息边界事件

描述

  • 节点边界上的中间捕获消息, 根据引用的消息定义捕获相同消息名称的消息

图形标记

  • 边界消息事件显示成一个普通的中间事件(圆圈里有个小圆圈),位于节点边缘,内部是一个消息小图标.消息图标是白色(无填充),表示捕获的意思

  • ==注意:== 边界消息事件可能是非中断(左侧) 或者中断(右侧) 的

XML 内容

  • 边界消息事件定义为标准的边界事件


<boundaryEvent id="boundary" attachedToRef="task" cancelActivity="true">          <messageEventDefinition messageRef="newCustomerMessage"/></boundaryEvent>
复制代码

取消边界事件

描述

  • 在事务性子流程的边界上的中间捕获取消

  • 事务取消时触发,当取消边界事件触发时:

  • 首先中断当前作用域的所有执行

  • 然后开始补偿事务内的所有激活的补偿边界事件.补偿是同步执行的:离开事务前,边界事务会等待补偿执行完毕

  • 当补偿完成后,事务子流程会沿着取消边界事务的外出连线继续执行

  • ==注意:==

  • 每个事务子流程只能有一个取消边界事件

  • 如果事务子流程包含内嵌子流程,补偿只会触发已经成功完成的子流程

  • 如果取消边界子流程对应的事务子流程配置为多实例,如果一个实例触发了取消,就会取消所有实例

图形标记

  • 取消边界事件显示为了一个普通的中间事件(圆圈里套小圆圈),在节点的边缘,内部是一个取消小图标.取消图标是白色(无填充),表明是捕获的意思

XML 内容

  • 取消边界事件定义为普通边界事件


<boundaryEvent id="boundary" attachedToRef="transaction" >          <cancelEventDefinition /></boundaryEvent>
复制代码


  • 取消边界事件都是中断的,不需要使用 cancelActivity 属性

补偿边界事件

描述

  • 节点边界的中间捕获补偿

  • 用来设置一个节点的补偿处理器

  • 补偿边界事件必须使用直接引用设置唯一的补偿处理器

  • 补偿边界事件与其他边界事件的策略不同:

  • 其他边界事件(信号边界事件)当到达关联的节点就会被激活.离开节点时,就会挂起,对应的事件订阅也会取消

  • 补偿边界事件在关联的节点成功完成时激活,当补偿事件触发或对应流程实例结束时,事件订阅才会删除

  • 补偿边界事件遵循如下规则:

  • 补偿触发时,补偿边界事件对应的补偿处理器会调用相同次数,根据它对应的节点的成功次数

  • 如果补偿边界事件关联到多实例节点,补偿事件会订阅每个实例

  • 如果补偿边界事件关联的节点中包含循环,补偿事件会在每次节点执行时进行订阅

  • 如果流程实例结束,订阅的补偿事件都会结束

  • 补偿边界事件不支持内嵌子流程

图形标记

  • 补偿边界事件显示为标准中间事件(圆圈里套圆圈),位于节点边缘,内部有一个补偿小图标.补偿图标是白色的(无填充),表示捕获的意思

  • 下图演示使用无方向的关联,为边界事件设置补偿处理器:

XML 内容

  • 补偿边界事件定义为标准边界事件


<boundaryEvent id="compensateBookHotelEvt" attachedToRef="bookHotel" >          <compensateEventDefinition /></boundaryEvent>
<association associationDirection="One" id="a1"  sourceRef="compensateBookHotelEvt" targetRef="undoBookHotel" />
<serviceTask id="undoBookHotel" isForCompensation="true" activiti:class="..." />
复制代码


  • 补偿边界事件在节点成功完成后激活, 不支持 cancelActivity 属性

中间捕获事件

  • 所有中间捕获事件都使用同样的方式定义:


<intermediateCatchEvent id="myIntermediateCatchEvent" >      <XXXEventDefinition/></intermediateCatchEvent>
复制代码


  • 中间捕获事件的定义:

  • 唯一标识(流程范围内)

  • 一个结构为 XXXEventDefinition 的 XML 子元素(TimerEventDefinition)定义了中间捕获事件的类型

定时中间捕获事件

描述

  • 定时中间事件作为一个监听器

  • 当执行到达捕获事件节点,就会启动一个定时器.当定时器触发(比如,一段时间之后),流程就会沿着定时中间事件的外出节点继续执行

图形标记

  • 定时器中间事件显示成标准中间捕获事件, 内部是一个定时器小图标:

XML 内容

  • 定时器中间事件定义为标准中间捕获事件. 指定类型的子元素为 timerEventDefinition 元素


    <intermediateCatchEvent id="timer">            <timerEventDefinition>                <timeDuration>PT5M</timeDuration>            </timerEventDefinition>        </intermediateCatchEvent>
复制代码

信号中间捕获事件

  • 中间捕获信号事件,通过引用信号定义来捕获相同信号名称的信号

  • 信号中间捕获事件与其它事件(比如错误事件)不同:

  • 信号不会在捕获之后被消费

  • 如果有两个激活的信号边界事件捕获相同的信号事件,两个边界事件都会被触发,即便在不同的流程实例中

图形标记

  • 中间信号捕获事件显示为一个普通的中间事件(圆圈套圆圈),内部有一个信号小图标.信号小图标是白色的(无填充),表示捕获的意思

XML 内容

  • 信号中间事件定义为普通的中间捕获事件. 对应类型的子元素是 signalEventDefinition 元素


<intermediateCatchEvent id="signal">        <signalEventDefinition signalRef="newCustomerSignal" /></intermediateCatchEvent>
复制代码

消息中间捕获事件

描述

  • 中间捕获消息事件,捕获特定名称的消息

图形标记

  • 中间捕获消息事件显示为普通中间事件(圆圈套圆圈),内部是一个消息小图标.消息图标是白色的(无填充),表示捕获的意思

XML 内容

  • 消息中间事件定义为标准中间捕获事件. 指定类型的子元素是 messageEventDefinition 元素


<intermediateCatchEvent id="message">        <messageEventDefinition signalRef="newCustomerMessage" /></intermediateCatchEvent>
复制代码

内部触发事件

  • 所有内部触发事件的定义都是一样的:


<intermediateThrowEvent id="myIntermediateThrowEvent" >      <XXXEventDefinition/></intermediateThrowEvent>
复制代码


  • 内部触发事件定义包含:

  • 唯一标识(流程范围)

  • 使用格式为 XXXEventDefinition 的 XML 子元素(比如 signalEventDefinition 等)定义中间触发事件的类型

中间触发空事件

  • 空中间触发事件流程图,用于表示流程中的某个状态

  • 可以添加执行监听器:


<intermediateThrowEvent id="noneEvent">  <extensionElements>    <activiti:executionListener class="org.activiti.engine.test.bpmn.event.IntermediateNoneEventTest$MyExecutionListener" event="start" />  </extensionElements></intermediateThrowEvent>
复制代码


  • 可以添加自己的代码,把事件发送给 BAM 工具或 DWH.引擎不会为这个事件做任何事情,它直接径直通过

信号中间触发事件

描述

  • 信号中间触发事件为定义的信号抛出一个信号事件

  • 在 activiti 中,信号会广播到所有激活的处理器中.信号可以通过同步和异步方式发布

  • 默认配置下,信号是同步发送的:

  • 抛出事件的流程实例会等到信号发送给所有捕获流程实例才继续执行

  • 捕获流程实例也会在触发流程实例的同一个事务中执行

  • 如果某个监听流程出现了技术问题(抛出异常),所有相关的实例都会失败

  • 信号也可以异步发送:

  • 会在到达抛出信号事件后决定哪些处理器是激活的

  • 对这些激活的处理器,会保存一个异步提醒消息(任务),并发送给 jobExecutor

图形标记

  • 中间信号触发事件显示为普通中间事件(圆圈套圆圈),内部又一个信号小图标,信号图标是黑色的(有填充),表示触发的意思

XML 内容

  • 消息中间事件定义为标准中间触发事件. 指定类型的子元素是 signalEventDefinition 元素


<intermediateThrowEvent id="signal">        <signalEventDefinition signalRef="newCustomerSignal" /></intermediateThrowEvent>
复制代码


  • 异步信号事件如下:


<intermediateThrowEvent id="signal">        <signalEventDefinition signalRef="newCustomerSignal" activiti:async="true" /></intermediateThrowEvent>
复制代码

补偿中间触发事件

描述

  • 用来触发补偿

  • 触发补偿:

  • 补偿可以由特定节点或包含补偿事件的作用域触发

  • 补偿是通过分配给节点的补偿处理器来完成的

  • 当补偿由节点触发,对应的补偿处理器会根据节点成功完成的次数执行相同次数

  • 如果补偿由当前作用域触发,当前作用域的所有节点都会执行补偿,也包含并发分支

  • 补偿的触发是继承式的:

  • 如果执行补偿的节点是子流程,补偿会作用到子流程中包含的所有节点

  • 如果子流程是内嵌节点,补偿会递归触发

  • 补偿不会传播到流程的上层

  • 如果补偿在子流程中触发,不会传播到子流程范围外

  • bpmn 规范定义,由节点触发的流程只会作用到子流程同一级别

  • activiti 的补偿执行次序与流程执行顺序相反: 最后完成的节点会最先执行补偿

  • 补偿中间触发事件可以用来补偿成功完成的事务性子流程

  • ==注意:==

  • 如果补偿被一个包含子流程的作用域触发,子流程还包含了关联补偿处理器的节点, 如果它已经成功完成了,补偿只会传播到子流程

  • 如果子流程中的节点也完成了,并关联了补偿处理器,如果子流程包含的这些节点还没有完成,就不会执行补偿处理器

  • 这个流程中,我们有两个并发分支,一个分支是内嵌子流程,一个是使用信用卡节点.假设两个分支都启动了,第一个分支等待用户完成审核预定任务.第二个分支执行使用信用卡节点, 并发生了一个错误,这导致取消预定事件,并触发补偿.这时,并发子流程还没有结束,意味着补偿事件不会传播给子流程, 所以取消旅店预定这个补偿处理器不会执行.如果用户任务(就是内嵌子流程)在取消预定之前完成了,补偿就会传播给内嵌子流程

  • 流程变量:

  • 当补偿内嵌子流程时,用来执行补偿处理器的分支可以访问子流程的本地流程实例,因为这时是子流程完成的分支

  • 为了实现这个功能,流程变量的快照会分配给分支(为执行子流程而创建的分支)有以下限制条件:

  • 补偿处理器无法访问子流程内部创建的,添加到同步分支的变量

  • 分配给分支的流程变量在继承关系上层的(分配给流程实例的流程变量没有包含在快照中):补偿触发时,补偿处理器通过它们所在的地方访问这些流程变量

  • 变量快照只用于内嵌子流程,不适用其他节点


 已知限制: 1. waitForCompletion="false"还不支持。当补偿使用中间触发补偿事件触发时， 事件没有等待，在补偿成功结束后 2. 补偿自己由并发分支执行。并发分支的执行顺序与被补偿的节点完成次序相反。 未来activiti可能支持选项来顺序执行补偿 3. 补偿不会传播给callActivity调用的子流程实例
复制代码
图形标记

  • 中间补偿触发事件显示为标准中间事件(圆圈套圆圈),内部是一个补偿小图标.补偿图标是黑色的(有填充),表示触发的意思

XML 内容

  • 补偿中间事件定义为普通的中间触发事件. 对应类型的子元素是 compensateEventDefinition 元素


<intermediateThrowEvent id="throwCompensation">        <compensateEventDefinition /></intermediateThrowEvent>
复制代码


  • 可选参数 activityRef 可以用来触发特定作用域/节点的补偿


<intermediateThrowEvent id="throwCompensation">        <compensateEventDefinition activityRef="bookHotel" /></intermediateThrowEvent>
复制代码


划线
评论
复制
发布于: 2021 年 06 月 02 日阅读数: 295

版权声明: 本文为 InfoQ 作者【攻城狮Chova】的原创文章。

原文链接:【http://xie.infoq.cn/article/2830e0531d913011db26c826d】。文章转载请联系作者。

事件6 月日更流程元素
用户头像

攻城狮Chova

关注

一位攻城狮的自我修养 2021.04.06 加入

分享技术干货，面试题和攻城狮故事。 你的关注支持是我持续进步的最大动力！ https://github.com/ChovaVea

评论

发布
暂无评论
Copyright © 2021, Geekbang Technology Ltd. All rights reserved. 极客邦控股（北京）有限公司 | 京 ICP 备 16027448 号 - 5京公网安备京公网安备 11010502039052号
不了解工作流框架Activiti中的流程事件？这篇工作流流程元素详解，带你详细分析工作流流程执行过程中的各种事件