Camunda Receive Task开启Asynchronous After后出现消息关联报错问题

你为「Receive offer」接收任务开启Asynchronous After配置后，该任务的执行会拆分为两个独立事务：

1. 「Receive offer」任务本身执行完成，写入历史活动记录，同时生成对应的异步执行Job提交到Camunda的ACT_RU_JOB数据表，当前事务提交
2. Camunda Job执行器异步拉取该Job，执行后续流程流转逻辑，将流程推进到「Attempted signing」消息等待节点

你观察到的「Receive offer已完成但流程卡滞」属于该配置的正常表现：历史活动实例查询只能确认第一步已完成，但对应的异步Job可能还未被调度执行，流程还未抵达下一个消息接收节点，因此关联attemptedSigningMessage消息时无法找到匹配的执行实例，触发报错。

• 方案1：给消息关联逻辑增加重试机制
  由于异步Job调度存在不可控的延迟，你可以在消息关联代码中加入指数退避重试逻辑，比如初始间隔1s，每次间隔翻倍，最多重试5次，直到关联成功或达到最大重试次数抛出异常，示例代码如下：

  int maxRetries = 5;
  long waitInterval = 1000;
  MismatchingMessageCorrelationException lastException = null;
  for (int i = 0; i < maxRetries; i++) {
      try {
          runtimeService.createMessageCorrelation("attemptedSigningMessage")
              // 如有业务标识可以补充processInstanceBusinessKey等条件缩小匹配范围
              .correlate();
          return;
      } catch (MismatchingMessageCorrelationException e) {
          lastException = e;
          Thread.sleep(waitInterval);
          waitInterval *= 2;
      }
  }
  throw lastException;
  

• 方案2：监听异步Job执行完成后再发送消息
  可以基于Camunda的事件监听机制，监听「Receive offer」对应异步Job的执行完成事件，确认流程已经流转到「Attempted signing」节点后，再触发attemptedSigningMessage消息的关联操作，从根源上避免时序问题。
• 方案3：调整Job执行器配置降低调度延迟
  若Job执行器调度间隔过长导致长时间卡滞，可以在Spring Boot配置中调整Job执行器参数，缩短调度等待时间，示例配置如下：

  camunda:
    bpm:
      job-execution:
        core-pool-size: 3
        max-pool-size: 10
        queue-capacity: 50
        wait-time-in-millis: 200 # 缩短调度间隔，默认是5000ms
  

• 方案4：开启消息关联乐观锁（适用于Camunda 7.10及以上版本）
  高版本Camunda支持消息关联的乐观锁配置，开启后即使流程还未抵达消息接收节点，消息也会暂时排队，等流程抵达后自动完成关联，无需额外重试，示例代码如下：

  runtimeService.createMessageCorrelation("attemptedSigningMessage")
      .enableOptimisticLocking()
      .correlate();
  

内容的提问来源于stack exchange，提问作者Sergey Luchko