如何将 Flux 的每个元素与需要元素属性的另一个 Flux 组合起来

Question

我有一个关于 Spring WebFlux 和 Reactor 的问题。我正在尝试编写一个简单的场景，其中在 GET 端点中，我返回代表实体的 DTO Flux，并且每个实体都有代表另一个实体的其他 DTO 的集合。这里请遵循详细信息。

我有两个实体，Person 和 Song，定义如下：

@Data
public class Person {
    @Id
    private Long id;
    private String firstName;
    private String lastName;
}

@Data
public class Song {
    @Id
    private Long id;
    private String title;
    private Long authorId;
}

这些实体由以下 DTO 表示：

@Data
public class SongDTO {
    private Long id;
    private String title;
    public static SongDTO from(Song s) {
        // converts Song to its dto
    }
}

@Data
public class PersonDTO {
    private Long id;
    private String firstName;
    private String lastName;
    private List<SongDTO> songs = new ArrayList<>();
    public static PersonDTO from(Person p, List<Song> songs) {
        // converts person to its dto, invokes SongDTO.from on each song 
        // and adds the result to personDTO.songs
    }
}

我的服务（为简洁起见，此处未显示）确实返回 Mono 和 Flux。然后我有以下 RestController：

@RestController
@RequestMapping("/people")
public class PersonController {
    @Autowired PersonService people;
    @Autowired SongService songs;
    
    @GetMapping(produces = MediaType.APPLICATION_JSON_VALUE)
    public Flux<PersonDTO> findAllPeople() {
        return people.findAll()
                .map(person -> PersonDTO.from(person, /* HERE */ new ArrayList<>()));
        // TODO: find the songs of each author reactively and put the results in personDTO.songs
    }
}

现在，我的问题是：我该如何

• 调用songs.findByAuthorId(person.getId())
• 将返回的 Flux 转换为 SongDTO 的 List
• 以反应方式设置 PersonDTO 中的列表？

我尝试查看 Reactor 的文档，但没有成功，搜索了其他 StackOverflow 问题和整个互联网，但找不到任何内容，很可能是因为我不太确定如何表达我的搜索。有人可以提供提示吗？

谢谢

Answer 1

您可以使用flatMap+ map：

people.findAll()
      .flatMap(person -> songs.findByAuthorId(person.getId())
                              .collectList()
                              .map(songList -> PersonDTO.from(person, songList)));