Mutiny异步更新如何确保数据库更新请求发出后再抛出异常

问题根因 #

你遇到的更新不执行问题核心是Mutiny响应式编程模型的冷流特性：Uni<Integer>类型的返回值只是一个操作描述对象，没有经过订阅触发的话，对应的数据库更新逻辑根本不会启动执行。

你之前尝试的几种方案不生效的原因：

• 调用await()：直接在Vert.x事件循环线程阻塞等待结果，违反了Vert.x事件循环禁止阻塞的规则，会直接抛出阻塞错误
• 单独调用subscribe()：订阅触发是异步调度的，调用subscribe()后代码会立刻同步执行下一行的抛异常逻辑，此时DB请求还没来得及发送，上层请求终止后会回收数据库连接，更新请求直接被丢弃
• 使用onItem().failWith()：你没有将抛异常的逻辑编排到Uni的执行链中，还是走同步抛异常的路径，failWith逻辑根本没有执行机会，自然无法中断流程

正确实现方案 #

所有逻辑必须通过Uni的链式回调编排，全程无阻塞，由上层框架（Vert.x Web/Quarkus REST等）负责最终订阅，就能保证抛异常前更新请求已经发送到数据库：

// 直接将组装完成的Uni返回给上层框架，不要自行调用subscribe、await
return persistenceManager.updateElement(datastore, filterParams, fieldsToUpdate)
  // 仅要求请求发出不需要等更新结果时保留这段，需要等更新执行完可以删除
  .onSubscription().invoke(() -> {
    // 到这个节点时，数据库连接已经就绪，更新请求已经提交到网络层准备发送
  })
  // 无论更新成功、失败，都在触发节点抛出业务异常，走统一切面逻辑
  .onItemOrFailure().transform((updateCount, dbError) -> {
    // 如需记录数据库本身的执行错误，可以在这里处理，不影响后续异常抛出
    throw new MyException(ErrorCodes.GONE, errMsg);
  });

关键说明 #

• 如果你只要求更新请求成功发送到数据库，不需要等待更新执行完成，保留onSubscription节点即可，该节点触发时请求已经写入网络缓冲区，不会因为后续抛异常被丢弃
• 如果你需要等待更新实际落库后再抛异常，直接删除onSubscription层即可，onItemOrFailure回调会在数据库返回更新结果（成功/失败）后才触发，再抛出的异常会正常进入你定义的切面，完成指标统计、错误日志记录等收尾工作
• 全程没有阻塞调用，完全符合Vert.x的线程模型要求，不会触发阻塞报错

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