在Reactor Mono流程中使用异常匹配结果类型是否合理？

当前异常使用方式的问题 #

这种用NotFoundException处理更新无匹配的场景不正确，原因如下：

1. 语义不符：NotFoundException的核心语义是「目标资源不存在」，但你的场景中模块本身是存在的，只是不满足「未发送过通知/距离上次通知已超过指定频率」的更新条件，属于正常业务分支，并非异常情况。
2. 性能与设计问题：异常的创建、捕获和栈追踪会带来额外性能开销，且异常应仅用于处理意外错误，而非业务逻辑分支判断，这种用法违背了异常设计的初衷。

正确实现方案（不破坏类型定义） #

你的目标是保持返回Mono<Boolean>，同时正确处理业务逻辑，以下是两种可行方案：

方案1：简化业务分支处理（无额外查询） #

保持Repository层代码不变，直接在Service层处理findOneAndUpdate返回的空结果，无需抛出不必要的异常：

private Mono<Boolean> maybeSendNotification(String moduleId, ModuleState state) {
  // 执行更新：匹配则返回更新后的Module，不匹配则返回Mono.empty()
  return repo.findOneAndUpdateNotificationDate(moduleId, notificationFrequency)
    // 更新成功则发送邮件，发送完成后返回true
    .flatMap(module -> notificationService.sendAlertEmail(module, state)
      .then(Mono.just(true)))
    // 不满足更新条件（无匹配）时直接返回true，符合原逻辑
    .defaultIfEmpty(true);
}

注：如果sendAlertEmail执行失败会直接向上抛出异常，与原代码中仅捕获NotFoundException的行为一致。

方案2：明确区分「模块不存在」与「不满足条件」（语义更清晰） #

如果需要在模块真的不存在时抛出NotFoundException，可以新增一个判断模块是否存在的查询，确保异常仅在资源真的不存在时抛出：

Repository层新增方法

public Mono<Boolean> existsById(String moduleId) {
  return Mono.from(collection.exists(eq(ID, new ObjectId(moduleId))));
}

Service层修改代码

private Mono<Boolean> maybeSendNotification(String moduleId, ModuleState state) {
  return repo.existsById(moduleId)
    .flatMap(exists -> {
      // 模块不存在时才抛出NotFoundException
      if (!exists) {
        return Mono.error(new NotFoundException());
      }
      // 模块存在时执行更新与发送逻辑
      return repo.findOneAndUpdateNotificationDate(moduleId, notificationFrequency)
        .flatMap(module -> notificationService.sendAlertEmail(module, state)
          .then(Mono.just(true)))
        .defaultIfEmpty(true);
    });
}

额外优化建议 #

• 确保now是方法内部获取的当前时间（如Instant.now()），避免使用外部共享变量，防止多线程场景下的时间不一致问题。
• 如果notificationService.sendAlertEmail返回Mono<Boolean>表示发送结果，可直接替换then(Mono.just(true))为该返回值，更准确反映发送状态。

内容的提问来源于stack exchange，提问作者podolinsky.e