使用Spring数据MongoDB和Kotlin更新对象不起作用

Question

我有以下请求处理程序

fun x(req: ServerRequest) = req.toMono()
    .flatMap {
        ...
        val oldest = myRepository.findOldest(...) // this is the object I want to modify
        ...
        val v= anotherMongoReactiveRepository.save(Y(...)) // this saves successfully
        myRepository.save(oldest.copy(
                remaining = (oldest.remaining - 1)
        )) // this is not saved
        ok().body(...)
    }

和以下mongodb反应式存储库

@Repository
interface MyRepository : ReactiveMongoRepository<X, String>, ... {
}

问题在于save()执行该方法后，对象中没有任何更改。我设法解决了这个问题，save().block()但是我不知道为什么在其他存储库中进行的第一个保存有效，而这个无效。为什么要这样做block()？

Answer 1

除非有人订阅了反应式发布者，否则什么都不会发生。这就是为什么当您使用block（）时它开始起作用的原因。如果您需要调用数据库并在另一个数据库请求中使用结果，而不是使用诸如map（），flatMap（）等Mono
/ Flux运算符…来构建所需所有操作的管道，然后返回结果Mono / Flux作为控制器的响应。Spring将订阅该Mono /
Flux并返回请求。您不需要阻止它。并且不建议这样做（使用block（）方法）。

简短示例如何在Java中使用MongoDB反应存储库：

@GetMapping("/users")
public Mono<User> getPopulation() {
    return userRepository.findOldest()
            .flatMap(user -> {              // process the response from DB
                user.setTheOldest(true);
                return userRepository.save(user);
            })
            .map(user -> {...}); // another processing
}