Java 怎么实现输入流的多次重复读取与重置操作-java教程-PHP中文网

java输入流默认单次顺序读取，需缓存数据实现重置：bytearrayinputstream适用于小中数据；bufferedinputstream的mark/reset有限制；apache commons io的resettableinputstream自动处理缓存；自定义流可精细控制缓存策略。

java 怎么实现输入流的多次重复读取与重置操作

Java 中的输入流（InputStream）默认是**单次顺序读取**的，一旦读完或指针前移，无法直接“倒带”重读。要实现多次重复读取与重置，核心思路是：**将数据缓存到内存或临时存储中，再基于缓存构建可重置的新流**。

使用 `ByteArrayInputStream` 缓存全部内容

适用于小到中等大小的数据（如配置文件、短文本、小图片），不占额外磁盘资源，性能好。

操作步骤：

先用原始输入流（如 FileInputStream 或网络流）读取全部字节到 byte[] 数组
每次需要读取时，新建一个 ByteArrayInputStream 包装该数组
ByteArrayInputStream 支持 reset() 和 mark()/markSupported()（默认支持）

示例：

byte[] data = Files.readAllBytes(Paths.get("data.txt")); // 或手动 readFully
InputStream reusableStream = new ByteArrayInputStream(data);

// 第一次读取
reusableStream.read(...);
reusableStream.mark(1024);
// ...处理中

// 想重来？直接新建一个
reusableStream = new ByteArrayInputStream(data); // 完全重置

用 `BufferedInputStream` + `mark()/reset()`（有限制）

仅当原始流本身支持 mark（如 FileInputStream 在部分 JDK 版本中支持，但 SocketInputStream 不支持），且你只打算重置一小段（需提前 mark(int readlimit)）。

注意：不是所有流都支持 mark/reset，调用前务必检查 markSupported() 返回 true。

OpenJDK 24

下载

示例：

InputStream raw = new FileInputStream("data.txt");
if (raw.markSupported()) {
    BufferedInputStream bis = new BufferedInputStream(raw, 8192);
    bis.mark(10000); // 最多能 reset 回 10000 字节内
    bis.read(...);
    bis.reset(); // 恢复到 mark 处
} else {
    System.out.println("底层流不支持 mark/reset");
}

借助第三方库：Apache Commons IO 的 `ResettableInputStream`

对不支持 mark 的流（如 HttpURLConnection.getInputStream()），可用 ResettableInputStream 自动缓存已读内容到内存或临时文件。

特点：

自动选择缓存策略：小数据走内存（ByteArrayInputStream），大数据走临时文件
调用 reset() 即可回到开头，无需关心底层是否支持
需引入依赖：org.apache.commons:commons-io

示例：

InputStream raw = getNetworkInputStream(); // 如 HTTP 响应流
InputStream resettable = new ResettableInputStream(raw);
resettable.read(...);
resettable.reset(); // 安全重置，内部已缓存
// 可重复调用 reset()