Project Reactor中用户保存场景的错误处理与方法签名问题

需求是保存用户到数据库前，先检查是否存在同名用户：存在则抛出异常由调用方处理，不存在则执行保存操作。

现有代码 #

Repository定义（基于ReactiveCrudRepository） #

interface UserRepository : ReactiveCrudRepository<User, Long> {

    @Query("SELECT * FROM user WHERE name = :name LIMIT 1")
    fun findByName(name: String): Mono<User>

    fun saveUser(user: User): Mono<User>

}

业务代码（存在问题） #

fun saveUser(user: User): Mono<User> {
  return repository.findByName(user.name)
    .flatMap { existingUser ->
      return Mono.error(UserExistsException())  // 此处return会直接跳出外层函数，不符合lambda预期
    }
    .switchIfEmpty {
      return repository.saveUser(user)  // 同样存在return的问题
    }
}

问题分析 #

1. ReactiveCrudRepository的findByName在无匹配数据时返回Mono.empty()，这是响应式编程中表示“无结果”的标准方式，不需要用Mono<Optional<User>>包裹。
2. 原代码的核心问题是Kotlin lambda中错误使用了return，导致直接跳出外层的saveUser函数，而非返回lambda所需的Mono<User>实例。
3. flatMap操作符完全适合处理“查到用户则抛异常”的逻辑，因为Mono.error(UserExistsException())返回的正是Mono<User>类型（错误信号属于响应式流的一部分）。

修正后的代码 #

fun saveUser(user: User): Mono<User> {
    return repository.findByName(user.name)
        // 查到同名用户，返回错误信号
        .flatMap { Mono.error(UserExistsException()) }
        // 未查到用户，执行保存逻辑
        .switchIfEmpty(repository.saveUser(user))
}

逻辑说明 #

• flatMap：当findByName发射用户对象（存在同名），返回携带异常的Mono，触发订阅者的错误处理流程。
• switchIfEmpty：当findByName发射empty信号（无同名用户），执行保存操作并返回保存后的用户Mono。

这样的写法完全符合响应式编程思维，代码简洁且遵循Spring Reactor的最佳实践。

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