前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >第十一节:Activiti6.0——定时器开始事件、消息开始事件和错误开始事件介绍

第十一节:Activiti6.0——定时器开始事件、消息开始事件和错误开始事件介绍

作者头像
凡人飞
发布2020-09-21 10:56:48
2.2K0
发布2020-09-21 10:56:48
举报
文章被收录于专栏:指缝阳光

一、概述

介绍: 在activiti中,事件按位置分可以有:开始事件中间事件边界时间结束事件;按事件的特性区分有:捕获事件抛出事件。除了事件,还有各种事件定义,常用的有:定时器事件定义错误事件定义信号事件定义消息事件定义取消事件定义补偿事件定义等。事件和事件定义可以进行组合,成为特定的事件。

此刻: 本文主要讲四种开始事件

  1. 无指定开始事件:不为开始事件指定任何的触发条件的事件。此处不介绍。
  2. 定时器开始事件:在开始事件中加入定时器事件定义。
  3. 消息开始事件:在开始事件中加入消息事件定义。
  4. 错误开始事件:错误开始事件只能使用在事件的子流程。

二、定时器开始事件

  1. 流程图
  1. 流程xml
代码语言:javascript
复制
	<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
    <startEvent id="_2" name="StartEvent">
      <timerEventDefinition>
        <!--从每分钟的0s开始,每隔5秒开始一次流程(生成一个流程实例)-->
        <timeCycle>0/5 * * * * ?</timeCycle>
      </timerEventDefinition>
    </startEvent>
    <userTask activiti:exclusive="true" id="UserTask" name="UserTask"/>
    <endEvent id="_4" name="EndEvent"/>
    <sequenceFlow id="_5" sourceRef="_2" targetRef="UserTask"/>
    <sequenceFlow id="_6" sourceRef="UserTask" targetRef="_4"/>
    </process>
  1. 编码部署
代码语言:javascript
复制
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();

//部署流程后,不用我们自己启动流程实例,定时器的时间到了后会自动启动流程实例
Deployment deployment = repositoryService.createDeployment().addClasspathResource("timer-start-event.bpmn").deploy();

long count = runtimeService.createProcessInstanceQuery().count();
System.out.println("sleep前的流程实例个数:" + count);

//
// 
//睡眠20s,5s运行一次,则会多4个流程实例
Thread.sleep(20 * 1000);

count = runtimeService.createProcessInstanceQuery().count();
System.out.println("sleep后的流程实例个数:" + count);

processEngine.close();
System.exit(0);
  1. 结果查看
  1. 个人遇到问题及猜测:在测试过程中遇到个数和时间不对。 定时开始事件设置的时间间隔为1s,31s后流程实例增加个数为3个,个人猜测:定时开始事件的流程实例启动间隔强制大于等于10s若设置的小于10s,则使用10s;若设置的时间间隔大于10s,则以设置的为准)

三、消息开始事件

  1. 流程图
  1. 流程xml
代码语言:javascript
复制
<message id="msg" name="msgName"></message>
<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
  <startEvent id="_2" name="StartEvent">
    <!--开始事件引用消息-->
    <messageEventDefinition messageRef="msg"></messageEventDefinition>
  </startEvent>
  <userTask activiti:exclusive="true" id="UserTask" name="UserTask"/>
  <endEvent id="_4" name="EndEvent"/>
  <sequenceFlow id="_5" sourceRef="_2" targetRef="UserTask"/>
  <sequenceFlow id="_6" sourceRef="UserTask" targetRef="_4"/>
</process>
  1. 编码部署
代码语言:javascript
复制
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();

Deployment deployment = repositoryService.createDeployment().addClasspathResource("message-start-event.bpmn").deploy();


//通过消息启动流程实例,在一个项目中的消息事件会存储在表act_ru_event_subscr中,
// 并且因为流程实例依靠具体的消息来启动,因此在该项目中的消息需要唯一。例:如果一个流程的消息name定义为"msgName",第一次部署时act_ru_event_subscr
// 表会存储消息与部署的流程定义的关联,之后再部署相同的消息时,不会再增加记录,不会与消息绑定;即只有第一绑定消息的流程定义是有效的。
ProcessInstance processInstance = runtimeService.startProcessInstanceByMessage("msgName");
System.out.println("流程实例ID:" + processInstance.getId());

processEngine.close();
System.exit(0);

4.结果查看: 运行结果:流程实例ID:345012 表act_ru_event_subscr:

四、错误开始事件

介绍: 此处模拟流程为,一个班级,班长清点人数,发现人数少了后,马上去报告班主任。

  1. 流程图
  1. 流程xml
代码语言:javascript
复制
<error id="errorId" errorCode="abc"></error>
<process id="myProcess_1" isClosed="false" isExecutable="true" processType="None">
  <startEvent id="_2" name="StartEvent"/>
  <serviceTask activiti:exclusive="true" id="CountPeople" name="CountPeople"
               activiti:class="com.xjf.test.delegate.CountPeopleDelegate"/>
  <endEvent id="_4" name="EndEvent"/>
  <sequenceFlow id="_5" sourceRef="_2" targetRef="CountPeople"/>
  <sequenceFlow id="_6" sourceRef="CountPeople" targetRef="_4"/>
  <!--triggeredByEvent配置必须为true,默认是false-->
  <subProcess activiti:exclusive="true" id="_7" name="SubProcess" triggeredByEvent="true">
    <startEvent id="_8" name="StartEvent">
      <errorEventDefinition errorRef="errorId"></errorEventDefinition>
    </startEvent>
    <serviceTask activiti:exclusive="true" id="Report" name="Report"
                 activiti:class="com.xjf.test.delegate.ReportDelegate"/>
    <endEvent id="_10" name="EndEvent"/>
    <sequenceFlow id="_3" sourceRef="_8" targetRef="Report"/>
    <sequenceFlow id="_11" sourceRef="Report" targetRef="_10"/>
  </subProcess>
</process>
  1. ServiceTask的两个委托类
代码语言:javascript
复制
public class CountPeopleDelegate implements JavaDelegate {
    @Override
    public void execute(DelegateExecution delegateExecution) {
        System.out.println("清点人数,要抛出错误");

        //抛出错误,子流程的错误开始事件会捕获
        throw new BpmnError("abc");
    }
}

public class ReportDelegate implements JavaDelegate {
    @Override
    public void execute(DelegateExecution delegateExecution) {
        System.out.println("少人了,准备上报");
    }
}
  1. 编码发布
代码语言:javascript
复制
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();

Deployment deployment = repositoryService.createDeployment().addClasspathResource("error-start-event.bpmn").deploy();
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();

//流程实例启动后,会自动执行:主流程抛出错误,子流程捕获到错误然后一直执行完
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
System.out.println("流程实例id:" + processInstance.getId());

processEngine.close();
System.exit(0);
  1. 查看结果

五、总结

  1. 所有的开始事件都是捕获事件,都需要具体的动作或事件来触发。
  2. 错误开始事件不能独立存在,必须是其他事件的子流程。
  3. 边界事件:在BPMN2.0的事件分类中,边界事件被划分到中间事件中,BPMN2.0中将狭义的中间事件和边界事件,统称为中间事件。可以单独作为流程元素存在于流程中的事件为中间事件,而附属于某个流程元素(如任务、子流程等)的事件为边界事件。
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019/12/06 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一、概述
  • 二、定时器开始事件
  • 三、消息开始事件
  • 四、错误开始事件
  • 五、总结
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档