ASP.NET Core生成ZIP压缩包的终极实战指南

// 在.csproj文件中添加必要依赖（确保版本兼容性！）
<ItemGroup>
  <PackageReference Include="System.IO.Compression" Version="6.0.0" />
  <!-- 推荐添加异步处理支持 -->
  <PackageReference Include="System.IO.Compression.ZipFile" Version="6.0.0" />
</ItemGroup>

/// <summary>
/// ZIP压缩核心控制器
/// </summary>
[ApiController]
[Route("api/[controller]")]
public class ZipController : ControllerBase
{
    /// <summary>
    /// 生成ZIP文件的核心方法
    /// </summary>
    [HttpGet("generate")]
    public async Task<IActionResult> GenerateZip()
    {
        // 1. 准备文件路径列表（示例：本地文件）
        var filePaths = new List<string>
        {
            "C:/Files/Report1.pdf",
            "C:/Files/Invoice2.xlsx",
            "C:/Files/Archive/Logs.txt"
        };

        // 2. 创建内存流存储ZIP内容（避免磁盘IO开销）
        using var memoryStream = new MemoryStream();
        
        // 3. 使用ZipArchive封装压缩逻辑
        using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, leaveOpen: true))
        {
            foreach (var file in filePaths)
            {
                // 4. 创建ZIP条目并添加文件
                var entry = archive.CreateEntry(Path.GetFileName(file));
                
                // 5. 使用双重using确保资源释放
                using var entryStream = entry.Open();
                using var fileStream = new FileStream(file, FileMode.Open, FileAccess.Read);
                
                // 6. 异步复制文件内容
                await fileStream.CopyToAsync(entryStream);
            }
        }

        // 7. 重置流位置并返回文件
        memoryStream.Seek(0, SeekOrigin.Begin);
        
        return File(memoryStream.ToArray(), "application/zip", "archive.zip");
    }
}

/// <summary>
/// 动态生成内容并压缩
/// </summary>
[HttpGet("dynamic")]
public IActionResult GenerateDynamicZip()
{
    using var memoryStream = new MemoryStream();
    
    using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true))
    {
        // 1. 创建动态文本文件
        var textEntry = archive.CreateEntry("DynamicText.txt");
        using var textStream = textEntry.Open();
        using var writer = new StreamWriter(textStream);
        writer.Write("这是动态生成的文本内容");
        
        // 2. 创建动态CSV文件
        var csvEntry = archive.CreateEntry("DataExport.csv");
        using var csvStream = csvEntry.Open();
        using var csvWriter = new StreamWriter(csvStream);
        csvWriter.WriteLine("ID,Name,Value");
        for (int i = 0; i < 1000; i++)
        {
            csvWriter.WriteLine($"{i},Item{i},Value{i}");
        }
    }
    
    memoryStream.Seek(0, SeekOrigin.Begin);
    return File(memoryStream.ToArray(), "application/zip", "dynamic.zip");
}

/// <summary>
/// 异步分块压缩处理（适合大文件）
/// </summary>
[HttpGet("chunked")]
public async Task<IActionResult> ChunkedCompression()
{
    // 1. 创建临时目录
    var tempDir = Path.Combine(Path.GetTempPath(), Guid.NewGuid().ToString());
    Directory.CreateDirectory(tempDir);
    
    try
    {
        // 2. 生成临时文件
        var tempFiles = new List<string>();
        for (int i = 0; i < 100; i++)
        {
            var tempFilePath = Path.Combine(tempDir, $"Chunk_{i}.txt");
            File.WriteAllText(tempFilePath, $"Chunk content {i}");
            tempFiles.Add(tempFilePath);
        }
        
        // 3. 创建ZIP文件
        var zipPath = Path.Combine(tempDir, "output.zip");
        ZipFile.CreateFromDirectory(tempDir, zipPath);
        
        // 4. 返回文件流
        var fileStream = new FileStream(zipPath, FileMode.Open);
        return File(fileStream, "application/zip", "chunked_output.zip");
    }
    finally
    {
        // 5. 清理临时文件
        try
        {
            if (Directory.Exists(tempDir))
                Directory.Delete(tempDir, true);
        }
        catch (Exception ex)
        {
            // 记录日志
            Console.WriteLine($"清理临时文件失败：{ex.Message}");
        }
    }
}

/// <summary>
/// 高效内存流压缩（适合小文件）
/// </summary>
[HttpGet("optimized")]
public IActionResult OptimizedCompression()
{
    // 1. 预分配内存空间
    const int initialCapacity = 1024 * 1024 * 10; // 10MB
    using var memoryStream = new MemoryStream(initialCapacity);
    
    using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true))
    {
        // 2. 批量添加文件
        for (int i = 0; i < 100; i++)
        {
            var entry = archive.CreateEntry($"File_{i}.txt");
            using var entryStream = entry.Open();
            using var writer = new StreamWriter(entryStream);
            writer.Write($"这是第{i}个文件");
        }
    }
    
    memoryStream.Seek(0, SeekOrigin.Begin);
    return File(memoryStream.ToArray(), "application/zip", "optimized.zip");
}

/// <summary>
/// 异步流式压缩（适合大文件）
/// </summary>
[HttpGet("streaming")]
public async Task<IActionResult> StreamingCompression()
{
    // 1. 创建响应流
    Response.ContentType = "application/zip";
    Response.Headers.ContentDisposition = "attachment; filename=streaming.zip";
    
    // 2. 直接写入响应流
    using var zipArchive = new ZipArchive(Response.BodyWriter.AsStream(), ZipArchiveMode.Create, true);
    
    // 3. 并行添加文件
    var tasks = new List<Task>();
    for (int i = 0; i < 100; i++)
    {
        tasks.Add(Task.Run(async () =>
        {
            var entry = zipArchive.CreateEntry($"Parallel_{i}.txt");
            using var entryStream = entry.Open();
            using var writer = new StreamWriter(entryStream);
            await writer.WriteAsync($"这是第{i}个并行文件");
        }));
    }
    
    await Task.WhenAll(tasks);
    
    return new EmptyResult();
}