如何修改Reactor示例实现flatMap的一对多元素转换？

要验证flatMap的一对多特性，核心是让每个输入元素返回一个包含多个输出对象的流/可迭代集合，而非单个对象。flatMap会自动将这些子流的元素扁平化合并成一个最终的输出流，这样就能实现N个输入生成N*M个输出的效果。

以Java Stream为例的实现 #

假设我们从3个球队名称（输入字符串），每个球队生成2名球员（输出Player对象），最终得到6个Player。

1. 定义Player实体类 #

class Player {
    private String name;
    private String position;
    private String team;

    public Player(String name, String position, String team) {
        this.name = name;
        this.position = position;
        this.team = team;
    }

    @Override
    public String toString() {
        return String.format("%s (%s) - %s", name, position, team);
    }
}

2. 核心flatMap逻辑实现 #

import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class FlatMapOneToManyDemo {
    public static void main(String[] args) {
        // 3个输入字符串：球队名称
        List<String> teams = List.of("Lakers", "Warriors", "Bulls");

        // flatMap实现一对多：每个球队生成2名球员
        List<Player> allPlayers = teams.stream()
                .flatMap(team -> generateTwoPlayers(team))
                .collect(Collectors.toList());

        // 打印结果：共6个Player对象
        allPlayers.forEach(System.out::println);
    }

    // 每个输入球队返回包含2个Player的Stream
    private static Stream<Player> generateTwoPlayers(String team) {
        return Stream.of(
                new Player(team + " Starter Forward", "Forward", team),
                new Player(team + " Starter Guard", "Guard", team)
        );
    }
}

代码说明 #

• map的逻辑是输入单个元素→返回单个元素，而这里flatMap的逻辑是输入单个球队→返回包含2个Player的Stream。
• flatMap会把3个独立的Stream（每个含2个元素）扁平化合并成一个包含6个元素的Stream，最终收集到List中就是6个Player对象。

反应式框架（如RxJava）的实现思路 #

如果是异步非阻塞场景，逻辑完全一致：每个输入元素返回一个包含多个元素的Observable/Flowable，flatMap会合并这些流：

import io.reactivex.rxjava3.core.Observable;

public class RxJavaFlatMapDemo {
    public static void main(String[] args) {
        Observable.just("Lakers", "Warriors", "Bulls")
                .flatMap(team -> Observable.just(
                        new Player(team + " Forward", "Forward", team),
                        new Player(team + " Guard", "Guard", team)
                ))
                .subscribe(player -> System.out.println(player));
    }
}

关键总结 #

flatMap的一对多特性本质是：将每个输入元素映射为一个多元素的流，再将所有流的元素平铺到一个输出流中。只要保证每个输入对应的子流包含多个元素，就能轻松实现输入数量和输出数量不相等的一对多转换。

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