Flowable消息事件
消息事件（message event），是指引用具名消息的事件。消息具有名字与载荷。与信号不同，消息事件只有一个接收者
1.启动事件
消息启动事件，也就是我们通过接收到某些消息后来启动流程实例，比如接收到了一封邮件，一条短信等，具体通过案例来讲解
我们需要先定义一个消息
然后在消息开始节点出引用
然后通过代码来处理，部署和启动
代码语言：javascript复制 /**
* 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);
}部署后不会自动启动，我们需要接收相关的信息后来触发。
代码语言：javascript复制 /**
* 通过消息来启动一个流程实例
*/
@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，报错如下：
2.中间事件
消息中间事件就是在流程运作中需要消息来触发的场景，案例演示，自动流程1处理完成后，需要接收特定的消息之后才能进入到自动流程2
消息中间事件绑定的消息为
然后通过代码来演示
代码语言：javascript复制 /**
* 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);
}可以看到的输出效果
3.边界事件
消息边界事件，如果在消息触发前还没有，案例演示：
部署流程
代码语言：javascript复制 /**
* 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);
}部署流程后启动流程实例会运转到
如果人工处理在消息订阅前没有处理就会触发边界事件
代码语言：javascript复制 /**
* 边界事件-发布消息
*/
@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);
}
搞定~
