C#实现分片上传文件

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.IO;
using System.Configuration;

namespace WebApplication1
{
    /// <summary>
    /// PartialFileSet 的摘要说明
    /// </summary>
    public class UpLoadPartialFile : IHttpHandler
    {
        public static DateTime mkdirRecodeTime = DateTime.Now.AddDays(-2);
        public static string keyHead = DateTime.Now.Year + "" + DateTime.Now.Month + DateTime.Now.Day;
        public static string path = ConfigurationManager.AppSettings["filePath"].ToString();
        public static object mkdirLock = new object();
   
        /// <summary>
        /// 根据日期字符串返回路径
        /// </summary>
        /// <param name="keyHead">日期字符串yyyyMMdd</param>
        /// <returns></returns>
        private static string getCurrentPathByDate(string keyHead)
        {

            return path + "\" + keyHead;
        }

        private static string getCurrentFilePathByDate(string keyHead, string guid, int id)
        {
            return getCurrentPathByDate(keyHead) + "\" + guid + id;
        }

        private static string getNewFilePathByDate(string keyHead, string guid)
        {
            string fileType = HttpContext.Current.Request["fileType"];
            if(fileType!=null&& fileType.Length>0)
            return getCurrentPathByDate(keyHead) + "\" + guid+"."+fileType;
            return getCurrentPathByDate(keyHead) + "\" + guid;
        }
        /// <summary>
        /// 如果目标文件夹不存在 创建文件夹
        /// </summary>
        /// <param name="keyHead"></param>
        private static void mkdirIfNoExit()
        {

            if ((DateTime.Now-mkdirRecodeTime ).Days < 1)
                return;
          
            //创建文件夹目录
            if (Directory.Exists(getCurrentPathByDate(keyHead)))
                return;
            lock (mkdirLock)
            {

                if (!Directory.Exists(path))
                    Directory.CreateDirectory(path);
                if (!Directory.Exists(getCurrentPathByDate(keyHead)))
                    Directory.CreateDirectory(getCurrentPathByDate(keyHead));

                keyHead = DateTime.Now.Year + "" + DateTime.Now.Month + DateTime.Now.Day;
                mkdirRecodeTime = DateTime.Now;
                return;
            }

        }

        private void uploadFile(HttpContext context)
        {
            try
            {
                //检查目录
                mkdirIfNoExit();
                


                if (context.Request.Files == null || context.Request.Files.Count == 0 || context.Request.Files[0].InputStream.Length == 0)
                {
                    context.Response.Write("{"state":"error","code":-6,"msg":"接口调用出错 上传文件不能为空"}");
                    return;
                }
                if (context.Request.Files.Count > 1)
                {
                    context.Response.Write("{"state":"error","code":-7,"msg":"接口调用出错 每次只能上传单个文件"}");
                    return;
                }
                string guid = Guid.NewGuid().ToString();

                string keyHead = DateTime.Now.Year + "" + DateTime.Now.Month + DateTime.Now.Day;
                string currentPath = getCurrentPathByDate(keyHead);
                string filePath = getNewFilePathByDate(keyHead, guid);
              
                lock (filePath)
                {
                    //创建文件
                    try
                    {
                        context.Request.Files[0].SaveAs(filePath);

                    }
                    catch (Exception e)
                    {
                        Util.LogHelper.Info(e.Message + e.StackTrace);

                        context.Response.Write("{"state":"error","code":-2,"msg":"接口调用出错 guid为" + guid + "的文件写入时出现错误 已记录日志"}");
                        return;
                    }
                }
                context.Response.Write("{"state":"success","code":0,"msg":""+keyHead+guid+""}");

            }
            catch (Exception e)
            {
                Util.LogHelper.Info(e.Message + e.StackTrace);
                context.Response.Write("{"state":"error","code":-1,"msg":"接口调用出错 已记录日志"}");
            }
        }

        private void uploadPartialFile(HttpContext context) {
            try
            {
                //检查目录
                mkdirIfNoExit();
                if (context.Request["date"] == null)
                {
                    context.Response.Write("{"state":"error","code":-2,"msg":"接口调用出错 参数date(第一片上传时间)不能为空"}");
                    return;
                }
                DateTime uploadData;
                if (!DateTime.TryParse(context.Request["date"], out uploadData))
                {

                    context.Response.Write("{"state":"error","code":-2,"msg":"接口调用出错date参数错误 格式 yyyy-MM-dd"}");
                    return;
                }
                if (context.Request["guid"] == null || context.Request["guid"].Trim().Length != 32)
                {
                    context.Response.Write("{"state":"error","code":-3,"msg":"接口调用出错 guid(文件唯一标示)不能为空且必须为32位长度"}");
                    return;
                }

                if (context.Request["id"] == null || context.Request["id"].Trim().Length == 0)
                {
                    context.Response.Write("{"state":"error","code":-4,"msg":"接口调用出错 id(文件分组id)不能为空"}");
                    return;
                }
                int id = -1;
                if (!int.TryParse(context.Request["id"], out id))
                {
                    context.Response.Write("{"state":"error","code":-5,"msg":"接口调用出错 id(文件分组id)必须为数字"}");
                    return;
                }


                if (context.Request.Files == null || context.Request.Files.Count == 0 || context.Request.Files[0].InputStream.Length == 0)
                {
                    context.Response.Write("{"state":"error","code":-6,"msg":"接口调用出错 上传文件不能为空"}");
                    return;
                }
                if (context.Request.Files.Count > 1)
                {
                    context.Response.Write("{"state":"error","code":-7,"msg":"接口调用出错 每次只能上传单个文件"}");
                    return;
                }
                string guid = context.Request["guid"].Trim();
                string keyHead = uploadData.Year + "" + uploadData.Month + uploadData.Day;
                string currentPath = getCurrentPathByDate(keyHead);
                string filePath = getCurrentFilePathByDate(keyHead, guid, id);
                if (File.Exists(filePath))
                {
                    context.Response.Write("{"state":"error","code":-8,"msg":"接口调用出错 guid为" + guid + "文件id为" + id + "的文件已存在"}");
                    return;
                }
                lock (filePath)
                {
                    if (File.Exists(filePath))
                    {
                        context.Response.Write("{"state":"error","code":-8,"msg":" guid为" + guid + "文件id为" + id + "的文件已存在"}");
                        return;
                    }
                    //创建文件
                    try
                    {
                        context.Request.Files[0].SaveAs(filePath);

                    }
                    catch (Exception e)
                    {
                        Util.LogHelper.Info(e.Message + e.StackTrace);

                        context.Response.Write("{"state":"error","code":-9,"msg":"接口调用出错 guid为" + guid + "文件id为" + id + "的文件写入时出现错误 已记录日志"}");
                        return;
                    }
                }

                context.Response.Write("{"state":"success","code":0,"msg":" guid为" + guid + "文件id为" + id + "的文件写入成功"}");

            }
            catch (Exception e)
            {
                Util.LogHelper.Info(e.Message + e.StackTrace);
                context.Response.Write("{"state":"error","code":-1,"msg":"接口调用出错 已记录日志"}");
            }
        }

        private void joinfile(HttpContext context)
        {
            try
            {
                //检查目录
                if (context.Request["date"] == null)
                {
                    context.Response.Write("{"state":"error","code":-2,"msg":"接口调用出错 参数date(第一片上传时间)不能为空"}");
                    return;
                }
                if (context.Request["guid"] == null || context.Request["guid"].Trim().Length != 32)
                {
                    context.Response.Write("{"state":"error","code":-3,"msg":"接口调用出错 guid(文件唯一标示)不能为空且必须为32位长度"}");
                    return;
                }

                if (context.Request["idArray"] == null || context.Request["idArray"].Trim().Length == 0)
                {
                    context.Response.Write("{"state":"error","code":-4,"msg":"接口调用出错 id(文件分组id列表)不能为空"}");
                    return;
                }
                DateTime uploadData;
                if (!DateTime.TryParse(context.Request["date"],out uploadData)) {

                    context.Response.Write("{"state":"error","code":-6,"msg":"接口调用出错date参数错误 格式 yyyy-MM-dd"}");
                    return;
                }

                string keyHead = uploadData.Year + "" + uploadData.Month + uploadData.Day;
                string guid = context.Request["guid"].Trim();

                List<int> IdArray = context.Request["idArray"].StringArrayConvertInt(',').OrderBy(u=>u).ToList();
                //开始检查文件是否全部存在
                List<string> pathList = new List<string>();
                if (IdArray.Count < 1)
                {
                    context.Response.Write("{"state":"error","code":-8,"msg":"接口调用出错文件列表文件少于2个无法进行合并操作 请检查IdArray参数"}");
                    return;
                }
                foreach (var item in IdArray)
                {
                    string path = getCurrentFilePathByDate(keyHead,guid,item);
                    if (!File.Exists(path))
                    {
                        context.Response.Write("{"state":"error","code":-7,"msg":"id编号为"+item+"的文件在服务器上不存在 请检查"}");
                        return;
                    }
                    pathList.Add(path);

                }
                string newGuid = Guid.NewGuid().ToString();
                string newFilePath = getNewFilePathByDate(keyHead,newGuid);
                using (System.IO.FileStream fileStram = File.Open(newFilePath, FileMode.Create,FileAccess.Write))
                {

                    //开始合并文件  创建一个副本
                    pathList.ForEach(u =>
                {
                    //读取文件
                    using (FileStream save = new FileStream(u, FileMode.Open, FileAccess.Read))
                    {
                        byte[] bt = new byte[1024];
                        int count = -1;
                        while ((count = save.Read(bt, 0, bt.Length)) > 0)
                        {
                            fileStram.Write(bt, 0, count);
                        }
                    }

                });
                    context.Response.Write("{"state":"success","code":0,"msg":""+ keyHead + newGuid + ""}");
                    //删除文件列表
                    delFile(pathList);
                }

            }
            catch (Exception e)
            {
                Util.LogHelper.Info(e.Message + e.StackTrace);
                context.Response.Write("{"state":"error","code":-1,"msg":"接口调用出错 已记录日志"}");
            }
        }
        public bool IsReusable
        {
            get
            {
                return false;
            }
        }
        public static void delFile(List<string> pathList) {
            try
            {

                for (int i = 0; i < pathList.Count; i++)
                {
                    File.Delete(pathList[i].Replace("\","/"));
                }
            }
            catch (Exception e)
            {
                Util.LogHelper.Info("删除分片文件错误"+e.Message+e.StackTrace);
            }
        }

        /// <summary>
        /// 创建部分文件集合
        /// </summary>
        /// <param name="context"></param>
        public  void ProcessRequest(HttpContext context)
        {
            try
            {

          
            context.Response.ContentType = "application/json";

            string mode = context.Request["mode"].ToLower();
                if (mode == "partialfile")
                    uploadPartialFile(context);
                else if (mode == "joinfile")
                    joinfile(context);
                else if (mode == "uploadfile")
                    uploadFile(context);
                else
                context.Response.Write("{"state":"error","code":-10,"msg":"接口调用出错 mode值范围为partialfile(上传分片文件)joinfile(合并分片文件)uploadfile上传单个文件 三种 "}");

            }

            catch (Exception e)
            {

                Util.LogHelper.Info("ProcessRequest执行错误" + e.Message + e.StackTrace);
                context.Response.Write("{"state":"error","code":-1,"msg":"接口调用出错 已记录日志"}");


            }
        }






    }
}

js调用

<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8" />
    <title></title>
</head>
<body>
    <script src="https://cdn.bootcss.com/jquery/3.2.1/jquery.js"></script>
    <script src="https://cdn.bootcss.com/jquery.form/3.51/jquery.form.js"></script>
    <form id="fileUpLoad" action="/UpLoadPartialFile.ashx?mode=partialfile" method="post" name="test">
        <input type="file" name="name" onchange="upload(this)" />上传分片文件
        <input type="hidden" id="guid" name="guid"value="aaaaaaaaaaaaaaaa" />
        <input type="hidden" name="date" value="2017-10-02" />
        <input type="hidden" id="id" name="id" value="0" />

    </form>

    <form id="fileUpLoadFile" action="/UpLoadPartialFile.ashx?mode=uploadfile" method="post" name="test">
        <input type="file" name="name2" onchange="uploadFile(this)"  />上传单个文件

    </form>
    <input type="text" id="fileType" name="fileType" placeholder="合并的文件后缀名称 可选(合并文件时有效)" value="mp4" />
    <button onclick="joinFIle()">合并文件</button>

</body>
</html>

<script>

    function newGuid() {
        var guid = "";
        for (var i = 1; i <= 32; i++) {
            var n = Math.floor(Math.random() * 16.0).toString(16);
            guid += n;
          
        }
        return guid;
    }
    var idArray = '';
    var date = 2017-10-02;
   var  i = 0;
    var guid = newGuid();
    $('#guid').val(guid);
    function joinFIle() {

        $.ajax('/UpLoadPartialFile.ashx?mode=joinfile&date=2017-10-02&guid=' + guid + '&idArray=' + idArray + '&fileType=' + $('#fileType').val()).done(function (rs) {
            alert(rs.msg);
        })

    }
    function upload(obj) {

        if (obj.size == 0)
            return;
        //上传表单
        $('#id').val(++i);
        idArray += i+',';
        $('#fileUpLoad').ajaxSubmit();

    }

    function uploadFile() {
        $('#fileUpLoadFile').ajaxSubmit();
    }
</script>

C#调用

        private static void post1()
        {
            string url = @"http://localhost:1128/uploadPartialFile.ashx?mode=partialfile&date=2017-10-03&id=1&guid=5ed1eddf7e7213ed0db6d5150b488335";//这里就不暴露我们的地址啦
            string modelId = "4f1e2e3d-6231-4b13-96a4-835e5af10394";
            string updateTime = "2016-11-03 14:17:25";
            string encrypt = "f933797503d6e2c36762428a280e0559";

            string filePath = @"D:/test2";
            string fileName = "test2";
            byte[] fileContentByte = new byte[1024]; // 文件内容二进制

            #region 将文件转成二进制

            FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read);
            fileContentByte = new byte[fs.Length]; // 二进制文件
            fs.Read(fileContentByte, 0, Convert.ToInt32(fs.Length));
            fs.Close();

            #endregion


            #region 定义请求体中的内容 并转成二进制

            string boundary = "ceshi";
            string Enter = "
";

            string modelIdStr = "--" + boundary + Enter
                    + "Content-Disposition: form-data; name="modelId"" + Enter + Enter
                    + modelId + Enter;

            string fileContentStr = "--" + boundary + Enter
                    + "Content-Type:application/octet-stream" + Enter
                    + "Content-Disposition: form-data; name="fileContent"; filename="" + fileName + """ + Enter + Enter;

            string updateTimeStr = Enter + "--" + boundary + Enter
                    + "Content-Disposition: form-data; name="updateTime"" + Enter + Enter
                    + updateTime;

            string encryptStr = Enter + "--" + boundary + Enter
                    + "Content-Disposition: form-data; name="encrypt"" + Enter + Enter
                    + encrypt + Enter + "--" + boundary + "--";


            var modelIdStrByte = Encoding.UTF8.GetBytes(modelIdStr);//modelId所有字符串二进制

            var fileContentStrByte = Encoding.UTF8.GetBytes(fileContentStr);//fileContent一些名称等信息的二进制（不包含文件本身）

            var updateTimeStrByte = Encoding.UTF8.GetBytes(updateTimeStr);//updateTime所有字符串二进制

            var encryptStrByte = Encoding.UTF8.GetBytes(encryptStr);//encrypt所有字符串二进制


            #endregion


            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = "POST";
            request.ContentType = "multipart/form-data;boundary=" + boundary;

            Stream myRequestStream = request.GetRequestStream();//定义请求流

            #region 将各个二进制 安顺序写入请求流 modelIdStr -> (fileContentStr + fileContent) -> uodateTimeStr -> encryptStr

            myRequestStream.Write(modelIdStrByte, 0, modelIdStrByte.Length);

            myRequestStream.Write(fileContentStrByte, 0, fileContentStrByte.Length);
            myRequestStream.Write(fileContentByte, 0, fileContentByte.Length);

            myRequestStream.Write(updateTimeStrByte, 0, updateTimeStrByte.Length);

            myRequestStream.Write(encryptStrByte, 0, encryptStrByte.Length);

            #endregion

            HttpWebResponse response = (HttpWebResponse)request.GetResponse();//发送

            Stream myResponseStream = response.GetResponseStream();//获取返回值
            StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));

            string retString = myStreamReader.ReadToEnd();

            myStreamReader.Close();
            myResponseStream.Close();
        }

Code=0表示接口调用成功

其他情况下code为负数 msg中包含具体错误信息

单个分片文件上传不能超过4000kb

上传分片文件

http://localhost:1128/UpLoadPartialFile.ashx?mode=partialfile

method:post

参数

date 分片上传 参数格式yyyy-MM-dd日期 例如:     2017-10-02 所有分片上传都使用一个时间 服务端根据这个参数来区分文件夹

id  (整数) 分片文件编号 如1  服务端合并文件将根据编号由小到大排序合并

guid 客户端生成一个guid 后面所有同一个文件的分片均使用同一个guid

guid为32位长度 即省略-分隔符

浏览器js调用报文如下

调用成功返回json

{"state":"success","code":0,"msg":" guid为db334a03fc01b200c770871374734c7b文件id为1的文件写入成功"}

合并分片文件

http://localhost:1128/UpLoadPartialFile.ashx?mode=joinfile&date=2017-10-02&guid=db334a03fc01b200c770871374734c7b&idArray=1,2,&fileType=mp4

method :post

参数

date 分片上传时间(必选)

guid 上传分片时使用的guid (必选)

idArray 编号列表 拼接逗号分隔 需要两个以上 否则无法合并文件(必选)

filetype 文件后缀名称 可选 如果传递该参数 读取时也要传递 否则无法找到文件

调用成功返回

{"state":"success","code":0,"msg":"2017102cdb64b77-5f7c-4ccf-aa11-1e327dfcd49f"}

Msg中的字符串用于读取文件

上传单个文件

http://localhost:1128/UpLoadPartialFile.ashx?mode=uploadfile

method:post

文件流写入到请求中

调用成功返回

{"state":"success","code":0,"msg":"2017102cdb64b77-5f7c-4ccf-aa11-1e327dfcd49f"}

Msg中的字符串用于读取文件 

安卓参考实现

http://blog.csdn.net/ylbf_dev/article/details/50468984

ios参考实现

http://www.jianshu.com/p/a0e3c77d3164