0
点赞
收藏
分享

微信扫一扫

【第十三篇】Flowable事件-消息事件

【第十三篇】Flowable事件-消息事件_3c

Flowable消息事件

  消息事件(message event),是指引用具名消息的事件。消息具有名字与载荷。与信号不同,消息事件只有一个接收者

1.启动事件

  消息启动事件,也就是我们通过接收到某些消息后来启动流程实例,比如接收到了一封邮件,一条短信等,具体通过案例来讲解

【第十三篇】Flowable事件-消息事件_消息事件_02

我们需要先定义一个消息

【第十三篇】Flowable事件-消息事件_3c_03

然后在消息开始节点出引用

【第十三篇】Flowable事件-消息事件_Flowable_04

然后通过代码来处理,部署和启动

/**
* Deploy
*/
@Test
void testDeploy() throws Exception {
//RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
.addClasspathResource("消息启动事件.bpmn20.xml")
.name("消息启动事件")
.deploy();
System.out.println("deploy.getId() = " + deploy.getId());
System.out.println("deploy.getName() = " + deploy.getName());
System.out.println("部署开始的时间:" + new Date());
//TimeUnit.MINUTES.sleep(3);
}

部署后不会自动启动,我们需要接收相关的信息后来触发。

/**
* 通过消息来启动一个流程实例
*/
@Test
void startFlow() throws Exception{

// runtimeService.startProcessInstanceById("event006:1:0532e730-af02-11ec-8cf3-c03c59ad2248");
// 注意:发送消息发送的应该是消息的名称而不是消息的ID
runtimeService.startProcessInstanceByMessage("第一个消息");
System.out.println("启动时间:" + new Date());
// 我们得保证容器的运行,所以需要阻塞
TimeUnit.MINUTES.sleep(1);
}

注意:发送消息发送的应该是消息的名称而不是消息的ID,报错如下:
【第十三篇】Flowable事件-消息事件_工作流_05

2.中间事件

  消息中间事件就是在流程运作中需要消息来触发的场景,案例演示,​​自动流程1​​​处理完成后,需要接收特定的消息之后才能进入到​​自动流程2​

【第十三篇】Flowable事件-消息事件_事件_06

消息中间事件绑定的消息为

【第十三篇】Flowable事件-消息事件_消息事件_07

然后通过代码来演示

/**
* Deploy
*/
@Test
void testDeploy() throws Exception {
//RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
.addClasspathResource("消息中间事件.bpmn20.xml")
.name("消息中间事件")
.deploy();
System.out.println("deploy.getId() = " + deploy.getId());
System.out.println("deploy.getName() = " + deploy.getName());
System.out.println("部署开始的时间:" + new Date());
//TimeUnit.MINUTES.sleep(3);
}

/**
* 通过消息来启动一个流程实例
*/
@Test
void startFlow() throws Exception{

runtimeService.startProcessInstanceById("event008:1:9217aa5e-af0e-11ec-b11f-c03c59ad2248");
// 注意:发送消息发送的应该是消息的名称而不是消息的ID
//runtimeService.startProcessInstanceByMessage("第一个消息");
System.out.println("启动时间:" + new Date());
// 我们得保证容器的运行,所以需要阻塞
//TimeUnit.MINUTES.sleep(1);
}

/**
* 中间事件-发布消息
*/
@Test
void recevedMsg(){
// 需要查询到executionId
String processExecutionId = "b5349e22-af0e-11ec-93e6-c03c59ad2248";
// 我们需要根据流程实例编号找到对应的执行编号
/* Execution execution = runtimeService.createExecutionQuery()
.processInstanceId("event008:1:9217aa5e-af0e-11ec-b11f-c03c59ad2248")
.singleResult();
System.out.println("----------->"+execution.getId());*/
runtimeService.messageEventReceived("第二个消息",processExecutionId);
}

可以看到的输出效果

【第十三篇】Flowable事件-消息事件_Flowable_08

3.边界事件

  消息边界事件,如果在消息触发前还没有,案例演示:
【第十三篇】Flowable事件-消息事件_工作流_09

部署流程

/**
* Deploy
*/
@Test
void testDeploy() throws Exception {
//RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
.addClasspathResource("消息边界事件.bpmn20.xml")
.name("消息边界事件")
.deploy();
System.out.println("deploy.getId() = " + deploy.getId());
System.out.println("deploy.getName() = " + deploy.getName());
System.out.println("部署开始的时间:" + new Date());
//TimeUnit.MINUTES.sleep(3);
}
/**
* 通过消息来启动一个流程实例
*/
@Test
void startFlow() throws Exception{

runtimeService.startProcessInstanceById("event009:1:f2096787-af11-11ec-b290-c03c59ad2248");
// 注意:发送消息发送的应该是消息的名称而不是消息的ID
//runtimeService.startProcessInstanceByMessage("第一个消息");
System.out.println("启动时间:" + new Date());
// 我们得保证容器的运行,所以需要阻塞
//TimeUnit.MINUTES.sleep(1);
}

部署流程后启动流程实例会运转到

【第十三篇】Flowable事件-消息事件_事件_10

如果人工处理在消息订阅前没有处理就会触发边界事件

/**
* 边界事件-发布消息
*/
@Test
void recevedMsg(){
// 需要查询到executionId
String processExecutionId = "1d503361-af12-11ec-89a4-c03c59ad2248";
// 我们需要根据流程实例编号找到对应的执行编号
/* Execution execution = runtimeService.createExecutionQuery()
.processInstanceId("event008:1:9217aa5e-af0e-11ec-b11f-c03c59ad2248")
.singleResult();
System.out.println("----------->"+execution.getId());*/
runtimeService.messageEventReceived("第三个消息",processExecutionId);
}

【第十三篇】Flowable事件-消息事件_3c_11

搞定~


举报

相关推荐

0 条评论