using System;
using System.IO;
using System.Collections.Generic;
using ICSharpCode.SharpZipLib.Zip;
namespace SharpZipLibTest
{
class Program
{
static void Main(string[] args)
{
string cur_path = Directory.GetCurrentDirectory();
string res_path = Directory.GetCurrentDirectory() + "/res";
string zip_path = Directory.GetCurrentDirectory() + "/res.zip";
string unzip_path = Directory.GetCurrentDirectory() + "/unzip_res";
Console.WriteLine("要压缩的资源目录: " + res_path);
Console.WriteLine("压缩后的文件名: "+zip_path);
ZipHelp.Compress(res_path, zip_path);
ZipHelp.UnCompress(zip_path, unzip_path);
Console.WriteLine("完成!");
Console.Read();
}
}
}
using System;
using System.IO;
using System.Collections.Generic;
using ICSharpCode.SharpZipLib.Zip;
using System.Threading.Tasks;
using System.Threading;
namespace UNetwork
{
/// <summary>
/// Zip辅助类
/// </summary>
public sealed class ZipHelper
{
/// <summary>
/// 压缩
/// </summary>
/// <param name="fileOrDir">要压缩的文件或文件夹路径</param>
/// <param name="savePath">要保存的文件名</param>
public static void Compress(string fileOrDir, string savePath)
{
if (Path.HasExtension(fileOrDir))
CompressFile(fileOrDir, savePath);
else
CompressDirectory(fileOrDir, savePath);
}
/// <summary>
/// 解压
/// </summary>
/// <param name="zipPath">zip文件所在路径</param>
/// <param name="savePath">解压后要存放的目录</param>
public static void UnCompressAsync(string zipPath, string savePath, Action<string> progressFun = null, Action completedFun = null)
{
if (!File.Exists(zipPath))
{
throw new FileNotFoundException(zipPath);
}
SynchronizationContext syncContext = SynchronizationContext.Current;
Task.Run(() => {
FileStream fs = File.OpenRead(zipPath);
ZipInputStream zis = new ZipInputStream(fs);
ZipEntry entry = zis.GetNextEntry();
while (entry != null)
{
syncContext?.Post(state =>
{
progressFun?.Invoke(entry.Name);
}, null);
string filename = savePath + Path.DirectorySeparatorChar + entry.Name;
string dir = Path.GetDirectoryName(filename);
if (!Directory.Exists(dir))
Directory.CreateDirectory(dir);
if (entry.IsFile)
WriteFile(filename, zis, entry);
zis.CloseEntry();
entry = zis.GetNextEntry();
}
zis.Close();
syncContext?.Post(state =>
{
completedFun?.Invoke();
}, null);
});
}
private static void CompressFile(string filePath, string savePath)
{
if (!File.Exists(filePath))
{
throw new FileNotFoundException(filePath);
}
ZipOutputStream zs = new ZipOutputStream(File.Create(savePath));
ZipEntry entry = new ZipEntry(filePath);
entry.DateTime = DateTime.Now;
zs.PutNextEntry(entry);
zs.Close();
}
private static void CompressDirectory(string dir, string savePath)
{
if (!Directory.Exists(dir))
{
throw new DirectoryNotFoundException(dir);
}
string parent_dir = Directory.GetParent(dir).FullName;
ZipOutputStream zs = new ZipOutputStream(File.Create(savePath));
dir_list.Clear();
dir_list.Add(dir);
SearchDirectory(dir);
//遍历所有文件夹
for (int i = 0; i < dir_list.Count; i++)
{
string path = dir_list[i];
DirectoryInfo TheFolder = new DirectoryInfo(path);
//遍历文件夹下的所有文件
foreach (FileInfo NextFile in TheFolder.GetFiles())
{
if (NextFile.Extension.Equals(".zip"))
continue;
FileStream fs = null;
try
{
fs = NextFile.Open(FileMode.Open, FileAccess.ReadWrite);
}
catch
{
continue;
}
//将文件分批读入缓存中
byte[] data = new byte[2048];
int size = 2048;
ZipEntry entry = new ZipEntry(Path.GetFileName(NextFile.Name));
entry.DateTime = DateTime.Now;
zs.PutNextEntry(entry);
while (true)
{
size = fs.Read(data, 0, size);
if (size <= 0) break;
zs.Write(data, 0, size);
}
fs.Close();
}
}
zs.Finish();
zs.Close();
}
private static List<string> dir_list = new List<string>();
private static void SearchDirectory(string dir)
{
DirectoryInfo TheFolder = new DirectoryInfo(dir);
foreach (DirectoryInfo NextFolder in TheFolder.GetDirectories())
{
dir_list.Add(NextFolder.FullName);
SearchDirectory(NextFolder.FullName);
}
}
private static void WriteFile(string saveFile, ZipInputStream zis, ZipEntry entry)
{
//创建目录
string dir = Path.GetDirectoryName(saveFile);
if (!Directory.Exists(dir))
Directory.CreateDirectory(dir);
byte[] buffer = new byte[4 * 1024];
FileStream fs = File.Create(saveFile);
//CompressedSize=0 时解压会卡住
if (entry.CompressedSize > 0)
{
int len = 0;
while ((len = zis.Read(buffer, 0, buffer.Length)) > 0)
{
fs.Write(buffer, 0, len);
}
}
fs.Close();
}
}
}