标签：java spring kotlin spring-data-mongodb spring-webflux

我有以下请求处理程序

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
}

标签：java,spring,kotlin,spring-data-mongodb,spring-webflux
来源： https://codeday.me/bug/20190627/1304792.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。