stream+springmvc实现文件断点续传
生活随笔
收集整理的這篇文章主要介紹了
stream+springmvc实现文件断点续传
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
手上有個文件上傳的需求，并且要支持斷點續傳最好要兼容性好一些，之前用過uploadify這個jquery上傳插件，但是首先它不支持斷點續傳而且HTML5版本的竟然要收費，秉承中國特色這里就不予考慮了；于是在網上找到了一個叫
Stream的支持HTML5和Flash并且支持斷點續傳的這么一個插件，經過一天的嘗試，終于把它整合到項目中去，現勉強能用了后續再優化優化應該能投入上線，廢話不多上代碼！
HTML+JS: <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%><%String path = request.getContextPath();String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";%><!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html> <head> <base href="<%=basePath%>"> <title>斷點續傳</title> <link rel="stylesheet" type="text/css" href="<%=basePath%>/statics/thirdparty/stream/css/stream-v1.css"> <script type="text/javascript" src="<%=basePath%>/statics/thirdparty/stream/js/stream-v1.js"></script> </head> <body> <div id="i_select_files"> </div > <div id="i_stream_files_queue"> </div> <button onclick="javascript:_t.upload();">開始上傳</button>|<button onclick="javascript:_t.stop();">停止上傳</button>|<button onclick="javascript:_t.cancel();">取消</button> |<button onclick="javascript:_t.disable();">禁用文件選擇</button>|<button onclick="javascript:_t.enable();">啟用文件選擇</button> |<button onclick="javascript:_t.hideBrowseBlock();">隱藏文件選擇按鈕</button>|<button onclick="javascript:_t.showBrowseBlock();">顯示文件選擇按鈕</button> |<button onclick="javascript:_t.destroy();_t=null;_t=new Stream(config);">銷毀重新生成按鈕</button> <br> Messages: <div id="i_stream_message_container" class="stream-main-upload-box" style="overflow: auto;height:200px;"> </div> </body><script type="text/javascript">/** * 配置文件（如果沒有默認字樣，說明默認值就是注釋下的值） * 但是，on*（onSelect， onMaxSizeExceed...）等函數的默認行為 * 是在ID為i_stream_message_container的頁面元素中寫日志 */ var config = { browseFileId : "i_select_files", /** 選擇文件的ID, 默認: i_select_files */ browseFileBtn : "<div>請選擇文件</div>", /** 顯示選擇文件的樣式, 默認: `<div>請選擇文件</div>` */ dragAndDropArea: "i_select_files", /** 拖拽上傳區域，Id（字符類型"i_select_files"）或者DOM對象, 默認: `i_select_files` */ dragAndDropTips: "<span>可以把文件(文件夾)拖拽到這里</span>", /** 拖拽提示, 默認: `<span>把文件(文件夾)拖拽到這里</span>` */ filesQueueId : "i_stream_files_queue", /** 文件上傳容器的ID, 默認: i_stream_files_queue */ filesQueueHeight : 200, /** 文件上傳容器的高度（px）, 默認: 450 */ messagerId : "i_stream_message_container", /** 消息顯示容器的ID, 默認: i_stream_message_container */ maxSize: 4294967296, /** 單個文件的最大大小，默認:2G */ multipleFiles: false, /** 多個文件一起上傳, 默認: false */ autoUploading: true, /** 選擇文件后是否自動上傳, 默認: true */// autoRemoveCompleted : true, /** 是否自動刪除容器中已上傳完畢的文件, 默認: false */// retryCount : 5, /** HTML5上傳失敗的重試次數 */// postVarsPerFile : { /** 上傳文件時傳入的參數，默認: {} */// param1: "val1",// param2: "val2"// },// swfURL : "/swf/FlashUploader.swf", /** SWF文件的位置 */ tokenURL : "<%=request.getContextPath()%>/tk", /** 根據文件名、大小等信息獲取Token的URI（用于生成斷點續傳、跨域的令牌） */// frmUploadURL : "/fd;", /** Flash上傳的URI */ uploadURL : "<%=request.getContextPath()%>/upload", /** HTML5上傳的URI */// simLimit: 200, /** 單次最大上傳文件個數 */// extFilters: [".txt", ".rpm", ".rmvb", ".gz", ".rar", ".zip", ".avi", ".mkv", ".mp3"], /** 允許的文件擴展名, 默認: [] */// onSelect: function(list) {alert('onSelect')}, /** 選擇文件后的響應事件 */ onMaxSizeExceed: function(size, limited, name) {alert('文件已超過4G');}, /** 文件大小超出的響應事件 */// onFileCountExceed: function(selected, limit) {alert('onFileCountExceed')}, /** 文件數量超出的響應事件 */// onExtNameMismatch: function(name, filters) {alert('onExtNameMismatch')}, /** 文件的擴展名不匹配的響應事件 */// onCancel : function(file) {alert('Canceled: ' + file.name)}, /** 取消上傳文件的響應事件 */// onComplete: function(file) {alert('onComplete')}, /** 單個文件上傳完畢的響應事件 */ onQueueComplete: function() { alert('onQueueComplete'); }, /** 所以文件上傳完畢的響應事件 */// onUploadError: function(status, msg) {alert('onUploadError')} /** 文件上傳出錯的響應事件 */// onDestroy: function() {alert('onDestroy')} /** 文件上傳出錯的響應事件 */ }; var _t = new Stream(config);</script></html> 頁面代碼精簡了下，只留下了關鍵部分。 TokenServlet： package com.dnion.oa.stream.servlet;?import java.io.IOException;import java.io.PrintWriter;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import org.apache.commons.lang.StringUtils;import org.json.JSONException;import org.json.JSONObject;import com.dnion.oa.stream.util.IoUtil;import com.dnion.oa.stream.util.TokenUtil;import com.dnion.oa.utils.Configuration;import com.dnion.oa.utils.Constant;?/** * According the file name and its size, generate a unique token. And this * token will be refer to user's file. */public class TokenServlet extends HttpServlet { private static final long serialVersionUID = 2650340991003623753L; static final String FILE_NAME_FIELD = "name"; static final String FILE_SIZE_FIELD = "size"; static final String TOKEN_FIELD = "token"; static final String SERVER_FIELD = "server"; static final String SUCCESS = "success"; static final String MESSAGE = "message"; @Override public void init() throws ServletException { }? @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String name = StringUtils.trimToEmpty(req.getParameter(FILE_NAME_FIELD)); String size = StringUtils.trimToEmpty(req.getParameter(FILE_SIZE_FIELD)); String token = TokenUtil.generateToken(name, size); PrintWriter writer = resp.getWriter(); JSONObject json = new JSONObject(); try { if (name.equals("")) { json.put(SUCCESS, false); json.put(MESSAGE, "文件名為空"); }else if (size.equals("")) { json.put(SUCCESS, false); json.put(MESSAGE, "文件大小為空"); }else{ json.put(TOKEN_FIELD, token); if (Configuration.getInstance().getIsCrossed()) json.put(SERVER_FIELD, Configuration.getInstance().getCrossServer()); json.put(SUCCESS, true); json.put(MESSAGE, "獲取TOKEN成功"); } } catch (JSONException e) { e.printStackTrace(); } /** TODO: save the token. */ writer.write(json.toString()); }? @Override protected void doHead(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { super.doHead(req, resp); }? @Override public void destroy() { super.destroy(); }} 這是實現上傳功能必須實現接口之一，看名字就知道基本功能就是獲取token實現‘斷點‘功能 StreamServlet： package com.dnion.oa.stream.servlet;?import java.io.File;import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PrintWriter;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import org.json.JSONException;import org.json.JSONObject;import com.dnion.oa.stream.util.IoUtil;import com.dnion.oa.utils.Configuration;?/** * File reserved servlet, mainly reading the request parameter and its file * part, stored it. */public class StreamServlet extends HttpServlet { private static final long serialVersionUID = -8619685235661387895L; /** when the has increased to 10kb, then flush it to the hard-disk. */ static final int BUFFER_LENGTH = 10240; static final String START_FIELD = "start"; public static final String CONTENT_RANGE_HEADER = "content-range"; @Override public void init() throws ServletException { } /** * Lookup where's the position of this file? */ @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { doOptions(req, resp); final String token = req.getParameter(TokenServlet.TOKEN_FIELD); final String size = req.getParameter(TokenServlet.FILE_SIZE_FIELD); final String fileName = req.getParameter(TokenServlet.FILE_NAME_FIELD); final PrintWriter writer = resp.getWriter(); /** TODO: validate your token. */ JSONObject json = new JSONObject(); long start = 0; boolean success = true; String message = ""; try { File f = IoUtil.getTokenedFile(token); start = f.length(); /** file size is 0 bytes. */ if (token.endsWith("_0") && "0".equals(size) && 0 == start) f.renameTo(IoUtil.getFile(fileName)); } catch (FileNotFoundException fne) { message = "Error: " + fne.getMessage(); success = false; } finally { try { if (success) json.put(START_FIELD, start); json.put(TokenServlet.SUCCESS, success); json.put(TokenServlet.MESSAGE, message); } catch (JSONException e) {} writer.write(json.toString()); IoUtil.close(writer); } }? @Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { doOptions(req, resp); final String token = req.getParameter(TokenServlet.TOKEN_FIELD); final String fileName = req.getParameter(TokenServlet.FILE_NAME_FIELD); Range range = IoUtil.parseRange(req); OutputStream out = null; InputStream content = null; final PrintWriter writer = resp.getWriter(); /** TODO: validate your token. */ JSONObject json = new JSONObject(); long start = 0; boolean success = true; String message = ""; File f = IoUtil.getTokenedFile(token); try { if (f.length() != range.getFrom()) { /** drop this uploaded data */ throw new StreamException(StreamException.ERROR_FILE_RANGE_START); } out = new FileOutputStream(f, true); content = req.getInputStream(); int read = 0; final byte[] bytes = new byte[BUFFER_LENGTH]; while ((read = content.read(bytes)) != -1) out.write(bytes, 0, read); start = f.length(); } catch (StreamException se) { success = StreamException.ERROR_FILE_RANGE_START == se.getCode(); message = "Code: " + se.getCode(); } catch (FileNotFoundException fne) { message = "Code: " + StreamException.ERROR_FILE_NOT_EXIST; success = false; } catch (IOException io) { message = "IO Error: " + io.getMessage(); success = false; } finally { IoUtil.close(out); IoUtil.close(content);? /** rename the file */ if (range.getSize() == start) { /** fix the `renameTo` bug */ File dst = IoUtil.getFile(fileName); dst.delete(); f.renameTo(dst); System.out.println("TK: `" + token + "`, NE: `" + fileName + "`"); /** if `STREAM_DELETE_FINISH`, then delete it. */ if (Configuration.getInstance().getIsDeleteFinished()) { dst.delete(); } } try { if (success) json.put(START_FIELD, start); json.put(TokenServlet.SUCCESS, success); json.put(TokenServlet.MESSAGE, message); } catch (JSONException e) {} writer.write(json.toString()); IoUtil.close(writer); } } @Override protected void doOptions(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { resp.setContentType("application/json"); resp.setHeader("Access-Control-Allow-Headers", "Content-Range,Content-Type"); resp.setHeader("Access-Control-Allow-Origin", Configuration.getInstance().getCrossOrigins()); resp.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS"); }? @Override public void destroy() { super.destroy(); }} 必須實現接口之一，也是最為主要的一個servlet 這兩個接口其實就是對應了js代碼中tokenURL和uploadURL,跳轉關系在web.xml中定義,把下面這段加進去就行了，記得改路徑 <servlet> <servlet-name>TokenServlet</servlet-name> <servlet-class>com.dnion.oa.stream.servlet.TokenServlet</servlet-class> <load-on-startup>0</load-on-startup></servlet><servlet-mapping> <servlet-name>TokenServlet</servlet-name> <url-pattern>/tk</url-pattern></servlet-mapping><servlet> <servlet-name>StreamServlet</servlet-name> <servlet-class>com.dnion.oa.stream.servlet.StreamServlet</servlet-class> <load-on-startup>0</load-on-startup></servlet><servlet-mapping> <servlet-name>StreamServlet</servlet-name> <url-pattern>/upload</url-pattern></servlet-mapping>?<servlet> <servlet-name>FormDataServlet</servlet-name> <servlet-class>com.dnion.oa.stream.servlet.FormDataServlet</servlet-class> <load-on-startup>0</load-on-startup></servlet><servlet-mapping> <servlet-name>FormDataServlet</servlet-name> <url-pattern>/fd</url-pattern></servlet-mapping> 基本參數保存在properties文件中 stream-config.properties: # file stored repository (Chinese words need ASCII, help tool @http://tool.oschina.net/encode?type=3)STREAM_FILE_REPOSITORY=# when the file has uploaded, whether delete it.STREAM_DELETE_FINISH=false# this server whether allow other different domain[s] upload file to this serverSTREAM_IS_CROSS=false# allowed domain (PS: flash method need modifying the `crossdomain.xml`)STREAM_CROSS_ORIGIN=*# when Browser @http:www.A.com, the file will upload to @STREAM_CROSS_SERVERSTREAM_CROSS_SERVER=http://customers.duapp.comTEMP_UPLOAD_PATH=E\:\\resumeUpload //暫時放在本地 測試用 Configuration.java讀取配置文件 Configuration.java：
package com.dnion.oa.utils;?import org.apache.commons.configuration.ConfigurationException;import org.apache.commons.configuration.PropertiesConfiguration;?public class Configuration { private static Configuration config; /** * 版本號 */ private String version; private String crossServer; private String crossOrigins; private String dnionTranscoderUrl; private Boolean isDeleteFinished; private Boolean isCrossed; private String uploadPath; private Configuration() { }? public synchronized static Configuration getInstance() { if (config == null) { config = new Configuration(); config.init(); } return config; } /** * 初始化 */ private void init() { PropertiesConfiguration prop = new PropertiesConfiguration(); prop.setEncoding("utf-8"); try { prop.load("props/stream-config.properties"); this.setCrossServer(prop.getString("STREAM_CROSS_SERVER", "")); this.setCrossOrigins(prop.getString("STREAM_CROSS_ORIGIN", "")); this.setDnionTranscoderUrl(prop.getString("DNION_TRANS_CODER_URL", "")); this.setIsDeleteFinished(Boolean.valueOf(prop.getString( "STREAM_DELETE_FINISH", ""))); this.setIsCrossed(Boolean.valueOf(prop.getString("STREAM_IS_CROSS", ""))); this.setChownShellCmd(prop.getString("CHOWN_SHELL_CMD", "")); this.setUploadPath(prop.getString("TEMP_UPLOAD_PATH", "")); } catch (ConfigurationException e) { e.printStackTrace(); } }? public String getVersion() { return version; }? public void setVersion(String version) { this.version = version; }? ...getter and setters 還有6對,別忘了} Maven依賴: <dependency> <groupId>commons-fileupload</groupId> <artifactId>commons-fileupload</artifactId> <version>1.3.1</version></dependency><dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.4</version></dependency><dependency> <groupId>org.json</groupId> <artifactId>json</artifactId> <version>20090211</version></dependency><dependency> <groupId>commons-configuration</groupId> <artifactId>commons-configuration</artifactId> <version>1.9</version></dependency> 其他還有一些TokenUtil.java就不給出了,作者代碼托管在oschina上,自己拉了看著改吧~ 效果圖稍候放出:
package com.dnion.oa.utils;?import org.apache.commons.configuration.ConfigurationException;import org.apache.commons.configuration.PropertiesConfiguration;?public class Configuration { private static Configuration config; /** * 版本號 */ private String version; private String crossServer; private String crossOrigins; private String dnionTranscoderUrl; private Boolean isDeleteFinished; private Boolean isCrossed; private String uploadPath; private Configuration() { }? public synchronized static Configuration getInstance() { if (config == null) { config = new Configuration(); config.init(); } return config; } /** * 初始化 */ private void init() { PropertiesConfiguration prop = new PropertiesConfiguration(); prop.setEncoding("utf-8"); try { prop.load("props/stream-config.properties"); this.setCrossServer(prop.getString("STREAM_CROSS_SERVER", "")); this.setCrossOrigins(prop.getString("STREAM_CROSS_ORIGIN", "")); this.setDnionTranscoderUrl(prop.getString("DNION_TRANS_CODER_URL", "")); this.setIsDeleteFinished(Boolean.valueOf(prop.getString( "STREAM_DELETE_FINISH", ""))); this.setIsCrossed(Boolean.valueOf(prop.getString("STREAM_IS_CROSS", ""))); this.setChownShellCmd(prop.getString("CHOWN_SHELL_CMD", "")); this.setUploadPath(prop.getString("TEMP_UPLOAD_PATH", "")); } catch (ConfigurationException e) { e.printStackTrace(); } }? public String getVersion() { return version; }? public void setVersion(String version) { this.version = version; }? ...getter and setters 還有6對,別忘了} Maven依賴: <dependency> <groupId>commons-fileupload</groupId> <artifactId>commons-fileupload</artifactId> <version>1.3.1</version></dependency><dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.4</version></dependency><dependency> <groupId>org.json</groupId> <artifactId>json</artifactId> <version>20090211</version></dependency><dependency> <groupId>commons-configuration</groupId> <artifactId>commons-configuration</artifactId> <version>1.9</version></dependency> 其他還有一些TokenUtil.java就不給出了,作者代碼托管在oschina上,自己拉了看著改吧~ 效果圖稍候放出:
總結
以上是生活随笔為你收集整理的stream+springmvc实现文件断点续传的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： CAS和Synchronized知识
- 下一篇： dev c++调试怎么看变量的值_利用G