如何在另一个具有循环依赖关系的mono中使用mono

Question

我有一个spring boot反应式应用程序。如果用户还不存在，我想在其中实现创建用户。这样地：

fun userAlreadyExist() = Mono.error<UserDTO>(UsernameAlreadyExistException())

fun create(userDTO: Mono<UserDTO>): Mono<Void> {
    return userDTO.filter { userRepository.existsByNameIgnoreCase(it.username).block() == false }
            .switchIfEmpty(userAlreadyExist())
            .flatMap { createNewUser(it).then() }

我真正不喜欢的是我需要使用。过滤器内的block（）。有没有更好的方法？

最大的问题是两者都有循环依赖关系，因为UserRepository需要知道用户名，而userDTO stream需要知道这是否已经存在并返回mono。

Answer 1

问题是，我使用的是filter（），而我应该使用的是filterWhen（），它计算异步Monos。

我所做的：

fun create(userDTO: Mono<UserDTO>): Mono<Void> {
    return userDTO.filterWhen { innerUserDTO ->
        userRepository.existsByNameIgnoreCase(innerUserDTO.username).map { !it }
    }
            .flatMap { createNewUser(it) }
            .switchIfEmpty(userAlreadyExist())
            .then()
}

Answer 2

这里的逻辑看起来有点奇怪-您可能可以这样做：

fun create(userDTO: Mono<UserDTO>): Mono<Void> {
    return userDTO.flatMap {
               userRepository.findByNameIgnoreCase(it.username)
                             .flatMap(user -> userAlreadyExist())
                             .switchIfEmpty(createNewUser(it)) 
           }.then()