【Flowable】消息事件

Metadata

title: 【Flowable】 消息事件
date: 2023-01-23 17:33
tags:
  - 行动阶段/完成
  - 主题场景/组件
  - 笔记空间/KnowladgeSpace/ProgramSpace/ModuleSpace
  - 细化主题/Module/Flowable
categories:
  - Flowable
keywords:
  - Flowable
description: 【Flowable】 消息事件

【Flowable】消息事件

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

1. 启动事件

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

我们需要先定义一个消息

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

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

/**
 * 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，报错如下：

2. 中间事件

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

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

然后通过代码来演示

/**
 * 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. 边界事件

消息边界事件，如果在消息触发前还没有，案例演示：

部署流程

/**
 * 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);
}
复制代码

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

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

/**
 * 边界事件-发布消息
 */
@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);
}
复制代码