如何将MinIO中的文件夹下载为Zip文件？解决空Zip问题

问题背景 #

已完成以下操作：

• 递归获取MinIO存储桶内所有对象：

Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder()
    .bucket(bucketName).recursive(true).build());

• 获取单个对象的InputStream流：

InputStream stream = minioClient.getObject(GetObjectArgs.builder()
.bucket(bucketName).object(objectName).build());

尝试将多个InputStream转换为Zip文件时，生成的Zip为空，使用的代码如下：

ByteArrayOutputStream fos = new ByteArrayOutputStream();
ZipOutputStream zipOut = new ZipOutputStream(fos);
ZipEntry zipEntry1 = new ZipEntry(objectName);
zipEntry1.setSize(resource.contentLength());
zipEntry1.setTime(System.currentTimeMillis());
zipOut.putNextEntry(zipEntry1);
StreamUtils.copy(stream.readAllBytes(), zipOut);
zipOut.closeEntry();

修复方案 #

1. 完整代码实现 #

需要遍历所有MinIO对象并逐个添加到Zip中，同时修正流处理逻辑：

ByteArrayOutputStream fos = new ByteArrayOutputStream();
// 使用try-with-resources自动管理流资源
try (ZipOutputStream zipOut = new ZipOutputStream(fos)) {
    // 遍历所有MinIO返回的对象结果
    for (Result<Item> result : results) {
        Item item = result.get();
        String objectName = item.objectName();
        
        // 获取当前对象的输入流
        try (InputStream stream = minioClient.getObject(GetObjectArgs.builder()
                .bucket(bucketName).object(objectName).build())) {
            
            // 创建Zip条目，使用MinIO返回的元数据
            ZipEntry zipEntry = new ZipEntry(objectName);
            zipEntry.setSize(item.size());
            zipEntry.setTime(item.lastModified().toEpochMilli());
            zipOut.putNextEntry(zipEntry);
            
            // 缓冲区循环读取流数据，避免大文件内存溢出
            byte[] buffer = new byte[4096];
            int bytesRead;
            while ((bytesRead = stream.read(buffer)) != -1) {
                zipOut.write(buffer, 0, bytesRead);
            }
            
            zipOut.closeEntry();
        }
    }
    // 完成Zip文件写入，确保所有数据刷新到输出流
    zipOut.finish();
} catch (Exception e) {
    e.printStackTrace();
}

// 此时fos中存储了完整的Zip数据，可用于下载或后续处理

2. 核心修复点 #

• 遍历所有对象：原代码仅处理单个对象，未循环MinIO返回的全部结果，导致Zip无有效内容。
• 流资源管理：用try-with-resources自动关闭流，避免资源泄漏，同时保证数据完整写入。
• 元数据正确性：直接使用MinIO返回的item.size()和item.lastModified()，替代不可靠的resource.contentLength()，避免条目信息异常。
• 调用finish()方法：必须执行该方法完成Zip文件的最终写入，否则数据可能未完全刷新到ByteArrayOutputStream。
• 高效流复制：替换stream.readAllBytes()为缓冲区循环读取，避免大文件占用过多内存。

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