引言
在现代Java开发中，Stream API 是处理集合数据的强大工具。它不仅让代码更加简洁易读，还能通过并行处理提升性能。本文将带你从基础概念入手，逐步深入Stream API的使用，并通过实战案例展示其强大功能。
1. 什么是Stream API？
Stream API 是Java 8引入的一个新特性，用于处理集合数据。它允许你以声明式的方式对数据进行操作，比如过滤、映射、排序等。Stream API的核心思想是将数据操作分为中间操作和终端操作。
- 中间操作：如
filter()、map()、sorted()，它们返回一个新的Stream，可以链式调用。 - 终端操作：如
collect()、forEach()、reduce()，它们触发Stream的处理并返回结果。
2. Stream API的核心操作
2.1 创建Stream
Stream可以通过多种方式创建：
java">// 从集合创建
List<String> list = Arrays.asList("Java", "Python", "C++");
Stream<String> stream = list.stream();
// 从数组创建
Stream<String> arrayStream = Arrays.stream(new String[]{"A", "B", "C"});
// 使用Stream.of()
Stream<Integer> numberStream = Stream.of(1, 2, 3, 4);
2.2 中间操作
- filter()：过滤元素
java">List<String> languages = Arrays.asList("Java", "Python", "C++", "JavaScript");
List<String> filtered = languages.stream()
.filter(lang -> lang.startsWith("J"))
.collect(Collectors.toList());
// 结果: ["Java", "JavaScript"]
- map()：转换元素
java">List<String> languages = Arrays.asList("Java", "Python", "C++");
List<Integer> lengths = languages.stream()
.map(String::length)
.collect(Collectors.toList());
// 结果: [4, 6, 3]
- sorted()：排序
java">List<String> sortedLanguages = languages.stream()
.sorted()
.collect(Collectors.toList());
// 结果: ["C++", "Java", "JavaScript", "Python"]
2.3 终端操作
- collect()：将Stream转换为集合
java">List<String> result = stream.collect(Collectors.toList());
- forEach()：遍历元素
java">languages.stream().forEach(System.out::println);
- reduce()：归约操作
java">Optional<String> combined = languages.stream()
.reduce((s1, s2) -> s1 + ", " + s2);
// 结果: "Java, Python, C++"
3. 并行Stream
Stream API 支持并行处理，只需将 stream() 替换为 parallelStream() 即可：
java">List<String> languages = Arrays.asList("Java", "Python", "C++", "JavaScript");
List<String> result = languages.parallelStream()
.filter(lang -> lang.length() > 3)
.collect(Collectors.toList());
4. 实战案例：统计文本中的单词频率
假设我们有一段文本，需要统计每个单词出现的频率：
java">String text = "Java is a programming language Java is widely used";
Map<String, Long> wordCounts = Arrays.stream(text.split(" "))
.collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));
// 结果: {Java=2, is=2, a=1, programming=1, language=1, widely=1, used=1}
5. 注意事项
- Stream是一次性的：一旦被消费，就不能重复使用。
- 避免副作用：Stream操作应尽量保持无状态，避免修改外部变量。
- 性能权衡：并行Stream并不总是更快，需根据数据量和操作复杂度评估。
6. 总结
Stream API 是Java中处理集合数据的利器，它让代码更加简洁、易读且高效。通过本文的学习，你应该已经掌握了Stream的基本用法，并能够在实际项目中灵活运用。希望这篇博客对你有所帮助！
推荐阅读文章
-
由 Spring 静态注入引发的一个线上T0级别事故（真的以后得避坑）
-
如何理解 HTTP 是无状态的，以及它与 Cookie 和 Session 之间的联系
-
HTTP、HTTPS、Cookie 和 Session 之间的关系
-
什么是 Cookie？简单介绍与使用方法
-
什么是 Session？如何应用？
-
使用 Spring 框架构建 MVC 应用程序：初学者教程
-
有缺陷的 Java 代码：Java 开发人员最常犯的 10 大错误
-
如何理解应用 Java 多线程与并发编程？
-
把握Java泛型的艺术：协变、逆变与不可变性一网打尽
-
Java Spring 中常用的 @PostConstruct 注解使用总结
-
如何理解线程安全这个概念？
-
理解 Java 桥接方法
-
Spring 整合嵌入式 Tomcat 容器
-
Tomcat 如何加载 SpringMVC 组件
-
“在什么情况下类需要实现 Serializable，什么情况下又不需要（一）？”
-
“避免序列化灾难：掌握实现 Serializable 的真相！（二）”
-
如何自定义一个自己的 Spring Boot Starter 组件（从入门到实践）
-
解密 Redis：如何通过 IO 多路复用征服高并发挑战！
-
线程 vs 虚拟线程：深入理解及区别
-
深度解读 JDK 8、JDK 11、JDK 17 和 JDK 21 的区别
-
10大程序员提升代码优雅度的必杀技，瞬间让你成为团队宠儿！
-
“打破重复代码的魔咒：使用 Function 接口在 Java 8 中实现优雅重构！”
-
Java 中消除 If-else 技巧总结
-
线程池的核心参数配置(仅供参考)
-
【人工智能】聊聊Transformer，深度学习的一股清流(13)
-
Java 枚举的几个常用技巧，你可以试着用用
-
由 Spring 静态注入引发的一个线上T0级别事故（真的以后得避坑）
-
如何理解 HTTP 是无状态的，以及它与 Cookie 和 Session 之间的联系
-
HTTP、HTTPS、Cookie 和 Session 之间的关系
-
使用 Spring 框架构建 MVC 应用程序：初学者教程
-
有缺陷的 Java 代码：Java 开发人员最常犯的 10 大错误
-
Java Spring 中常用的 @PostConstruct 注解使用总结
-
线程 vs 虚拟线程：深入理解及区别
-
深度解读 JDK 8、JDK 11、JDK 17 和 JDK 21 的区别
-
10大程序员提升代码优雅度的必杀技，瞬间让你成为团队宠儿！
-
探索 Lombok 的 @Builder 和 @SuperBuilder：避坑指南（一）
-
为什么用了 @Builder 反而报错？深入理解 Lombok 的“暗坑”与解决方案（二）
