Spring响应式编程中如何从两个Flux<对象>获取Flux或List？

嗨，作为Spring响应式的新手，这种把主数据和关联数据配对的需求太常见啦！我来给你分享两种实用的处理方式，帮你轻松搞定这个场景。

方法一：使用DTO组合数据（推荐） #

首先建议你定义一个专门的DTO类，用来封装House和它对应的图片集合，这样能保持原实体类的纯净性：

// 定义HouseWithImages DTO
public class HouseWithImages {
    private House house;
    private List<Image> images;

    // 构造函数、getter和setter
    public HouseWithImages(House house, List<Image> images) {
        this.house = house;
        this.images = images;
    }

    // 省略getter、setter方法
}

然后在控制器里，通过flatMap来遍历每个House，查询对应的图片并组合：

@RestController
@RequestMapping("/api")
public class HouseController {

    private final HouseService houseService;
    private final ImageService imageService;

    // 构造注入服务类
    public HouseController(HouseService houseService, ImageService imageService) {
        this.houseService = houseService;
        this.imageService = imageService;
    }

    @GetMapping("/houses-with-images")
    public Flux<HouseWithImages> getHousesWithAllImages() {
        return houseService.getAllHouses() // 获取所有房屋的Flux<House>
                .flatMap(house -> 
                    // 针对当前房屋查询对应的图片，转成Mono<List<Image>>
                    imageService.findByHouseId(house.getId())
                        .collectList()
                        // 把House和图片列表组合成HouseWithImages
                        .map(images -> new HouseWithImages(house, images))
                );
    }
}

方法二：直接扩展House实体类 #

如果你不想额外定义DTO，也可以给House类添加一个images字段，直接把图片集合绑定到原实体上：

// 修改House实体类，添加images字段
public class House {
    private Long id;
    private String address;
    // 其他原有字段
    private List<Image> images; // 新增的图片集合字段

    // 省略原有getter、setter，新增images的getter和setter
}

对应的控制器代码：

@GetMapping("/houses")
public Flux<House> getHousesWithImages() {
    return houseService.getAllHouses()
            .flatMap(house -> 
                imageService.findByHouseId(house.getId())
                    .collectList()
                    .map(images -> {
                        house.setImages(images);
                        return house;
                    })
            );
}

关键知识点说明 #

• flatMap：用来将每个House对象转换成一个Mono<HouseWithImages>（或Mono<House>），最终合并成Flux返回，它是异步并行处理的，能提升查询效率；如果需要顺序处理，可以换成concatMap。
• collectList()：把Flux<Image>转换成Mono<List<Image>>，这样就能把一个房屋的所有图片收集成一个列表，方便和房屋对象绑定。

这样处理后，前端就能拿到每个房屋及其对应的完整图片集合啦～

内容的提问来源于stack exchange，提问作者ace