Spring Webflux非阻塞依赖资源调用

Question

我正在使用Spring Webflux和Spring Data MongoDB Reactive。在我的REST控制器中，我试图从数据库（MongoDB）中获取一种类型的所有对象（例如，一个品牌的所有自行车）。我当前的实现看起来是这样的：

@GetMapping("/bybrand/{brandId}")
public Flux<Bike> bikesByBrand(@PathVariable(value = "brandId") String brandId) {
    return bikeRepository.findByBrand( //returns a Flux<Bike>
            brandRepository.findById(brandId) //returns a Mono<Brand>
                    .block() //returns a Brand
    );
}

为了保持反应模式，我希望避免block（）调用。我尝试了map（）和doOnSuccess（）的多种组合，但没有找到正确的方法来完成我想要做的事情。我在网上找到的示例或教程并没有涵盖对数据库使用依赖调用的用例。如何避免在这里使用block（）？使用依赖的previous调用访问数据库的黄金标准是什么？

我的另一种方法是。

brandRepository.findById(brandId)
            .doOnSuccess(brand -> bikeRepository.findByBrand(brand));

但是我找不到一种方法来最终返回superior方法中lambda函数的结果（自行车的通量）。

Answer 1

您可以使用flatMapMany

return brandRepository.findById(brandId).flatMapMany(bikeRepository::findByBrand)