用百度webuploader分片上傳大文件

  通常在作文件上傳的時候,都是經過客戶端把要上傳的文件上傳到服務器,此時上傳的文件都在服務器內存,若是上傳的是視頻等大文件,那麼服務器內存就很緊張,並且通常咱們都是用flash或者html5作異步上傳,若是文件比較大的話,即使是客戶端顯示文件已經上傳了100%,仍是會有一個比較長時間的等待,並且當前頁面對服務器的請求也會被阻塞。html

  正常狀況下,通常都是在長傳完成後,在服務器直接保存。html5

  

1  public void ProcessRequest(HttpContext context)
2         {
3             context.Response.ContentType = "text/plain";
4             //保存文件
5             context.Request.Files[0].SaveAs(context.Server.MapPath("~/1/" + context.Request.Files[0].FileName));
6             context.Response.Write("Hello World");
7         }

  最近項目中用百度開源的上傳組件webuploader,官方介紹webuploader支持分片上傳。具體webuploader的使用方法見官網http://fex.baidu.com/webuploader/。web

var uploader = WebUploader.create({
            auto: true,
            swf:'/webuploader/Uploader.swf',
            // 文件接收服務端。
            server: '/Uploader.ashx',
            // 內部根據當前運行是建立,多是input元素,也多是flash.
            pick: '#filePicker',
            chunked: true,//開啓分片上傳
            threads: 1,//上傳併發數
            //因爲Http的無狀態特徵,在往服務器發送數據過程傳遞一個進入當前頁面是生成的GUID做爲標示
            formData: {guid:"<%=Guid.NewGuid().ToString()%>"}
        });

  webuploader的分片上傳是把文件分紅若干份,而後向你定義的文件接收端post數據,若是上傳的文件大於分片的尺寸,就會進行分片,而後會在post的數據中添加兩個form元素chunk和chunks,前者標示當前分片在上傳分片中的順序(從0開始),後者表明總分片數。服務器

  選擇一個文件後分了7個分片,因此對Uploader.ashx進行了7次post數據的過程。併發

  

  每次請求中的form元素chunk和chunks以及爲了標示是同一個文件的分片的GUID異步

  

  在服務器端接收到數據後,就能夠根據這些參數進行處理了。post

  一、按按GUID建立一個臨時文件ui

  二、把收到的分片數據追加到對應GUID的文件中。spa

  三、根據上傳的文件名重命名臨時文件code

  四、若是沒有分片直接保存

  

public void ProcessRequest(HttpContext context)
        {
            context.Response.ContentType = "text/plain";
            //若是進行了分片
            if (context.Request.Form.AllKeys.Any(m => m == "chunk"))
            {
                //取得chunk和chunks
                int chunk =Convert.ToInt32(context.Request.Form["chunk"]);
                int chunks = Convert.ToInt32(context.Request.Form["chunks"]);

              
                //根據GUID建立用該GUID命名的臨時文件
                string path = context.Server.MapPath("~/1/" + context.Request["guid"]);
                FileStream addFile = new FileStream(path, FileMode.Append, FileAccess.Write);
                BinaryWriter AddWriter = new BinaryWriter(addFile);
                //得到上傳的分片數據流
                HttpPostedFile file = context.Request.Files[0];
                Stream stream = file.InputStream;

                BinaryReader TempReader = new BinaryReader(stream);
                //將上傳的分片追加到臨時文件末尾
                AddWriter.Write(TempReader.ReadBytes((int)stream.Length));
                //關閉BinaryReader文件閱讀器
                TempReader.Close();
                stream.Close();
                AddWriter.Close();
                addFile.Close();

                TempReader.Dispose();
                stream.Dispose();
                AddWriter.Dispose();
                addFile.Dispose();
                //若是是最後一個分片,則重命名臨時文件爲上傳的文件名
                if (chunk == (chunks - 1))
                {
                    FileInfo fileinfo = new FileInfo(path);
                    fileinfo.MoveTo(context.Server.MapPath("~/1/" + context.Request.Files[0].FileName));
                }
            }
            else//沒有分片直接保存
            {
                context.Request.Files[0].SaveAs(context.Server.MapPath("~/1/" + context.Request.Files[0].FileName ));
            }
            context.Response.Write("ok");
        }

  還存在一些問題沒解決,雖然暫時知足需求

  一、若是上傳併發超過1個的時候,就會出現一個分片上傳服務器還沒處理結束,第二個分片同時就到了,那樣就會出現文件被佔用的錯誤。

  二、若是加鎖的辦法解決第一個問題,那加鎖了就確定會影響效率(同時只有一個進程能訪問保存文件那段代碼)。

  三、文件的順序問題,有個多是第二個分片先到,而後第一個纔到,那麼就不能一次追加流到臨時文件了,只能建立多個臨時文件,待全部分片上傳完成後,拼接成一個文件。

  只是個Demo,但願有人幫助解決下存在的問題。

相關文章
相關標籤/搜索