前言
Java 8 引入了 Stream API，它是一种用于处理集合（Collection）数据的强大工具。Stream 不是数据结构，而是对数据源进行操作的一种方式，支持声明式、函数式的操作，如过滤、映射、排序等。
Stream 操作分为中间操作和终端操作：
- 中间操作（Intermediate operations）：返回一个 Stream，可以链式调用。
- 终端操作（Terminal operations）：触发实际计算，返回非 Stream 类型的结果。
获取 Stream 的方式
常见的创建 Stream 的方法如下：
// 从集合创建
List<String> list = Arrays.asList("a", "b", "c");
Stream<String> stream = list.stream();
// 从数组创建
int[] arr = {1, 2, 3};
IntStream intStream = Arrays.stream(arr);
// 使用 Stream.of 创建
Stream<String> stream = Stream.of("a", "b", "c");
// 无限流（generate / iterate）
Stream<Integer> infiniteStream = Stream.generate(() -> 1);
Stream<Integer> iterateStream = Stream.iterate(0, n -> n + 2);
Stream 的常用操作
filter
用于过滤符合条件的数据：
List<String> filtered = list.stream()
.filter(s -> s.startsWith("J"))
.toList();
map
将每个元素映射成另一个对象：
List<String> upperCase = list.stream()
.map(String::toUpperCase)
.toList();
sorted
对流中的元素进行排序：
List<String> sorted = list.stream()
.sorted()
.toList();
也可以自定义排序规则
.sorted((s1, s2) -> s2.compareTo(s1))
或者使用 Comparator：
.sorted(Comparator.reverseOrder())
limit / skip
限制流的大小或跳过前 N 个元素：
List<String> limited = list.stream()
.limit(2)
.toList();
List<String> skipped = list.stream()
.skip(2)
.toList();
distinct
去重，基于 equals() 方法判断重复项：
List<String> unique = list.stream()
.distinct()
.toList();
forEach
遍历流中的每个元素：
list.stream()
.forEach(System.out::println);
collect
收集流的结果到容器中，常配合 Collectors 使用：
List<String> filteredList = list.stream()
.filter(s -> s.length() > 3)
.collect(Collectors.toList());
String joined = list.stream()
.collect(Collectors.joining(", "));
reduce
归约操作，合并流中的元素为一个结果：
Optional<String> reduced = list.stream()
.reduce((s1, s2) -> s1 + "-" + s2);
也可以提供初始值：
String result = list.stream()
.reduce("start", (acc, s) -> acc + "-" + s);
并行流（Parallel Stream）
使用并行流可以提高大数据量下的处理效率：
List<String> parallelResult = list.parallelStream()
.filter(s -> s.startsWith("A"))
.toList();
需要注意线程安全问题和是否适合并行处理。
注意事项
- Stream 只能被消费一次，再次使用会抛出异常。
- 中间操作是惰性求值的，只有遇到终端操作才会真正执行。
- 避免在流中修改外部变量，容易引发并发问题。
- 适当使用并行流，不是所有情况都适用。
- 注意空指针异常，尤其是在处理集合时。
总结
Stream API 极大地简化了对集合的操作，使得代码更简洁、可读性更高。通过链式调用，我们可以清晰地表达数据处理逻辑。但也要注意其性能特性和使用场景，合理选择是否使用 Stream 或传统循环。
