Activiti 启动事件（Start Event）

阅读量：5131 次

发布时间：2019-06-13

本文共 12898 字，大约阅读时间需要 42 分钟。

Activiti 启动事件（Start Event）

作者:邓家海

生活里，没有容易二字，忧伤是一种本能，而微笑是一种能力

前言：

启动事件是Activiti活动的开始节点。现在有很多国产的工作流是省略了开始和结束这两个节点的。但是BPMBN 2.0标准是必须要有开始和结束节点的。启动事件表示流程的开始。定义了流程如何被启动的启动事件类型（当收到消息、特定的时是以一个小图标来形象表示事件的。在 XML 表示中，类型是由子元素的声明给出的。启动事件总是捕获型的：从概念上讲，该事件（任何时候）会一直等待直到触发发生。

启动事件（Start Event）的类型：

（1）空启动事件（None Satrt Event）

（2）定时启动事件（Timer Satrt Event）

（3）信号事件(Signal Start Event)

（4）消息事件(Message Start Event)

（5）异常事件(Error Start Event)

（1）空启动事件（None Satrt Event）

图标：

图 1-1 空启动事件图标

空启动事件就是一个圆圈。在工作流里面使用的非常多。但是空启动事件必须要人工去启动一个流程。空启动事件是建立在部署完成的流程上面的。每启动一次，就会产生一个新的流程实例。

代码：

这个启动事件非常的简单。就无需多说。

（2）定时启动事件（Timer Satrt Event）

图标：

图 2-1 定时启动事件图标

定时启动事件是一个时钟图标，注意的是，这个时钟图标是比较少圆圈的，要跟定时边界事件区分清楚。

定时器启动事件用于在给定的时间点创建流程实例。它可以用在只启动一次的流程中，也可以用在特定时间间隔下启动。如果是有重复执行的,流程在周期内都有效，可以重复利用。

的流程。

注意：

子流程中不能使用定时器启动事件。定时器是从流程部署开始计时，不需要去启动流程。

代码：

timeDate:指定ISO 8601格式的日期定时器激活。

1 
     
      2 3     
      
       2016-08-23T18:13:00

timeDuration：定义定时器经过多少时间后激活。时间段也是取得ISO 8601格式，比如在一年三个月五天六小时七分三十秒内，可以写成P1Y3M5DT6H7M30S。

timeCycle：定义定时器重复间隔，在某些场景使用，比如周期性的启动流程，任务超时发送提醒。timeCycle的设置目前有两种方式：ISO 8601和Cron表达式(quartz任务调度框架提供的解决方案)，activiti默认是使用ISO 8601。例如现在重复三次，每次间隔10小时：

1  
     
      2     
      
       R3/PT10H
      3 
     2 3 
     
      4 5     
      
       R3/PT10H/${EndDate}
      6 7

其中endDate是可选的配置，上面使用了两张方式加上了endDate,　定时器将会在指定的时间停止工作。

此外如果你使用Cron 表达式，可以这样写：

0 0/5 * * * ?

注意：

第一个数字表示秒，而不是像通常Unix cron中那样表示分钟。重复的时间周期能更好的处理相对时间，它可以计算一些特定的时间点 (比如用户任务的开始时间)，而cron表达式可以处理绝对时间, 这对定时启动事件特别有用。

你可以使用表达式进行配置，在里面动态设置值，不过该值需要为ISO 8601或者(cron表达式)格式

1 
     
      2 3   
      
       4 5     
       
        ${duration}
       6 7

示例：从 2011 年 3 月 11 日 12:13 开始，流程将启动 4 次，每次间隔 5 分钟。

1 
     
      2 
      
       3 
       
        R4/2017-06-11T12:13/PT5M
       4 
      5

示例：流程将在选定的时间上启动一次

1 
     
      2 
      
       3 
       
        2017-06-11T12:13:14
       4 
      5

实验：

我们设计一个简单的流程，一个定时启动事件，一个手动任务来监控定时启动任务是否已经启动。

流程设计：

图 2-2定时启动事件流程设计

流程代码：

1 
      2  3 
     
       4  5   
      
        6  7     
       
         8  9       
        
         10 11         
         
          R4/2017-06-27T20:45/PT1M
         12 13       
        14 15     
       16 17     
       
        18 19       
        
         20 21         
         22 23       
        24 25     
       26 27     
       28 29     
       30 31     
       32 33   
      34 35   
      
       36 37     
       
        38 39       
        
         40 41         
         42 43       
        44 45       
        
         46 47         
         48 49       
        50 51       
        
         52 53         
         54 55       
        56 57       
        
         58 59         
         60 61         
         62 63       
        64 65       
        
         66 67         
         68 69         
         70 71       
        72 73     
       74 75   
      76 77

手动任务监听器代码：

1 /** 2  3  * 4  5  */ 6  7 package light.mvc.workflow.serviceTask; 8  9  10 11 import org.activiti.engine.delegate.DelegateExecution;12 13 import org.activiti.engine.delegate.JavaDelegate;14 15  16 17 /**  18 19  *   20 21  * 项目名称：lightmvc  22 23  * 类名称：ServiceTask  24 25  * 类描述：  26 27  * 创建人：邓家海  28 29  * 创建时间：2017年6月4日 下午6:18:11  30 31  * 修改人：deng  32 33  * 修改时间：2017年6月4日 下午6:18:11  34 35  * 修改备注：  36 37  * @version   38 39  *   40 41  */42 43  44 45 public class TimerTestRunningTask implements JavaDelegate{46 47  48 49 //重写委托的提交方法50 51 @Override52 53 public void execute(DelegateExecution execution) throws Exception {54 55 //receiveTaskprocess56 57 System.out.println("TimerTestRunningTask is running！");58 59 }60 61  62 63 }

部署流程，无需启动。

运行结果：

图 2-3定时启动事件运行结果

注意的是，当定时启动任务已经超过运行时间，再次去部署流程里面启动这个任务，就会把它当成一个普通的空启动事件来处理。部署新的流程，上一版本的流程就会被移除。

（3）信号事件(Signal Start Event)

信号启动事件，使用具名信号启动流程实例。这个信号可以由流程实例中的信号抛出中间事件（intermediary signal throw event），或

者API（runtimeService.signalEventReceivedXXX方法）触发。这些情况下，所有拥有相同名字信号启动事件的流程定义都会被启动。

请注意这些情况下，都可以选择异步还是同步启动流程实例。

需要为API传递的 signalName ，是由 signal 元素的 name 属性决定的名字。 signal 元素被 signalEventDefinition 的 signalRef

属性所引用。

图标：

图 3-1 信号启动事件图标

信号事件流程图设计：

图 3-2 信号启动流程设计

信号事件的启动：

1 List
     
       executions =  execution.getEngineServices().getRuntimeService().createExecutionQuery() 2  3        .signalEventSubscriptionName("singal") 4  5        .list(); 6  7 for(Execution e:executions){ 8  9 execution.getEngineServices().getRuntimeService().signalEventReceived("singal", e.getId());10 11 }

信号事件XML代码：

说明：

信号启动事件的两种启动方式：

1、信号可以是流程实例中抛出的信号事件

2、API触发

信号事件的执行方式：

1、异步执行

2、同步执行

注意：信号启动事件，是所有相同名称的信号事件都会被执行！

（4）消息事件（Message Start Event ）

启动方式：

1、流程实例中的信号抛出事件

2、API触发（runtimeService.signalEventReceivedXXX方法）触发

注意事项：

1）流程的消息名称必须是唯一的，一个流程定义不得包含多个同名的启动消息。否则部署流程的时候就会抛异常。

2）消息启动事件，在所有部署的流程里面必须要唯一，否则也会抛异常。

3）直接启动消息定义事件，会当作一个普通启动事件执行。

4）新版本发布，会取消上一版本的消息订阅。

5）启动流程实例的三种方法

1 ProcessInstance startProcessInstanceByMessage(String messageName);2 ProcessInstance startProcessInstanceByMessage(String messageName, Map
     
       processVariables);3 ProcessInstance startProcessInstanceByMessage(String messageName, String businessKey, Map

注：messageName 是由 message 元素的 name 属性决定的名字。 message 元素被 messageEventDefinition 的 messageRef 属性引用

6）只有顶层流程（toplevel process）才支持消息启动事件，嵌入流程（子流程）不支持消息事件。

7）如果一个流程定义多个消息事件无法使用runtimeService.startProcessInstanceByKey(…) 与

runtimeService.startProcessInstanceById(…) 启动消息事件，但是一个流程定义单个消息事件可以启动。如果同一个流程定义同时具有多个消息事件和空启动事件，就会启动空启动事件，同一个流程定义多个消息事件的时候，使用这个方法启动，就会抛异常。

图标：

图 4-1 消息启动事件图标

流程图设计：

图 4-2 消息启动事件流程设计

我们在消息启动事件后面放置了一个手工任务，并在这个手工任务上面设置一个监听类，这个任务只要是监控这个启动事件的流程是否被成功的执行。

流程代码：

我们测试的时候借助一个手工任务触发消息事件的流程。

手工任务流程设计：

图 4-3 手工任务事件流程设计

手工任务流程代码：

手工任务监听类：

1 /** 2  3  * 4  5  */ 6  7 package light.mvc.workflow.serviceTask; 8  9  10 11 import java.util.List;12 13  14 15 import org.activiti.engine.delegate.DelegateExecution;16 17 import org.activiti.engine.delegate.JavaDelegate;18 19 import org.activiti.engine.runtime.Execution;20 21  22 23 /**  24 25  *   26 27  * 项目名称：lightmvc  28 29  * 类名称：ServiceTask  30 31  * 类描述：  32 33  * 创建人：邓家海  34 35  * 创建时间：2017年6月4日 下午6:18:11  36 37  * 修改人：deng  38 39  * 修改时间：2017年6月4日 下午6:18:11  40 41  * 修改备注：  42 43  * @version   44 45  *   46 47  */48 49  50 51 public class TestRunningTask implements JavaDelegate{52 53  54 55 //重写委托的提交方法56 57 @Override58 59 public void execute(DelegateExecution execution) throws Exception { execution.getEngineServices().getRuntimeService().startProcessInstanceByMessage("message");60 61 System.out.println("TestRunningTask is running！");62 63 }64 65  66 67 }

消息事件执行测试代码（监听类）：

1 /** 2  3  * 4  5  */ 6  7 package light.mvc.workflow.serviceTask; 8  9  10 11 import org.activiti.engine.delegate.DelegateExecution;12 13 import org.activiti.engine.delegate.JavaDelegate;14 15  16 17 /**  18 19  *   20 21  * 项目名称：lightmvc  22 23  * 类名称：ServiceTask  24 25  * 类描述：  26 27  * 创建人：邓家海  28 29  * 创建时间：2017年6月4日 下午6:18:11  30 31  * 修改人：deng  32 33  * 修改时间：2017年6月4日 下午6:18:11  34 35  * 修改备注：  36 37  * @version   38 39  *   40 41  */42 43  44 45 public class MessageTestRunningTask implements JavaDelegate{46 47  48 49 //重写委托的提交方法50 51 @Override52 53 public void execute(DelegateExecution execution) throws Exception {54 55 //receiveTaskprocess56 57 System.out.println("MessageTestRunningTask is running！");58 59 }60 61  62 63 }

运行结果：

图 4-4 消息事件执行结果

（5）异常事件（错误启动事件 Error Start Event ）

BPMN2.0规定了错误开始事件只能使用在事件子流程（Event Sub-Process）中，该该事件不能使用在其他流程中，包括最高级流程（Top-Level Process）、嵌套子流程（Sub-Process）和调用子流程（Call Activity）。BPMN错误与Java异常不是一回事。事实上，这两者毫无共同点。BPMN错误事件是建模业务异常（business exceptions）的方式。

错误消息开始事件图标：

图 5-1 异常事件图标

错误事件定义 Error Event Definitions ：

error的errorCode用于查找匹配的错误捕获边界事件。如果errorRef不匹配任何已定义的error，则该errorRef会用做errorCode的快捷方式。

请注意errorRef必须遵从BPMN 2.0概要（schema），且必须是合法的QName。

下面这两段代码是一样的

1）

2）

错误启动事件流程图设计：

图 5-2 异常事件流程设计

说明：

我们一共设计两个流程，一个是子流程事件，一个是主流程。当这个流程启动，便会启动主流程。主流程的Servertask便会抛出一个BpmnError的流程错误。这个流程错误会被Activiti引擎拦截到，然户触发子流程事件里面的错误启动事件。从而触发SubServertask这个Server任务。

图解：

图 5-3 异常事件图解

流程图XML定义：

主流程的监听类：

1 /** 2  3  * 4  5  */ 6  7 package light.mvc.workflow.serviceTask; 8  9  10 11 import org.activiti.engine.delegate.BpmnError;12 13 import org.activiti.engine.delegate.DelegateExecution;14 15 import org.activiti.engine.delegate.JavaDelegate;16 17  18 19 /**  20 21  *   22 23  * 项目名称：lightmvc  24 25  * 类名称：ServiceTask  26 27  * 类描述：  28 29  * 创建人：邓家海  30 31  * 创建时间：2017年6月4日 下午6:18:11  32 33  * 修改人：deng  34 35  * 修改时间：2017年7月16日 下午7:28:11  36 37  * 修改备注：  38 39  * @version   40 41  *   42 43  */44 45  46 47 public class TestRunningTask implements JavaDelegate{48 49  50 51 //重写委托的提交方法52 53  54 55  56 57 @Override58 59 public void execute(DelegateExecution execution) throws Exception{60 61 System.out.println("TestRunningTask is running!");62 63  64 65  66 67 //throw new BpmnError("myError","myError");68 69 throw new BpmnError("MyErrorCode","myError");70 71  72 73  74 75  76 77  78 79 }80 81  82 83  84 85 }86 87

子流程事件的监听类：

1 /** 2  3  * 4  5  */ 6  7 package light.mvc.workflow.serviceTask; 8  9  10 11 import org.activiti.engine.delegate.DelegateExecution;12 13 import org.activiti.engine.delegate.JavaDelegate;14 15  16 17 /**  18 19  *   20 21  * 项目名称：lightmvc  22 23  * 类名称：ServiceTask  24 25  * 类描述：  26 27  * 创建人：邓家海  28 29  * 创建时间：2017年6月4日 下午6:18:11  30 31  * 修改人：deng  32 33  * 修改时间：2017年6月4日 下午6:18:11  34 35  * 修改备注：  36 37  * @version   38 39  *   40 41  */42 43  44 45 public class ErrorTestRunningTask implements JavaDelegate{46 47  48 49 //重写委托的提交方法50 51 @Override52 53 public void execute(DelegateExecution execution) throws Exception {54 55 //receiveTaskprocess56 57 System.out.println("ErrorTestRunningTask is running！");58 59 }60 61  62 63 }64 65