java – 用spring数据更新对象mongodb和kotlin不能正常工作

我有以下请求处理程序fun x(req: ServerRequest) = req.toMono().flatMap {...val oldest = myRepository.findOldest(...) // this is the object I want to modify...val v= anotherMongoReactiveRepository.save(Y...

我有以下请求处理程序

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()时它开始工作的原因.如果你需要调用DB并在另一个DB请求中使用结果,而不是使用mono / Flux运算符(如map(),flatMap(),…)来构建所需操作的管道,然后返回结果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
}