.NET基于WebUploader大文件分片上传、断网续传、秒传

╰半橙微兮° 2021-06-26 16:06 521阅读 0赞

现在的项目开发基本上都用到了上传文件功能，或图片，或文档，或视频。

我们常用的常规上传已经能够满足当前要求了，然而有时会出现如下问题：

1.  文件过大（比如1G以上），超出服务端的请求大小限制；
2.  请求时间过长，请求超时；
3.  传输中断，必须重新上传导致前功尽弃；
4.  设置了`webconfig`和`iis`后还是不能上传成功；
5.  不想使用`FTP`，只想用`http`。

我们这里只讲分片上传，至于断网续传和秒传已经写好`Demo`，下载地址放在文末，有兴趣的可以下载自己玩玩。

`http`的网络请求中本身就已经具备了分片上传功能，那么什么是分片上传？我们来看看：  
分片上传原理  
片上传支持将一个文件切割为一系列特定大小的数据片，分别将这些小数据片上传到服务端，全部上传完后再在服务端将这些数据片合并成为一个资源。

分片上传引入了两个概念：块（`Block`）和片（`Chunk`）。每个块由一到多个片组成，而一个资源则由一到多个块组成。他们之间的关系可以用下图表述：  
![在这里插入图片描述][2019062422160235.png]  
块和片是上传过程中作为临时存储的单位。服务端会以约七天为单位的周期清除上传后未被合并为块(文件)的数据片(块)。

与分片上传相关的 `API` 有：创建块(`mkblk`)、上传片(`bput`)、创建文件(`mkfile`)。一个完整的分片上传流程可用下图表示：  
![在这里插入图片描述][20190624221631262.png]  
其中的关键点如下：

将待上传的文件按预定义块大小切分为若干个块（每块大小不大于 4MB：块的大小可以自定义）。如果这个文件小于 4MB，就只有一个块。

将每个块再按预定义的片大小切分为若干个片，先在服务端创建一个相应块（通过调用mkblk，并带上第一个片的内容），然后再循环将所有剩下的片全部上传（通过调用bput，从而完成一个块的上传）

在所有块上传完成后，通过调用`mkfile`将这些上传完成的块信息再严格的按顺序组装出一个逻辑资源的元信息，从而完成整个资源的分片上传过程。

在这个理论基础上，结合`WebUploade`插件（百度上传插件）和`net mvc`进行`demo`编写，老规矩，`demo`在文末，可以下载。

我们看一下效果图：

### 分片上传： ###

![在这里插入图片描述][20190624222612352.png]  
上传中（图一）  
![在这里插入图片描述][20190624222626950.png]  
上传成功（图二）

### 分片、断网(暂停)、秒传： ###

![在这里插入图片描述][20190624223940923.png]  
上传中（图一）  
![在这里插入图片描述][20190624223950917.png]上传成功（图二）

## 代码展示 ##

下载`webuploader`插件后引入项目中，主要引用文件：

前端完整代码

<!DOCTYPE html>
    <html xmlns="http://www.w3.org/1999/xhtml">
    <head>
        <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
        <title></title>
    </head>
    <body>
    <script src="~/Scripts/jquery-1.10.2.min.js"></script>
    <link href="~/Content/webuploader.css" rel="stylesheet" />
    <script src="~/Scripts/webuploader.js"></script>
    <script src="~/Scripts/bootstrap.min.js"></script>
    <div id="uploader" class="wu-example">
        
        <div id="thelist" class="uploader-list"></div>
        <div class="btns">
            <div id="picker">选择文件</div>
            <input id="ctlBtn" type="button" value="开始上传" class="btn btn-default" />
        </div>
    </div>
        <table width="50%" border="1" class="fileList_parent">
            <thead>
                <tr style="background-color:#DADADA">
                    <th>文件名称</th>
                    <th>类型</th>
                    <th>大小</th>
                    <th>进度</th>
                    <th>说明</th>
                </tr>
            </thead>
            <tbody class="fileList">
            </tbody>
        </table>
    </body>
    </html>
    <script> var applicationPath = window.applicationPath === "" ? "" : window.applicationPath || "../../"; var GUID = WebUploader.Base.guid();//一个GUID $(function () { var $ = jQuery; var $list = $('#thelist'); var uploader = WebUploader.create({ // 选完文件后，是否自动上传。 auto: false, // swf文件路径 swf: applicationPath + '../Content/Uploader.swf', // 文件接收服务端。 server: applicationPath + 'Home/Upload', // 选择文件的按钮。可选。 // 内部根据当前运行是创建，可能是input元素，也可能是flash. pick: '#picker', chunked: true,//开始分片上传 chunkSize: 2048000,//每一片的大小 formData: { guid: GUID //自定义参数，待会儿解释 }, // 不压缩image, 默认如果是jpeg，文件上传前会压缩一把再上传！ resize: false }); // 当有文件被添加进队列的时候 uploader.on('fileQueued', function (file) { $list.append('<div id="' + file.id + '" class="item">' + '<h4 class="info">' + file.name + '</h4>' + '<p class="state">等待上传...</p>' + '</div>'); var name = file.name; //文件名 var type = fileType(file.name); //文件类型，获取的是文件的后缀 var volume = bytesToSize(file.size); //文件大小格式化 var oTr = $("<tr></tr>"); var str = '<td><cite title="' + name + '">' + name + '</cite></td>'; str += '<td>' + type + '</td>'; str += '<td>' + volume + '</td>'; str += '<td id="jintutiao">'; str += '<span id="baifenbi"></span>0%'; str += '</td>'; str += '<td id="uploding">等待上传</td>'; $(".fileList").html(str) }); var aa = 1; // 文件上传过程中创建进度条实时显示。 uploader.on('uploadProgress', function (file, percentage) { var $li = $('#' + file.id), $percent = $li.find('.progress .progress-bar'); // 避免重复创建 if (!$percent.length) { $percent = $('<div class="progress progress-striped active">' + '<div class="progress-bar" role="progressbar" style="width: 0%">' + '</div>' + '</div>').appendTo($li).find('.progress-bar'); } $li.find('p.state').text('上传中'); $("#uploding").html("上传中"); $percent.css('width', percentage * 100 + '%'); if (percentage == 1) { aa++; } if (aa<=2) { var shuzi=percentage * 100; $("#baifenbi").html(shuzi.toFixed(2)); } }); // 文件上传成功，给item添加成功class, 用样式标记上传成功。 uploader.on('uploadSuccess', function (file, response) { $('#' + file.id).find('p.state').text('已上传'); $.post('Home/Merge', { guid: GUID, fileName: file.name }, function (data) { $("#uploader .state").html("上传成功..."); $("#uploding").html("上传成功"); }); }); // 文件上传失败，显示上传出错。 uploader.on('uploadError', function (file) { $('#' + file.id).find('p.state').text('上传出错'); }); // 完成上传完了，成功或者失败，先删除进度条。 uploader.on('uploadComplete', function (file) { $('#' + file.id).find('.progress').fadeOut(); }); //所有文件上传完毕 uploader.on("uploadFinished", function () { //提交表单 }); //开始上传 $("#ctlBtn").click(function () { uploader.upload(); }); }); //字节大小转换，参数为b function bytesToSize(bytes) { var sizes = ['Bytes', 'KB', 'MB', 'G']; if (bytes == 0) return 'n/a'; var i = parseInt(Math.floor(Math.log(bytes) / Math.log(1024))); return (bytes / Math.pow(1024, i)).toFixed(1) + ' ' + sizes[i]; }; //通过文件名，返回文件的后缀名 function fileType(name) { var nameArr = name.split("."); return nameArr[nameArr.length - 1].toLowerCase(); } </script>

后端控制器完整代码展示

using System;
    using System.Collections.Generic;
    using System.IO;
    using System.Linq;
    using System.Web;
    using System.Web.Mvc;
    namespace BigFileUploader.Controllers
    { 
        public class HomeController : Controller
        { 
            #region 文件上传
            [HttpPost]
            public ActionResult Upload()
            { 
                string fileName = Request["name"];
                string fileRelName = fileName.Substring(0, fileName.LastIndexOf('.'));//设置临时存放文件夹名称
    
                int index = Convert.ToInt32(Request["chunk"]);//当前分块序号
                var guid = Request["guid"];//前端传来的GUID号
                var dir = Server.MapPath("~/Upload");//文件上传目录
                dir = Path.Combine(dir, fileRelName);//临时保存分块的目录
                if (!System.IO.Directory.Exists(dir))
                    System.IO.Directory.CreateDirectory(dir);
                string filePath = Path.Combine(dir, index.ToString());//分块文件名为索引名，更严谨一些可以加上是否存在的判断，防止多线程时并发冲突
                var data = Request.Files["file"];//表单中取得分块文件
                string extension = data.FileName.Substring(data.FileName.LastIndexOf(".") + 1,
                    (data.FileName.Length - data.FileName.LastIndexOf(".") - 1));//获取文件扩展名
                //if (data != null)//为null可能是暂停的那一瞬间
                //{ 
                data.SaveAs(filePath + fileName);
                //}
                return Json(new {  erron = 0 });//Demo，随便返回了个值，请勿参考
            }
            public ActionResult Merge()
            { 
                var guid = Request["guid"];//GUID
                var uploadDir = Server.MapPath("~/Upload");//Upload 文件夹
                var fileName = Request["fileName"];//文件名
                string fileRelName = fileName.Substring(0, fileName.LastIndexOf('.'));
                var dir = Path.Combine(uploadDir, fileRelName);//临时文件夹 
                var files = System.IO.Directory.GetFiles(dir);//获得下面的所有文件
                var finalPath = Path.Combine(uploadDir, fileName);//最终的文件名（demo中保存的是它上传时候的文件名，实际操作肯定不能这样）
                var fs = new FileStream(finalPath, FileMode.Create);
                foreach (var part in files.OrderBy(x => x.Length).ThenBy(x => x))//排一下序，保证从0-N Write
                { 
                    var bytes = System.IO.File.ReadAllBytes(part);
                    fs.Write(bytes, 0, bytes.Length);
                    bytes = null;
                    System.IO.File.Delete(part);//删除分块
                }
                fs.Flush();
                fs.Close();
                System.IO.Directory.Delete(dir);//删除文件夹
                return Json(new {  error = 0 });//随便返回个值，实际中根据需要返回
            }
            #endregion
        }
    }

## 总结 ##

以上说的是分片上传的`demo`，断网续传和秒传在下面，大家下载下来玩哇，个人感觉蛮不错的。  
分片上传demo下载地址：[https://pan.baidu.com/s/1osGyv2qYzTmtNIImqkcKvw][https_pan.baidu.com_s_1osGyv2qYzTmtNIImqkcKvw] 提取码：ie57

分片上传、断网续传、秒传demo下载地址：[https://pan.baidu.com/s/1TuvGR6qUcKLMFjZGaQl5vg][https_pan.baidu.com_s_1TuvGR6qUcKLMFjZGaQl5vg] 提取码：aej4

[2019062422160235.png]: /images/20210626/7205a8c79a91439095b5b249e530c828.png
[20190624221631262.png]: /images/20210626/825b7baa08c64c438575c03c9ccef624.png
[20190624222612352.png]: /images/20210626/77891b097b22438bb57396679d051434.png
[20190624222626950.png]: /images/20210626/6ccde818b85e45ac82186442b05b40eb.png
[20190624223940923.png]: /images/20210626/bdf7e53d920a449da37acb5190279ccb.png
[20190624223950917.png]: /images/20210626/46774e7cf6a94214ae1f3c5cbeb02cb3.png
[https_pan.baidu.com_s_1osGyv2qYzTmtNIImqkcKvw]: https://pan.baidu.com/s/1osGyv2qYzTmtNIImqkcKvw
[https_pan.baidu.com_s_1TuvGR6qUcKLMFjZGaQl5vg]: https://pan.baidu.com/s/1TuvGR6qUcKLMFjZGaQl5vg