Stream流是Java 8引入的声明式数据处理工具,不存储也不修改源数据,通过链式操作高效处理集合或数组。其核心特点包括无存储性、函数式编程风格、惰性求值和只能消费一次。Stream操作分为中间操作和终止操作:中间操作如filter、map、flatMap、sorted、distinct、limit和skip等返回新Stream,支持链式调用;终止操作如forEach、collect、reduce、count、匹配判断和查找方法则触发计算并产生结果,执行后流失效。Stream可通过Collection.stream()、Arrays.stream()、Stream.of()、Stream.iterate()和Stream.generate()等方式创建,支持并行处理以提升性能,但需注意线程安全与开销。掌握其惰性机制与操作分类,可写出简洁高效的代码,关键在于合理组合操作,并牢记Stream的一次性特性。

Stream流是Java 8引入的一个重要特性,用于以声明式方式处理数据集合。它不是存储数据的结构,也不会修改源数据,而是通过一系列链式操作对集合或数组进行高效、便捷的处理。
1. 什么是Stream流
Stream可以理解为“数据流”,它从一个数据源(如集合、数组)中抽象出元素序列,并支持对这些元素进行各种操作。Stream本身不保存数据,也不改变原数据源,每次操作都会返回一个新的Stream实例。
核心特点包括:
- 无存储性:Stream不存储元素,只负责传输和处理。
- 函数式编程风格:操作基于函数式接口,常配合Lambda表达式使用。
- 惰性求值:中间操作不会立即执行,只有遇到终止操作时才会触发整个流程。
- 可消费一次:一个Stream只能被遍历一次,之后需重新生成。
2. Stream的操作类型
Stream操作分为两大类:中间操作和终止操作。
立即学习“Java免费学习笔记(深入)”;
中间操作(Intermediate Operations)这类操作返回一个新的Stream,支持链式调用。常见方法有:
- filter():按条件筛选元素。
- map():将每个元素转换成另一个对象。
- flatMap():将流中的每个值替换成流,然后把所有流连接成一个流。
- sorted():对元素排序。
- distinct():去除重复元素。
- limit()、skip():限制或跳过前若干个元素。
这类操作会触发实际计算,并产生结果或副作用,执行后Stream失效。
- forEach():遍历每个元素并执行操作。
- collect():将流中的元素收集到集合或其他结构中。
- reduce():聚合操作,如求和、拼接等。
- count():返回元素个数。
- anyMatch()、allMatch()、noneMatch():判断是否匹配指定条件。
- findFirst()、findAny():获取第一个或任意一个元素。
3. 创建Stream的方式
可以从多种数据源创建Stream:
- Collection.stream():如List、Set等集合调用stream()方法。
- Arrays.stream():将数组转为Stream。
- Stream.of():直接传入多个元素创建流。
- Stream.iterate() 和 Stream.generate():创建无限流,适合生成规律数据。
4. 并行Stream
Stream支持并行处理,利用多核CPU提升性能。通过调用parallelStream()或在已有流上调用parallel()即可启用并行模式。
并行Stream会将数据分片,分别处理后再合并结果。但并非所有场景都适合并行,需注意线程安全与性能开销。
基本上就这些。掌握Stream的核心概念有助于写出更简洁、可读性更强的数据处理代码。关键在于理解其惰性执行机制和操作分类,合理组合中间与终止操作完成目标。不复杂但容易忽略的是:Stream是一次性的,用完就得重来。










