Flowable事件之消息事件
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flowable事件之消息事件相关的知识，希望对你有一定的参考价值。
参考技术A在这里插入图片描述
消息事件（message event），是指引用具名消息的事件。消息具有名字与载荷。与信号不同，消息事件只有一个接收者
消息启动事件，也就是我们通过接收到某些消息后来启动流程实例，比如接收到了一封邮件，一条短信等，具体通过案例来讲解
在这里插入图片描述
我们需要先定义一个消息
在这里插入图片描述
然后在消息开始节点出引用
在这里插入图片描述
然后通过代码来处理，部署和启动
部署后不会自动启动，我们需要接收相关的信息后来触发。
注意 ：发送消息发送的应该是消息的名称而不是消息的ID，报错如下：
消息中间事件就是在流程运作中需要消息来触发的场景，案例演示， 自动流程1 处理完成后，需要接收特定的消息之后才能进入到 自动流程2
在这里插入图片描述
消息中间事件绑定的消息为
在这里插入图片描述
然后通过代码来演示
可以看到的输出效果
在这里插入图片描述
3.边界事件
消息边界事件，如果在消息触发前还没有，案例演示：
部署流程
部署流程后启动流程实例会运转到
在这里插入图片描述
在这里插入图片描述
搞定~
第十四篇Flowable事件-错误事件
Flowable事件之错误事件
错误事件可以用做一个流程的开始事件或者作为一个任务或者子流程的边界事件，错误事件没有提供作用中间事件的功能，这一点和前面介绍的定时器事件和消息事件还有区别的。
1.开始事件
错误启动事件（error start event），可用于触发事件子流程（Event Sub-Process）。错误启动事件不能用于启动流程实例。
错误启动事件总是中断。我们通过案例来介绍。此处我们用Eclipse来绘制流程图，熟悉下Eclipse工具
注意：绘制的是子流程事件：
然后我们再定义一个错误，内容为：
<error id="error01" errorCode="abcd">
在FlowableUI中没找到错误定义的选项，我们就在流程文件中自己添加即可。
完整的流程文件
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
<error id="error01" errorCode="abcd"></error>
<process id="myProcess" name="My process" isExecutable="true">
<startEvent id="startevent1" name="Start"></startEvent>
<serviceTask id="servicetask1" name="自动任务一" activiti:class="com.bobo.delegate.MyOneDelegate"></serviceTask>
<sequenceFlow id="flow1" sourceRef="startevent1" targetRef="servicetask1"></sequenceFlow>
<endEvent id="endevent1" name="End"></endEvent>
<sequenceFlow id="flow2" sourceRef="servicetask1" targetRef="endevent1"></sequenceFlow>
<subProcess id="eventsubprocess1" name="Event sub Process" triggeredByEvent="true">
<startEvent id="errorstartevent1" name="Error start">
<errorEventDefinition errorRef="error01"></errorEventDefinition>
</startEvent>
<serviceTask id="servicetask2" name="自动任务二" activiti:class="com.bobo.delegate.MyTwoDelegate"></serviceTask>
<endEvent id="endevent2" name="End"></endEvent>
<sequenceFlow id="flow3" sourceRef="servicetask2" targetRef="endevent2"></sequenceFlow>
<sequenceFlow id="flow4" sourceRef="errorstartevent1" targetRef="servicetask2"></sequenceFlow>
</subProcess>
</process>
<bpmndi:BPMNDiagram id="BPMNDiagram_myProcess">
<bpmndi:BPMNPlane bpmnElement="myProcess" id="BPMNPlane_myProcess">
<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
<omgdc:Bounds height="35.0" width="35.0" x="480.0" y="260.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="servicetask1" id="BPMNShape_servicetask1">
<omgdc:Bounds height="55.0" width="105.0" x="710.0" y="250.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
<omgdc:Bounds height="35.0" width="35.0" x="930.0" y="260.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="eventsubprocess1" id="BPMNShape_eventsubprocess1">
<omgdc:Bounds height="211.0" width="401.0" x="530.0" y="420.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="errorstartevent1" id="BPMNShape_errorstartevent1">
<omgdc:Bounds height="35.0" width="35.0" x="600.0" y="520.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="servicetask2" id="BPMNShape_servicetask2">
<omgdc:Bounds height="55.0" width="105.0" x="700.0" y="510.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endevent2" id="BPMNShape_endevent2">
<omgdc:Bounds height="35.0" width="35.0" x="850.0" y="520.0"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
<omgdi:waypoint x="515.0" y="277.0"></omgdi:waypoint>
<omgdi:waypoint x="710.0" y="277.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
<omgdi:waypoint x="815.0" y="277.0"></omgdi:waypoint>
<omgdi:waypoint x="930.0" y="277.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
<omgdi:waypoint x="805.0" y="537.0"></omgdi:waypoint>
<omgdi:waypoint x="850.0" y="537.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
<omgdi:waypoint x="635.0" y="537.0"></omgdi:waypoint>
<omgdi:waypoint x="700.0" y="537.0"></omgdi:waypoint>
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</definitions>
然后我们在主流程中的自动任务一中我们抛出异常
public class MyOneDelegate implements JavaDelegate
@Override
public void execute(DelegateExecution execution)
System.out.println("完成自动审批任务-----》MyOneDelegate" + LocalDateTime.now().toString());
// 业务执行发现有问题 此处的errorCode需要和定义的error标签中的errorCode保持一致
throw new BpmnError("abcd");
然后我们在自定义任务二中简单定义一个输出即可。然后我们部署任务
@Test
public void test01() throws Exception
ZipInputStream in = new ZipInputStream(SpringBootFlowableApplicationTests.class.getClassLoader().getResourceAsStream("错误启动事件.bar"));
Deployment deployment = processEngine.getRepositoryService().createDeployment()
.addZipInputStream(in)
.name("错误启动事件")
.deploy();
System.out.println("-----");
然后我们再启动流程实例，那么自动任务一就会抛出异常，然后对应的子流程就会开始
/**
* 启动流程实例
*
*/
@Test
public void startProcessInstanceByKey() throws Exception
processEngine.getRuntimeService()
.startProcessInstanceById("myProcess:1:c0462994-af79-11ec-8cae-c03c59ad2248");
System.out.println("开始启动的时间：" + LocalDateTime.now().toString());
// 需要在此阻塞比等待长的时间
TimeUnit.MINUTES.sleep(3);
输出结果获取到了我们期望的结果
通过输出结果也可以看到执行的自动任务一后，抛出错误事件abcd,子流程触发并执行了。
2.边界事件
定义如下的流程图：
注意绘制的时候
xml文件内容为：
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
<error id="error02" errorCode="a123" ></error>
<process id="myProcess" name="My process" isExecutable="true">
<startEvent id="startevent1" name="Start"></startEvent>
<serviceTask id="servicetask2" name="自动任务二" activiti:class="com.bobo.delegate.MyTwoDelegate"></serviceTask>
<serviceTask id="servicetask3" name="自动任务三" activiti:class="com.bobo.delegate.MyThreeDelegate"></serviceTask>
<endEvent id="endevent2" name="End"></endEvent>
<sequenceFlow id="flow5" sourceRef="servicetask2" targetRef="endevent2"></sequenceFlow>
<endEvent id="endevent3" name="End"></endEvent>
<sequenceFlow id="flow6" sourceRef="servicetask3" targetRef以上是关于Flowable事件之消息事件的主要内容，如果未能解决你的问题，请参考以下文章