JavaStream API的语法和基本操作_技术教程

Java Stream 是一次性管道，执行终端操作后即关闭，重复调用会抛 IllegalStateException；filter 保留元素、map 一对一转换、flatMap 展平嵌套流；需过滤 null 避免 NPE；并行流非万能，受限于数据量、操作状态及 IO 类型。

Stream 是一次性消费的，不能重复调用 `collect()` 或 `forEach()`

Java 的 Stream 不是数据容器，而是一次性管道。一旦执行了终端操作（如 collect()、forEach()、count()），流就关闭了。再调用会抛出 java.lang.IllegalStateException: stream has already been operated upon or closed。

错误写法：

List list = Arrays.asList("a", "b");
Stream s = list.stream();
s.collect(Collectors.toList());
s.forEach(System.out::println); // ❌ 报错

正确做法：每次需要新流就重新创建 —— list.stream().map(...).collect(...)，或把中间操作链写完整再执行终端操作
调试时别在中间插 forEach() 打断流；要用 peek()： stream.peek(System.out::println).filter(...)

`filter()`、`map()`、`flatMap()` 的关键区别

这三个是最常混用的中间操作，核心差异在「返回值类型」和「是否扁平化」：

filter(Predicate)：输入 T，输出仍是 T，但只保留满足条件的元素（数量 ≤ 原始）
map(Function)：输入 T，输出 R，一对一转换（数量不变）
flatMap(Function>)：输入 T，输出 Stream，然后自动“展平”一层（适合处理嵌套集合、Optional、字符串转字符流等）

例如把 List> 拉平成 List，必须用 flatMap：

listOfLists.stream()
    .flatMap(innerList -> innerList.stream())
    .collect(Collectors.toList());

空集合、null 元素与 `Optional` 的
配合要点

Stream 本身不拒绝 null 元素，但多数终端操作（如 collect()）在遇到 null 时可能抛 NullPointerException，尤其在使用 Collectors.toMap() 时键或值为 null 会直接失败。

安全过滤 null：stream.filter(Objects::nonNull)

避免 toMap() 因 key 为 null 失败：

stream.filter(Objects::nonNull)
    .collect(Collectors.toMap(
        item -> item.getId(), 
        item -> item.getName(),
        (a, b) -> a // 冲突解决，防止 key 重复
    ));