前言
上一篇net core WebApi——文件分片上传与跨域请求处理介绍完文件的上传操作,本来是打算紧接着写文件下载,中间让形形色色的事给耽误的,今天还是抽个空整理完文件这块儿,然后就可以鼓捣别的东西了。
开始
这里我们仍然使用基础工程,需要下载的朋友请移步net core Webapi 总目录,代码都是与博客的进度基本同步的。
上传的时候我们介绍过分片的思路,而下载也一样,只是客户端与服务端角色转换下就好了。
后端
- 接收前端下载请求,校验请求信息,返回文件基本信息
- 根据前端请求文件片段进行下载流处理。
前端
- 向后端发起下载请求,获取文件总片段数
- 根据片段数循环请求文件片段流进行下载(可单独请求某一片段文件数据)
文件下载相对于上传来说稍微简洁点儿,如果不考虑服务器压力也可以一个a标签解决下载问题,分片的意义就在于每次与服务端的交互减少流量,有些时候我们推荐拿空间换时间,但对于大流量来说还是慢慢来比较好,单次访问量如果大再加上多并发怕是服务器会受不了,所以有了一片片分步来循环访问这个方法。
也是直接来看代码吧,我们在FileController创建几个接口方法RequestDownloadFile,FileDownload。
/// <summary>
/// 请求下载文件
/// </summary>
/// <param name="fileInfo">文件参数信息[name]</param>
/// <returns></returns>
[HttpPost, Route("RequestDownload")]
public MessageEntity RequestDownloadFile([FromBody]Dictionary<string, object> fileInfo)
{
}
/// <summary>
/// 分段下载文件
/// </summary>
/// <param name="fileInfo">请求参数信息[index,name]</param>
/// <returns></returns>
[HttpPost, Route("Download")]
public async Task<IActionResult> FileDownload([FromBody]Dictionary<string, object> fileInfo)
{
}
RequestDownloadFile
这里说明下,与服务端的操作都要尽可能多的确认身份信息(当然后续会有说这块儿),文件的相关操作也一样需要并且还要严格点儿,我这里就是为了做示例演示所以只传文件信息即可。
public MessageEntity RequestDownloadFile([FromBody]Dictionary<string, object> fileInfo)
{
MessageEntity message = new MessageEntity();
string fileName = string.Empty;
string fileExt = string.Empty;
if (fileInfo.ContainsKey("name"))
{
fileName = fileInfo["name"].ToString();
}
if (fileInfo.ContainsKey("ext"))
{
fileExt = fileInfo["ext"].ToString();
}
if (string.IsNullOrEmpty(fileName))
{
message.Code = -1;
message.Msg = "文件名不能为空";
return message;
}
//获取对应目录下文件,如果有,获取文件开始准备分段下载
string filePath = $".{AprilConfig.FilePath}{DateTime.Now.ToString("yyyy-MM-dd")}/{fileName}";
filePath = $"{filePath}{fileExt}";
FileStream fs = null;
try
{
if (!System.IO.File.Exists(filePath))
{
//文件为空
message.Code = -1;
message.Msg = "文件尚未处理完";
return message;
}
fs = new FileStream(filePath, FileMode.Open);
if (fs.Length <= 0)
{
//文件为空
message.Code = -1;
message.Msg = "文件尚未处理完";
return message;
}
int shardSize = 1 * 1024 * 1024;//一次1M
RequestFileUploadEntity request = new RequestFileUploadEntity();
request.fileext = fileExt;
request.size = fs.Length;
request.count = (int)(fs.Length / shardSize);
if ((fs.Length % shardSize) > 0)
{
request.count += 1;
}
request.filedata = GetCryptoString(fs);
message.Data = request;
}
catch (Exception ex)
{
LogUtil.Debug($"读取文件信息失败:{filePath},错误信息:{ex.Message}");
}
finally
{
if (fs != null)
{
fs.Close();
}
}
return message;
}
FileDownload
public async Task<IActionResult> FileDownload([FromBody]Dictionary<string, object> fileInfo)
{
//开始根据片段来下载
int index = 0;
if (fileInfo.ContainsKey("index"))
{
int.TryParse(fileInfo["index"].ToString(), out index);
}
else
{
return Ok(new { code = -1, msg = "缺少参数" });
}
string fileName = string.Empty;
string fileExt = string.Empty;
if (fil