Java 8引入Stream API,提供函数式数据处理方式。通过stream()创建流,支持filter、map、sorted等中间操作及collect、forEach、count等终止操作,实现链式调用。示例中从用户列表筛选活跃用户并提取姓名。中间操作惰性执行,仅在终止操作时触发。支持IntStream等专用流进行sum、average等聚合计算。注意流不可重复消费,避免外部状态修改,大数据可用parallelStream并行处理。掌握Stream可简化复杂逻辑,提升代码可读性与维护性。

Java中的Stream API从Java 8开始引入,为集合数据的处理提供了更简洁、函数式的方式。相比传统的for循环或迭代器,Streams能让你以声明式风格操作数据,提升代码可读性和维护性。
创建Stream并执行基本操作
大多数集合类都提供了stream()方法来获取流。你可以对流进行过滤、映射、排序等中间操作,最后通过终止操作得到结果。
示例:- 使用
filter()筛选满足条件的元素 - 用
map()转换元素类型或提取字段 - 通过
collect()将结果收集为List、Set等集合
比如有一个用户列表,只想要活跃用户的姓名:
List.filter(user -> user.isActive())
.map(User::getName)
.collect(Collectors.toList());
常用中间操作与终止操作
Stream的操作分为中间操作(返回Stream)和终止操作(返回具体结果)。多个中间操作可以链式调用,只有遇到终止操作时才会真正执行。
立即学习“Java免费学习笔记(深入)”;
-
filter(Predicate):按条件保留元素 -
map(Function):转换每个元素 -
sorted()或sorted(Comparator):排序 -
distinct():去重(基于equals)
-
forEach(Consumer):遍历执行操作 -
collect(Collector):收集结果 -
count():返回元素数量 -
findFirst():返回第一个元素(Optional) -
anyMatch()/allMatch():判断是否存在或全部满足条件
处理数值型数据与聚合操作
对于数字类型的流,可以使用IntStream、LongStream、DoubleStream进行高效计算,避免装箱开销。
- 用
mapToInt()将对象流转为int流 - 调用
sum()、average()、max()等进行统计
例如统计所有用户年龄总和:
int totalAge = users.stream().mapToInt(User::getAge)
.sum();
避免常见误区
Stream虽然强大,但使用时要注意几点:
- 一个Stream只能被消费一次,重复使用会抛出异常
- 中间操作是惰性的,不调用终止操作不会执行
- 尽量避免在Stream中修改外部变量,保持函数纯净
- 大数据量时可考虑parallelStream()并行处理,但注意线程安全
基本上就这些。掌握Stream后,你会发现很多复杂的遍历逻辑可以几行代码搞定,而且语义清晰。










