using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.IO.Compression; using System.IO; using System.Diagnostics; namespace ConsoleApp1 { class Program { static void Main(string[] args) { DecompressDemo(); Console.ReadLine(); } private static void CompressDemo() { string source = @"D:\"; string[] files = Directory.GetFiles(source, "*", SearchOption.AllDirectories); if(files!=null && files.Any()) { foreach(var file in files) { CompressFile(file); } } } private static void CompressFile(string file) { Console.WriteLine($"Start to compress {file}"); Stopwatch sw = new Stopwatch(); sw.Start(); string compressedFullName = Path.Combine(Path.GetDirectoryName(file), Path.GetFileNameWithoutExtension(file)) + ".zip"; if (File.Exists(compressedFullName)) { File.Delete(compressedFullName); } Task compressTask = Task.Run(() => { using (FileStream fs = File.Open(file, FileMode.Open)) { using (FileStream compressedFileStream = File.Create(compressedFullName)) { using (GZipStream gZipStream = new GZipStream(compressedFileStream, CompressionMode.Compress)) { fs.CopyTo(gZipStream); } } } }); compressTask.Wait(); sw.Stop(); if (compressTask.IsCompleted) { Console.WriteLine($"{file} has been compressed successfully,cost:{sw.ElapsedMilliseconds} ElapsedMilliseconds!"); } } private static void DecompressDemo() { string source = @"D:\"; string[] compressedFiles = Directory.GetFiles(source, "*.zip"); if (compressedFiles != null && compressedFiles.Any()) { foreach (var file in compressedFiles) { DecompressFile(file); } } } private static void DecompressFile(string file) { Console.WriteLine($"Start to decompress {file}"); Stopwatch decompressSW = new Stopwatch(); decompressSW.Start(); string newFileName = Path.Combine(Path.GetDirectoryName(file)) + Guid.NewGuid().ToString() + Path.GetFileNameWithoutExtension(file); Task decompressTask = Task.Run(() => { using (FileStream fs = File.Open(file, FileMode.Open)) { using (FileStream decompressedStream = File.Create(newFileName)) { using (GZipStream gzipdecompressedStream = new GZipStream(fs, CompressionMode.Decompress)) { gzipdecompressedStream.CopyTo(decompressedStream); } } } }); decompressTask.Wait(); if(decompressTask.IsCompleted) { decompressSW.Stop(); Console.WriteLine($"Decompress as {newFileName} cost {decompressSW.ElapsedMilliseconds} milliseconds"); } } } }
原文链接: https://www.cnblogs.com/Fred1987/p/12083760.html
欢迎关注
微信关注下方公众号,第一时间获取干货硬货;公众号内回复【pdf】免费获取数百本计算机经典书籍;
也有高质量的技术群,里面有嵌入式、搜广推等BAT大佬
原创文章受到原创版权保护。转载请注明出处:https://www.ccppcoding.com/archives/402071
非原创文章文中已经注明原地址,如有侵权,联系删除
关注公众号【高性能架构探索】,第一时间获取最新文章
转载文章受原作者版权保护。转载请注明原作者出处!