如何计算InputStream的CRC32校验和并重复使用该输入流

InputStream是单向读取的流，读完后指针会停在末尾，除非流本身支持重置，否则无法直接重新读取。下面是几种实用的解决办法：

方法一：利用流的mark/reset功能（仅支持该特性的流） #

如果你的InputStream实现支持mark()和reset()（比如ByteArrayInputStream），可以在计算校验和前标记流的起始位置，计算完成后重置指针：

private long calculateChecksum(InputStream stream) throws IOException {
    // 先确认流是否支持mark/reset操作
    if (!stream.markSupported()) {
        throw new IllegalArgumentException("该流不支持mark/reset");
    }
    // 标记当前位置，参数设为足够大的值，确保能容纳整个流内容
    stream.mark(Integer.MAX_VALUE);
    
    CRC32 crc = new CRC32();
    byte[] buffer = new byte[8192];
    int length;
    while ((length = stream.read(buffer)) > 0) {
        crc.update(buffer, 0, length);
    }
    
    // 重置流到之前标记的位置
    stream.reset();
    return crc.getValue();
}

之后即可正常读取流内容：

long crcValue = calculateChecksum(inputStream);
String text = IOUtils.toString(inputStream, UTF_8);

注意：像FileInputStream这类默认不支持mark/reset的流，此方法不适用。

方法二：将流内容复制到内存中复用 #

把原流的内容读取到ByteArrayOutputStream，再转换成可重复读取的ByteArrayInputStream，这样就能多次操作：

// 先把原流内容复制到内存
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] buffer = new byte[8192];
int length;
while ((length = inputStream.read(buffer)) > 0) {
    baos.write(buffer, 0, length);
}
byte[] data = baos.toByteArray();

// 生成可复用的流
InputStream reusableStream = new ByteArrayInputStream(data);

// 计算校验和
long crcValue = calculateChecksum(reusableStream);
// 重置指针（或直接新建一个ByteArrayInputStream）
reusableStream.reset();
// 读取字符串
String text = IOUtils.toString(reusableStream, UTF_8);

缺点：如果流内容过大，会占用大量内存，适合处理小体积的流。

方法三：一次读取同时完成校验和与字符串转换 #

最高效的方式是只读取一次流，同时完成CRC32计算和字符串转换，避免重复读取的开销：

private Pair<Long, String> calculateChecksumAndReadString(InputStream stream, Charset charset) throws IOException {
    CRC32 crc = new CRC32();
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    byte[] buffer = new byte[8192];
    int length;
    while ((length = stream.read(buffer)) > 0) {
        crc.update(buffer, 0, length);
        baos.write(buffer, 0, length);
    }
    String text = baos.toString(charset.name());
    return new Pair<>(crc.getValue(), text);
}

使用时直接调用：

Pair<Long, String> result = calculateChecksumAndReadString(inputStream, StandardCharsets.UTF_8);
long crcValue = result.getKey();
String text = result.getValue();

此方法无需考虑流的重置问题，且仅读取一次流，性能最优。

内容的提问来源于stack exchange，提问作者tony