Java中的Stream API：从入门到实战

引言

在现代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可以通过多种方式创建：

// 从集合创建
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()：过滤元素

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()：转换元素

List<String> languages = Arrays.asList("Java", "Python", "C++");
List<Integer> lengths = languages.stream().map(String::length).collect(Collectors.toList());
// 结果: [4, 6, 3]

• sorted()：排序

List<String> sortedLanguages = languages.stream().sorted().collect(Collectors.toList());
// 结果: ["C++", "Java", "JavaScript", "Python"]

2.3 终端操作

• collect()：将Stream转换为集合

List<String> result = stream.collect(Collectors.toList());

• forEach()：遍历元素

languages.stream().forEach(System.out::println);

• reduce()：归约操作

Optional<String> combined = languages.stream().reduce((s1, s2) -> s1 + ", " + s2);
// 结果: "Java, Python, C++"

3. 并行Stream

Stream API 支持并行处理，只需将 stream() 替换为 parallelStream() 即可：

List<String> languages = Arrays.asList("Java", "Python", "C++", "JavaScript");
List<String> result = languages.parallelStream().filter(lang -> lang.length() > 3).collect(Collectors.toList());

4. 实战案例：统计文本中的单词频率

假设我们有一段文本，需要统计每个单词出现的频率：

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 的“暗坑”与解决方案（二）