Java 8 Stream 是否需要关闭？

1. 概述

Java 8 引入了 Lambda 表达式，让代码变得更简洁、更具函数式风格。其中，Stream API 和 函数式接口 是这次变革的核心。

本文将聚焦一个常见但容易被忽视的问题：我们是否需要显式关闭 Java 8 的 Stream？
从资源管理的角度出发，帮你理清什么时候该关、什么时候不用关，避免踩坑。

2. Stream 的关闭机制

Java 8 中的 Stream 接口继承自 BaseStream，而后者实现了 AutoCloseable：

public interface Stream<T> extends BaseStream<T, Stream<T>> {
    // ...
}

public interface BaseStream<T, S extends BaseStream<T, S>> extends AutoCloseable {
    // ...
}

✅ 看上去像是必须手动关闭的资源？但事实没那么简单。

虽然 Stream 实现了 AutoCloseable，并不代表所有 Stream 都需要显式关闭。是否需要关闭，取决于它的底层资源类型。

下面我们分两种情况讨论。

2.1 基于集合、数组和生成器的 Stream ❌ 不需要关闭

大多数情况下，我们是通过集合、数组或生成方法创建 Stream：

List<String> colors = List.of("Red", "Blue", "Green")
    .stream()
    .filter(c -> c.length() > 4)
    .map(String::toUpperCase)
    .collect(Collectors.toList());

或者使用随机数生成无限流：

Random random = new Random();
random.ints().takeWhile(i -> i < 1000).forEach(System.out::println);

又或者基于数组创建：

String[] colors = {"Red", "Blue", "Green"};
Arrays.stream(colors).map(String::toUpperCase).toArray();

⚠️ 这类 Stream 的唯一“资源”就是内存，而 JVM 的 垃圾回收机制（GC）会自动回收，无需手动干预。

✅ 结论：

**来自集合、数组、或内存生成的 Stream，不需要也不应该显式调用 close()**。

2.2 基于 IO 资源的 Stream ✅ 必须关闭

某些 Stream 是由外部资源（如文件、网络）驱动的，它们持有操作系统级别的句柄（如文件描述符），这类 Stream 必须显式关闭，否则会导致资源泄漏。

典型例子：Files.lines() —— 它会打开一个文件并逐行读取：

Files.lines(Paths.get("/path/to/data.csv"))
    .flatMap(line -> Arrays.stream(line.split(",")))
    .map(String::trim)
    .filter(s -> !s.isEmpty())
    .forEach(System.out::println);

🔍 背后发生了什么？

Files.lines() 内部会打开一个 FileChannel
当 Stream 被消费时，这个通道保持打开状态
如果你不关闭 Stream，FileChannel 就不会释放 → 文件句柄泄漏

⚠️ 在高并发或长时间运行的应用中，这种泄漏可能导致：

文件句柄耗尽（Too many open files）
系统级错误
性能下降甚至服务崩溃

✅ 正确做法：使用 try-with-resources 自动关闭

try (Stream<String> lines = Files.lines(Paths.get("/path/to/data.csv"))) {
    lines.flatMap(line -> Arrays.stream(line.split(",")))
         .map(String::trim)
         .filter(s -> !s.isEmpty())
         .forEach(System.out::println);
}

这样即使中间发生异常，JVM 也会确保 close() 被调用。

📌 关键点总结：

Stream 来源	是否需要 close	原因
`Collection.stream()`	❌ 否	仅内存资源，GC 自动回收
`Arrays.stream()`	❌ 否	同上
`Stream.of()`, `Stream.generate()`	❌ 否	内存中生成
`Files.lines()`	✅ 是	底层持有 FileChannel
`BufferedReader.lines()`	✅ 是	持有文件/IO 句柄
`JarFile.stream()`	✅ 是	归档文件资源

🔔 记住一句话：凡是涉及 IO、文件、网络、JAR 包等外部资源的 Stream，都必须关闭！

⚠️ 注意事项：

重复关闭会抛异常：调用已关闭的 Stream 的 close() 会触发 IllegalStateException
尽早关闭：不要让 IO Stream 的作用域超出必要范围
避免在并行流中处理 IO Stream：尤其是在 try-with-resources 外部传递 Stream，容易出错

3. 总结

场景	是否关闭	推荐做法
内存数据源（集合、数组、生成器）	❌ 不需要	直接使用，无需管理
IO 数据源（文件、JAR、Socket）	✅ 必须关闭	使用 `try-with-resources` 包装

简单粗暴一句话总结：

Stream 是否要 close，看它背后有没有“真正的资源” —— 有 IO 就关，纯内存就不关。

搞清楚这一点，就能避免资源泄漏，也能避免画蛇添足地给 List.stream() 加 try 块。

🔗 示例代码已托管至 GitHub：https://github.com/baeldung/java-streams

Persistence

REST

Security

1. 概述

2. Stream 的关闭机制

2.1 基于集合、数组和生成器的 Stream ❌ 不需要关闭

2.2 基于 IO 资源的 Stream ✅ 必须关闭

3. 总结