using System.IO;
using System.Threading.Tasks;
namespace IRaCIS.Core.Infrastructure.Extention
{
///
/// 大文件操作扩展类
///
public static class FileExt
{
///
/// 以文件流的形式复制大文件
///
/// 源
/// 目标地址
/// 缓冲区大小,默认8MB
public static void CopyToFile(this Stream fs, string dest, int bufferSize = 1024 * 8 * 1024)
{
using var fsWrite = new FileStream(dest, FileMode.OpenOrCreate, FileAccess.ReadWrite);
byte[] buf = new byte[bufferSize];
int len;
while ((len = fs.Read(buf, 0, buf.Length)) != 0)
{
fsWrite.Write(buf, 0, len);
}
}
///
/// 以文件流的形式复制大文件(异步方式)
///
/// 源
/// 目标地址
/// 缓冲区大小,默认8MB
public static async void CopyToFileAsync(this Stream fs, string dest, int bufferSize = 1024 * 1024 * 8)
{
using var fsWrite = new FileStream(dest, FileMode.OpenOrCreate, FileAccess.ReadWrite);
byte[] buf = new byte[bufferSize];
int len;
await Task.Run(() =>
{
while ((len = fs.Read(buf, 0, buf.Length)) != 0)
{
fsWrite.Write(buf, 0, len);
}
}).ConfigureAwait(true);
}
///
/// 将内存流转储成文件
///
///
///
public static void SaveFile(this MemoryStream ms, string filename)
{
using var fs = new FileStream(filename, FileMode.Create, FileAccess.Write);
byte[] buffer = ms.ToArray(); // 转化为byte格式存储
fs.Write(buffer, 0, buffer.Length);
fs.Flush();
}
}
}