在Spring反应式编程中，如何从两个通量（对象）中获取通量或列表？

Question

我是Spring Reactive Project的新手。在我的Spring Boot Controller课程中

流量

来自给定的流量的服务层

list of Flux<Image> like List<Flux<Image>> or List<List<Image>>

仅包含“封面”=“是”或“类型”=“卧室”的图像。如何做到这一点？编程代码将回答这个问题。

尝试将以下内容作为解决方案的一部分，但即使是此部分解决方案也不起作用：

List<Flux<Image>> imagesList= new ArrayList<Flux<Image>>();
        Flux<House> houses = houseService.findAllHouses();

        houses.map(house ->  house.getId()).subscribe(id -> imageService.findByHouseId(id))
        .map(imageFlux ->imagesList.add(imageFlux));

请注意，我正在寻找的解决方案不涉及调用block（）（否定被动的好处），除非这是唯一的方法。

在非反应性情况下，这就是我想要的：

List<House> houses  --> List of all houses
Map<String,List<Image>> mapOfImages  --> where key is houseId 

所以对于每个房子，我可以在视图模板中迭代房屋时轻松获得该房子的图像。

这些（房屋和地图图像）将传递给模型，如

model.addAttribute("houses",houses);
model.addAttribute("mapOfImages",mapOfImages);

因此，现在在thyemleaf视图模板中，我可以：

<div data-th-each="house : ${houses}">
        <h3 data-th-text="${house.title}"></h3>
        <div data-th-each="image : ${mapOfImages.get(house.houseId)}">
          <h5 data-th-text="${image.fileName}"></h5>
          <h5 data-th-text="${image.type}"></h5>
        </div>
 </div>   

使用的数据库是Mongodb，它有两个独立的集合：house和image，也就是说，没有嵌入式集合，将图像绑定到房屋的唯一东西是image上的houseId属性。




Answer 1

您基本上希望将房屋对象流转换为图像对象流。

因此，使用flatMap（）转换通量

Mono<List<Image>> images = houseService.findAllHouses() // returns Flux<House>
  .flatMap(house -> imageService.findByHouseId(id)      // returns Flux<Image>
                        .filter(image -> "yes".equals(image.getCover()) && ... )) 
  .collectList();                                       //returns Mono<List<Image>>

这里可以使用CollectList（），因为您最有可能想要将图像转换为单个Mono

return images.map(imageList -> ServerResponse.ok()
                                       .body(fromObject(imageList)));

此外，我建议阅读关于何时使用哪个运算符的项目反应器参考。

编辑：

所以，你想要一个单声道

我将描述艰难的方式，其中图像不包含房屋id。我们需要某物，它链接属于特定房屋的图像列表。您可以为此定义一个类，也可以只使用reactor。util。作用元组2。这样，我们就可以使用collectMap（）：

Mono<Map<String, Collection<Image>>> images = houseService.findAllHouses()
     .flatMap(house -> imageService.findByHouseId(id)
                           .filter(...)
                           .map(image -> Tuples.of(id, image)))
     .collectMultiMap(tuple -> tuple.getT1(), 
                      tuple -> tuple.getT2());

当然，如果您有一个对房屋的引用，那么您可以再次省略映射（），直接使用集合多映射：

...
    .collectMultiMap(image -> image.getHouseId(), image -> image);