JavaStream常用方法大全

Java Stream API 的核心奥秘不在于死记硬背方法列表，而在于深刻理解“中间操作”与“终止操作”的根本分野——filter、map 等中间操作惰性不执行，只有接上 collect、forEach 等终止操作才会真正触发计算；同时必须警惕 collect 需搭配 Collectors 正确使用、peek 仅用于调试不可替代 forEach、findFirst 必须安全处理 Optional、以及同一 Stream 实例不可重复消费等关键陷阱。掌握这些底层逻辑，才能写出高效、健壮、不易出错的函数式代码。

Java 的 Stream API 不是“多学几个方法就行”，而是得先分清哪些操作是中间操作、哪些是终止操作，否则链式调用会出错或不执行。

哪些方法必须成对出现：中间操作 vs 终止操作

Stream 是惰性求值的——只写 filter()、map()、sorted() 这类中间操作，什么都不会发生。必须接一个终止操作（如 collect()、forEach()、count()）才会真正触发计算。

• 常见中间操作：filter()、map()、flatMap()、sorted()、distinct()、limit()、skip()
• 常见终止操作：collect()、forEach()、reduce()、count()、findFirst()、anyMatch()、allMatch()
• 错误示例：

  list.stream().filter(x -> x > 0).map(String::valueOf); // 没有终止操作 → 白写

collect() 怎么选下游收集器才不踩坑

collect() 是最常用也最容易写错的终止操作。它不直接返回 List 或 Map，而是依赖 Collectors 工具类提供具体行为。

• 要转 List：用 Collectors.toList()，不是 new ArrayList()
• 要转 Set：用 Collectors.toSet()，注意无序且去重
• 要转 Map：必须指定 key 和 value，且 key 不能重复，否则抛 IllegalStateException
• 安全写法（避免 key 冲突）：

  Map<integer string> map = list.stream()
      .collect(Collectors.toMap(
          Person::getId,
          Person::getName,
          (v1, v2) -> v1 // 冲突时保留第一个
      ));</integer>

forEach() 和 peek() 看似相似，用途完全不同

forEach() 是终止操作，用于消费流元素；peek() 是中间操作，仅用于调试或副作用，但不能替代 forEach()。

• 想遍历并打印日志（调试）→ 用 peek()，可继续链式调用

  list.stream()
      .filter(x -> x > 0)
      .peek(System.out::println) // ✅ 中间操作，不影响后续
      .map(x -> x * 2)
      .collect(Collectors.toList());

• 只想遍历做 I/O 或修改外部状态 → 用 forEach()，但它是终止操作，后面不能再接其他 Stream 方法

  list.stream().forEach(System.out::println); // ❌ 后面加 .map() 编译失败

• 并发流中 forEach() 不保证顺序，要顺序遍历请用 forEachOrdered()

Optional 和 findFirst() 配合时别忘了判空

findFirst() 返回的是 Optional，不是原始类型。直接调 .get() 是高危操作，一旦流为空就抛 NoSuchElementException。

• 安全做法优先用 orElse()、orElseGet() 或 ifPresent()
• 反模式：

  String first = list.stream().filter(s -> s.startsWith("a")).findFirst().get(); // 可能崩溃

• 推荐写法：

  String first = list.stream()
      .filter(s -> s.startsWith("a"))
      .map(String::toUpperCase)
      .findFirst()
      .orElse("default");

• 如果后续逻辑复杂，用 ifPresent() 更清晰：

  optional.ifPresent(value -> doSomething(value));

Stream 的核心约束很明确：中间操作可叠加，终止操作只能有一个，且不可重复使用同一 Stream 实例。很多人卡在“为什么没输出”“为什么报错说 stream 已关闭”，往往就是漏了终止操作，或在同一个 Stream 上多次调用了 collect() 或 forEach()。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。