在处理大型 ZIP 归档文件时，将整个文件内容一次性读取到内存中（例如使用 InputStream.readAllBytes()）再进行处理，可能会导致严重的内存溢出问题。特别是当文件大小接近或超过可用内存时，这种做法是不可取的。更好的方法是采用流式处理，即每次只读取和写入一小部分数据，从而显著降低内存占用。
正如摘要所述，InputStream.transferTo(OutputStream) 方法提供了一种高效的流式数据传输方式，避免了将整个文件加载到内存中。
使用 InputStream.transferTo(OutputStream) 方法
InputStream.transferTo(OutputStream) 方法从输入流读取所有字节，并将它们写入到给定的输出流。该方法内部使用固定大小的缓冲区（在 Java 17 中为 8KB），以块为单位读取和写入数据，从而实现高效的流式传输。
以下是一个使用 InputStream.transferTo(OutputStream) 方法解压 ZIP 文件的示例代码：
import java.io.*;
import java.util.zip.ZipInputStream;
import java.util.zip.ZipEntry;
public class ZipExtractor {
public static void extractZip(InputStream inputStream, String destinationDirectory) throws IOException {
try (ZipInputStream zipIn = new ZipInputStream(inputStream)) {
ZipEntry entry = zipIn.getNextEntry();
while (entry != null) {
String filePath = destinationDirectory + File.separator + entry.getName();
if (!entry.isDirectory()) {
// 如果是文件，则提取
try (FileOutputStream fileOut = new FileOutputStream(filePath)) {
zipIn.transferTo(fileOut);
}
} else {
// 如果是目录，则创建
File dir = new File(filePath);
dir.mkdirs();
}
zipIn.closeEntry();
entry = zipIn.getNextEntry();
}
}
}
public static void main(String[] args) {
String zipFilePath = "path/to/your/archive.zip"; // 替换为你的 ZIP 文件路径
String destinationDirectory = "path/to/your/destination"; // 替换为你的目标目录
try (FileInputStream fis = new FileInputStream(zipFilePath)) {
extractZip(fis, destinationDirectory);
System.out.println("ZIP 文件解压成功！");
} catch (IOException e) {
System.err.println("ZIP 文件解压失败：" + e.getMessage());
e.printStackTrace();
}
}
}
代码解释：
- extractZip(InputStream inputStream, String destinationDirectory) 方法： 接受一个 InputStream 和目标目录作为参数。
- ZipInputStream zipIn = new ZipInputStream(inputStream)： 创建一个 ZipInputStream 对象，用于读取 ZIP 文件的内容。
- zipIn.getNextEntry()： 获取 ZIP 文件中的下一个条目（文件或目录）。
-
循环处理每个条目：
- 如果条目是文件，则创建 FileOutputStream 并使用 zipIn.transferTo(fileOut) 将条目的内容写入文件。
- 如果条目是目录，则创建目录。
- zipIn.closeEntry()： 关闭当前条目。
- 主函数 main()： 创建 FileInputStream 读取 ZIP 文件，然后调用 extractZip() 方法进行解压。
注意事项：
- 确保目标目录存在，或者在代码中创建它。
- 处理 IOException 异常，以便在发生错误时进行适当的错误处理。
- 使用 try-with-resources 语句可以确保 InputStream 和 OutputStream 在使用完毕后自动关闭，避免资源泄漏。
- InputStream.transferTo(OutputStream) 方法在 Java 9 及以上版本可用。如果使用 Java 8 或更早版本，可以使用循环读取和写入缓冲区的替代方案。
Java 8 及更早版本的替代方案
如果你的项目使用 Java 8 或更早版本，InputStream.transferTo() 方法不可用。可以使用以下代码实现类似的功能：
import java.io.*;
import java.util.zip.ZipInputStream;
import java.util.zip.ZipEntry;
public class ZipExtractorLegacy {
private static final int BUFFER_SIZE = 8192; // 8KB 缓冲区
public static void extractZip(InputStream inputStream, String destinationDirectory) throws IOException {
try (ZipInputStream zipIn = new ZipInputStream(inputStream)) {
ZipEntry entry = zipIn.getNextEntry();
while (entry != null) {
String filePath = destinationDirectory + File.separator + entry.getName();
if (!entry.isDirectory()) {
// 如果是文件，则提取
try (FileOutputStream fileOut = new FileOutputStream(filePath)) {
byte[] buffer = new byte[BUFFER_SIZE];
int bytesRead;
while ((bytesRead = zipIn.read(buffer)) != -1) {
fileOut.write(buffer, 0, bytesRead);
}
}
} else {
// 如果是目录，则创建
File dir = new File(filePath);
dir.mkdirs();
}
zipIn.closeEntry();
entry = zipIn.getNextEntry();
}
}
}
public static void main(String[] args) {
String zipFilePath = "path/to/your/archive.zip"; // 替换为你的 ZIP 文件路径
String destinationDirectory = "path/to/your/destination"; // 替换为你的目标目录
try (FileInputStream fis = new FileInputStream(zipFilePath)) {
extractZip(fis, destinationDirectory);
System.out.println("ZIP 文件解压成功！");
} catch (IOException e) {
System.err.println("ZIP 文件解压失败：" + e.getMessage());
e.printStackTrace();
}
}
}代码解释：
- 使用一个 8KB 的缓冲区 buffer。
- 使用 zipIn.read(buffer) 从输入流中读取数据到缓冲区。
- 使用 fileOut.write(buffer, 0, bytesRead) 将缓冲区中的数据写入输出流。
- 循环读取和写入，直到 zipIn.read() 返回 -1，表示已经到达流的末尾。
总结
在处理大型 ZIP 文件时，避免将整个文件加载到内存中至关重要。InputStream.transferTo(OutputStream) 方法（Java 9+）提供了一种高效的流式传输方式，可以显著降低内存占用。对于 Java 8 及更早版本，可以使用循环读取和写入缓冲区的替代方案。选择合适的方案可以有效地避免内存溢出问题，提高程序的稳定性和性能。记住，正确处理输入输出流，并使用 try-with-resources 语句可以确保资源在使用完毕后被正确释放。
