首页 / Streams / Collectors.flatMapping()
Streams 中级

Collectors.flatMapping()

使用 flatMapping() 在分组收集器内部进行扁平化。

代码对比
✕ Java 8 
// Flatten within a grouping collector
// Required complex custom collector
Map<String, Set<String>> tagsByDept =
    // no clean way in Java 8
✓ Java 9+ 
var tagsByDept = employees.stream()
    .collect(groupingBy(
        Emp::dept,
        flatMapping(
            e -> e.tags().stream(),
            toSet()
        )
    ));
发现此代码有问题？ 告诉我们。
为什么现代方式更好
🧩

可组合

作为 groupingBy 内的下游收集器使用。

📏

更扁平

避免嵌套的 stream-inside-collector 模式。

📖

表达性强

flatMapping 的意图一目了然。

旧方式
嵌套 flatMap
现代方式
flatMapping()
自 JDK
9
难度
中级
JDK 支持
Collectors.flatMapping()
可用

自 JDK 9 起广泛可用（2017 年 9 月）

工作原理

Collectors.flatMapping() 在 groupingBy 等收集器内部将一对多映射作为下游收集器应用。这避免了 groupingBy 和 flatMap 的笨拙嵌套。

相关文档
Collectors.flatMapping() ↗
相关模式
Streams 入门

Optional.ifPresentOrElse()

Java 8
Optional<User> user = findUser(id);
if (user.isPresent()) {
    greet(user.get());
} else {
    handleMissing();
}
Java 9+
findUser(id).ifPresentOrElse(
    this::greet,
    this::handleMissing
);
悬停查看现代版 ➜
JDK 9+ →
Streams 入门

Stream.ofNullable()

Java 8
Stream<String> s = val != null
    ? Stream.of(val)
    : Stream.empty();
Java 9+
Stream<String> s =
    Stream.ofNullable(val);
悬停查看现代版 ➜
JDK 9+ →
Streams 中级

Stream.iterate() with predicate

Java 8
Stream.iterate(1, n -> n * 2)
    .limit(10)
    .forEach(System.out::println);
// can't stop at a condition
Java 9+
Stream.iterate(
    1,
    n -> n < 1000,
    n -> n * 2
).forEach(IO::println);
// stops when n >= 1000
悬停查看现代版 ➜
JDK 9+ →
分享 𝕏 🦋 in ⬡