1. 程式人生 > >單文件WebUploader做大文件的分塊和斷點續傳

單文件WebUploader做大文件的分塊和斷點續傳

serial multiple 添加 ngs size center watermark 前言 load()

前言:

WebUploader是由Baidu WebFE(FEX)團隊開發的一個簡單的以HTML5為主,FLASH為輔的現代文件上傳組件。在現代的瀏覽器裏面能充分發揮HTML5的優勢,同時又不摒棄主流IE瀏覽器,沿用原來的FLASH運行時,兼容IE6+,iOS 6+, android 4+。兩套運行時,同樣的調用方式,可供用戶任意選用。

上面的一段話是來自 http://fex.baidu.com/webuploader/ 的介紹,現在做的項目需要用到大文件的上傳,之前沒有做過,現有的jquery的uploadify只用於上傳圖片什麽的小文件,查了網上的資料,這個插件好像對於大文件不是很友好,為了安全起見,使用百度的成熟框架,不論是多文件還是單個的大文件都是很好用的,沒有很多的問題,關於webuploader的詳細介紹看官網就行:

我的項目是javaweb,開發環境是MyEclipse,頁面使用jsp

1、先將 webuploader-0.1.5.zip 這個文件下載下來:https://github.com/fex-team/webuploader/releases

根據個人的需求放置自己需要的東西就行,全部放到項目裏也可以,下面是我自己需要的東西:

技術分享圖片

2、代碼部分:分為jsp和servlet部分


1、jsp部分代碼:

[html] view plain copy
  1. <script type="text/javascript">
  2. var fileMd5;
  3. //監聽分塊上傳過程中的三個時間點
  4. WebUploader.Uploader.register({
  5. "before-send-file":"beforeSendFile",
  6. "before-send":"beforeSend",
  7. "after-send-file":"afterSendFile",
  8. },{
  9. //時間點1:所有分塊進行上傳之前調用此函數
  10. beforeSendFile:function(file){
  11. var deferred = WebUploader.Deferred();
  12. //1、計算文件的唯一標記,用於斷點續傳
  13. (new WebUploader.Uploader()).md5File(file,0,10*1024*1024)
  14. .progress(function(percentage){
  15. $(‘#item1‘).find("p.state").text("正在讀取文件信息...");
  16. })
  17. .then(function(val){
  18. fileMd5=val;
  19. $(‘#item1‘).find("p.state").text("成功獲取文件信息...");
  20. //獲取文件信息後進入下一步
  21. deferred.resolve();
  22. });
  23. return deferred.promise();
  24. },
  25. //時間點2:如果有分塊上傳,則每個分塊上傳之前調用此函數
  26. beforeSend:function(block){
  27. var deferred = WebUploader.Deferred();
  28. $.ajax({
  29. type:"POST",
  30. url:"<%=basePath%>Video?action=checkChunk",
  31. data:{
  32. //文件唯一標記
  33. fileMd5:fileMd5,
  34. //當前分塊下標
  35. chunk:block.chunk,
  36. //當前分塊大小
  37. chunkSize:block.end-block.start
  38. },
  39. dataType:"json",
  40. success:function(response){
  41. if(response.ifExist){
  42. //分塊存在,跳過
  43. deferred.reject();
  44. }else{
  45. //分塊不存在或不完整,重新發送該分塊內容
  46. deferred.resolve();
  47. }
  48. }
  49. });
  50. this.owner.options.formData.fileMd5 = fileMd5;
  51. deferred.resolve();
  52. return deferred.promise();
  53. },
  54. //時間點3:所有分塊上傳成功後調用此函數
  55. afterSendFile:function(){
  56. //如果分塊上傳成功,則通知後臺合並分塊
  57. $.ajax({
  58. type:"POST",
  59. url:"<%=basePath%>Video?action=mergeChunks",
  60. data:{
  61. fileMd5:fileMd5,
  62. },
  63. success:function(response){
  64. alert("上傳成功");
  65. var path = "uploads/"+fileMd5+".mp4";
  66. $("#item1").attr("src",path);
  67. }
  68. });
  69. }
  70. });
  71. var uploader = WebUploader.create({
  72. // swf文件路徑
  73. swf: ‘<%=basePath%>scripts/webuploader-0.1.5/Uploader.swf‘,
  74. // 文件接收服務端。
  75. server: ‘<%=basePath%>UploadVideo‘,
  76. // 選擇文件的按鈕。可選。
  77. // 內部根據當前運行是創建,可能是input元素,也可能是flash.
  78. pick: {id: ‘#add_video‘, <span style="background-color:rgb(255,204,0);">//這個id是你要點擊上傳文件的id,自己設置就好</span>
  79. multiple:false},
  80. // 不壓縮image, 默認如果是jpeg,文件上傳前會壓縮一把再上傳!
  81. resize: true,
  82. auto:true,
  83. //開啟分片上傳
  84. chunked: true,
  85. chunkSize:10*1024*1024,
  86. accept: {
  87. //限制上傳文件為MP4
  88. extensions: ‘mp4‘,
  89. mimeTypes: ‘video/mp4‘,
  90. }
  91. });
  92. // 當有文件被添加進隊列的時候
  93. uploader.on( ‘fileQueued‘, function( file ) {
  94. $(‘#item1‘).empty();
  95. $(‘#item1‘).html(‘<div id="‘ + file.id + ‘" class="item">‘+
  96. <a class="upbtn" id="btn" onclick="stop()">[取消上傳]</a>‘+
  97. <p class="info">‘ + file.name + ‘</p>‘ +
  98. <p class="state">等待上傳...</p></div>‘
  99. );
  100. });
  101. // 文件上傳過程中創建進度條實時顯示。
  102. uploader.on( ‘uploadProgress‘, function( file, percentage ) {
  103. $(‘#item1‘).find(‘p.state‘).text(‘上傳中 ‘+Math.round(percentage * 100) + ‘%‘);
  104. });
  105. uploader.on( ‘uploadSuccess‘, function( file ) {
  106. $( ‘#‘+file.id ).find(‘p.state‘).text(‘已上傳‘);
  107. });
  108. uploader.on( ‘uploadError‘, function( file ) {
  109. $( ‘#‘+file.id ).find(‘p.state‘).text(‘上傳出錯‘);
  110. });
  111. uploader.on( ‘uploadComplete‘, function( file ) {
  112. $( ‘#‘+file.id ).find(‘.progress‘).fadeOut();
  113. });
  114. function start(){
  115. uploader.upload();
  116. $(‘#btn‘).attr("onclick","stop()");
  117. $(‘#btn‘).text("取消上傳");
  118. }
  119. function stop(){
  120. uploader.stop(true);
  121. $(‘#btn‘).attr("onclick","start()");
  122. $(‘#btn‘).text("繼續上傳");
  123. }
  124. </script>

2、servlet部分代碼:


servlet部分需要兩個servlet,一個用於接收分塊文件,一個用於合並分塊成一個文件:

1、接收分塊servlet代碼:

[java] view plain copy
  1. @SuppressWarnings("serial")
  2. public class UploadVideo extends HttpServlet {
  3. @Override
  4. protected void doGet(HttpServletRequest req, HttpServletResponse resp)
  5. throws ServletException, IOException {
  6. // TODO Auto-generated method stub
  7. super.doGet(req, resp);
  8. doPost(req, resp);
  9. }
  10. @SuppressWarnings("unchecked")
  11. public void doPost(HttpServletRequest request, HttpServletResponse response)
  12. throws ServletException, IOException {
  13. DiskFileItemFactory factory = new DiskFileItemFactory();
  14. ServletFileUpload sfu = new ServletFileUpload(factory);
  15. sfu.setHeaderEncoding("utf-8");
  16. String savePath = this.getServletConfig().getServletContext()
  17. .getRealPath("");
  18. String folad = "uploads";
  19. savePath = savePath + "\\"+folad+"\\";
  20. String fileMd5 = null;
  21. String chunk = null;
  22. try {
  23. List<FileItem> items = sfu.parseRequest(request);
  24. for(FileItem item:items){
  25. if(item.isFormField()){
  26. String fieldName = item.getFieldName();
  27. if(fieldName.equals("fileMd5")){
  28. fileMd5 = item.getString("utf-8");
  29. }
  30. if(fieldName.equals("chunk")){
  31. chunk = item.getString("utf-8");
  32. }
  33. }else{
  34. File file = new File(savePath+"/"+fileMd5);
  35. if(!file.exists()){
  36. file.mkdir();
  37. }
  38. File chunkFile = new File(savePath+"/"+fileMd5+"/"+chunk);
  39. FileUtils.copyInputStreamToFile(item.getInputStream(), chunkFile);
  40. }
  41. }
  42. } catch (FileUploadException e) {
  43. // TODO Auto-generated catch block
  44. e.printStackTrace();
  45. }
  46. }
  47. }

2、合並分塊servlet代碼:

[java] view plain copy
  1. @SuppressWarnings("serial")
  2. public class Video extends HttpServlet {
  3. public void doGet(HttpServletRequest request, HttpServletResponse response)
  4. throws ServletException, IOException {
  5. super.doGet(request, response);
  6. doPost(request, response);
  7. }
  8. public void doPost(HttpServletRequest request, HttpServletResponse response)
  9. throws ServletException, IOException {
  10. String savePath = this.getServletConfig().getServletContext()
  11. .getRealPath("");
  12. String folad = "uploads";
  13. savePath = savePath + "\\"+folad+"\\";
  14. String action = request.getParameter("action");
  15. if(action.equals("mergeChunks")){
  16. //合並文件
  17. //需要合並的文件的目錄標記
  18. String fileMd5 = request.getParameter("fileMd5");
  19. //讀取目錄裏的所有文件
  20. File f = new File(savePath+"/"+fileMd5);
  21. File[] fileArray = f.listFiles(new FileFilter(){
  22. //排除目錄只要文件
  23. @Override
  24. public boolean accept(File pathname) {
  25. // TODO Auto-generated method stub
  26. if(pathname.isDirectory()){
  27. return false;
  28. }
  29. return true;
  30. }
  31. });
  32. //轉成集合,便於排序
  33. List<File> fileList = new ArrayList<File>(Arrays.asList(fileArray));
  34. Collections.sort(fileList,new Comparator<File>() {
  35. @Override
  36. public int compare(File o1, File o2) {
  37. // TODO Auto-generated method stub
  38. if(Integer.parseInt(o1.getName()) < Integer.parseInt(o2.getName())){
  39. return -1;
  40. }
  41. return 1;
  42. }
  43. });
  44. //UUID.randomUUID().toString()-->隨機名
  45. File outputFile = new File(savePath+"/"+fileMd5+".mp4");
  46. //創建文件
  47. outputFile.createNewFile();
  48. //輸出流
  49. FileChannel outChnnel = new FileOutputStream(outputFile).getChannel();
  50. //合並
  51. FileChannel inChannel;
  52. for(File file : fileList){
  53. inChannel = new FileInputStream(file).getChannel();
  54. inChannel.transferTo(0, inChannel.size(), outChnnel);
  55. inChannel.close();
  56. //刪除分片
  57. file.delete();
  58. }
  59. outChnnel.close();
  60. //清除文件夾
  61. File tempFile = new File(savePath+"/"+fileMd5);
  62. if(tempFile.isDirectory() && tempFile.exists()){
  63. tempFile.delete();
  64. }
  65. System.out.println("合並成功");
  66. }else if(action.equals("checkChunk")){
  67. //檢查當前分塊是否上傳成功
  68. String fileMd5 = request.getParameter("fileMd5");
  69. String chunk = request.getParameter("chunk");
  70. String chunkSize = request.getParameter("chunkSize");
  71. File checkFile = new File(savePath+"/"+fileMd5+"/"+chunk);
  72. response.setContentType("text/html;charset=utf-8");
  73. //檢查文件是否存在,且大小是否一致
  74. if(checkFile.exists() && checkFile.length()==Integer.parseInt(chunkSize)){
  75. //上傳過
  76. response.getWriter().write("{\"ifExist\":1}");
  77. }else{
  78. //沒有上傳過
  79. response.getWriter().write("{\"ifExist\":0}");
  80. }
  81. }
  82. }
  83. }

至此,大文件上傳的分塊和斷點就ok了,這也只是我自己的項目需求編寫的,這個框架還涵蓋很多的內容和功能,需要你自己去研究了,不過都不是很難,你也可以去修改它的css和js文件根據自己的需求。

單文件WebUploader做大文件的分塊和斷點續傳