Java編程實(shí)現(xiàn)服務(wù)器端支持?jǐn)帱c(diǎn)續(xù)傳的方法(可支持快車、迅雷)
本文實(shí)例講述了Java編程實(shí)現(xiàn)服務(wù)器端支持?jǐn)帱c(diǎn)續(xù)傳的方法。分享給大家供大家參考,具體如下:
大家知道Tomcat之流對(duì)靜態(tài)資源可以實(shí)現(xiàn)斷點(diǎn)續(xù)傳支持,但是如果是一個(gè)被控制的流,如有權(quán)限控制,或下載地址僅是個(gè)代理的時(shí)候,這時(shí)候需要自己實(shí)現(xiàn)斷點(diǎn)續(xù)傳的支持,小弟不才,這里提供基本斷點(diǎn)續(xù)傳[a-,-b,a-b]的簡(jiǎn)單實(shí)現(xiàn),經(jīng)驗(yàn)證,可支持迅雷7和火狐的多次斷點(diǎn)續(xù)傳?,F(xiàn)貼出代碼,大家共同分享:
Servlet
import java.io.BufferedOutputStream; import java.io.File; import java.io.IOException; import java.io.RandomAccessFile; import java.io.UnsupportedEncodingException; import java.net.URI; import java.net.URISyntaxException; import java.net.URLDecoder; import javax.servlet.ServletException; import javax.servlet.ServletOutputStream; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.bsteel.cloud.storage.servlet.base.BaseServlet; import com.bsteel.cloud.storage.utils.FileUtil; /** * 文件下載(支持?jǐn)帱c(diǎn)續(xù)傳【迅雷\快車\旋風(fēng)\Firefox\Chrome】) * @author jdkleo * */ public class FileIoServlet extends BaseServlet { private static final long serialVersionUID = 1L; @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { this.doPost(req, resp); } @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{ download(request,response); } /** * 文件下載 * @param request * @param response * @throws UnsupportedEncodingException */ private void download(HttpServletRequest request,HttpServletResponse response) throws UnsupportedEncodingException { File downloadFile = getFile(request); long pos = FileUtil.headerSetting(downloadFile, request, response); // log.info("跳過(guò)"+pos); ServletOutputStream os = null; BufferedOutputStream out = null; RandomAccessFile raf = null; byte b[] = new byte[1024];//暫存容器 try { os = response.getOutputStream(); out = new BufferedOutputStream(os); raf = new RandomAccessFile(downloadFile, "r"); raf.seek(pos); try { int n = 0; while ((n = raf.read(b, 0, 1024)) != -1) { out.write(b, 0, n); } out.flush(); } catch(IOException ie) { } } catch (Exception e) { log.error(e.getMessage(), e); } finally { if (out != null) { try { out.close(); } catch (IOException e) { log.error(e.getMessage(), e); } } if (raf != null) { try { raf.close(); } catch (IOException e) { log.error(e.getMessage(), e); } } } } private File getFile(HttpServletRequest request) throws UnsupportedEncodingException { String uriStr = request.getParameter("uri"); if (null != uriStr){ uriStr = URLDecoder.decode(uriStr,"UTF-8"); if (uriStr.startsWith("file://")){ uriStr = uriStr.substring(7); return new File(uriStr); }else if (uriStr.startsWith("hbase://")){ try { return new File(new URI(uriStr)); } catch (URISyntaxException e) { log.error(e.getMessage(),e); } } } throw new RuntimeException("it's not a real uri"); } }
Range支持
import java.io.File; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /** * 文件處理工具 * @author jdkleo * */ public class FileUtil { /** * 斷點(diǎn)續(xù)傳支持 * @param file * @param request * @param response * @return 跳過(guò)多少字節(jié) */ public static long headerSetting(File file,HttpServletRequest request, HttpServletResponse response) { long len = file.length();//文件長(zhǎng)度 if ( null == request.getHeader("Range") ){ setResponse(new RangeSettings(len),file.getName(),response); return 0; } String range = request.getHeader("Range").replaceAll("bytes=", ""); RangeSettings settings = getSettings(len,range); setResponse(settings,file.getName(),response); return settings.getStart(); } private static void setResponse(RangeSettings settings,String fileName, HttpServletResponse response) { response.addHeader("Content-Disposition", "attachment; filename=\"" + IoUtil.toUtf8String(fileName) + "\""); response.setContentType( IoUtil.setContentType(fileName));// set the MIME type. if (!settings.isRange()) { response.addHeader("Content-Length", String.valueOf(settings.getTotalLength())); } else { long start = settings.getStart(); long end = settings.getEnd(); long contentLength = settings.getContentLength(); response.setStatus(javax.servlet.http.HttpServletResponse.SC_PARTIAL_CONTENT); response.addHeader("Content-Length", String.valueOf(contentLength)); String contentRange = new StringBuffer("bytes ").append(start).append("-").append(end).append("/").append(settings.getTotalLength()).toString(); response.setHeader("Content-Range", contentRange); } } private static RangeSettings getSettings(long len, String range) { long contentLength = 0; long start = 0; long end = 0; if (range.startsWith("-"))// -500,最后500個(gè) { contentLength = Long.parseLong(range.substring(1));//要下載的量 end = len-1; start = len - contentLength; } else if (range.endsWith("-"))//從哪個(gè)開(kāi)始 { start = Long.parseLong(range.replace("-", "")); end = len -1; contentLength = len - start; } else//從a到b { String[] se = range.split("-"); start = Long.parseLong(se[0]); end = Long.parseLong(se[1]); contentLength = end-start+1; } return new RangeSettings(start,end,contentLength,len); } }
Range封裝
public class RangeSettings{ private long start; private long end; private long contentLength; private long totalLength; private boolean range; public RangeSettings(){ super(); } public RangeSettings(long start, long end, long contentLength,long totalLength) { this.start = start; this.end = end; this.contentLength = contentLength; this.totalLength = totalLength; this.range = true; } public RangeSettings(long totalLength) { this.totalLength = totalLength; } public long getStart() { return start; } public void setStart(long start) { this.start = start; } public long getEnd() { return end; } public void setEnd(long end) { this.end = end; } public long getContentLength() { return contentLength; } public void setContentLength(long contentLength) { this.contentLength = contentLength; } public long getTotalLength() { return totalLength; } public void setTotalLength(long totalLength) { this.totalLength = totalLength; } public boolean isRange() { return range; } }
IO流相關(guān)處理工具類
import java.io.InputStream; public class IoUtil { public static String setContentType(String returnFileName){ String contentType = "application/octet-stream"; if (returnFileName.lastIndexOf(".") < 0) return contentType; returnFileName = returnFileName.toLowerCase(); returnFileName = returnFileName.substring(returnFileName.lastIndexOf(".")+1); if (returnFileName.equals("html") || returnFileName.equals("htm") || returnFileName.equals("shtml")){ contentType = "text/html"; } else if (returnFileName.equals("css")){ contentType = "text/css"; } else if (returnFileName.equals("xml")){ contentType = "text/xml"; } else if (returnFileName.equals("gif")){ contentType = "image/gif"; } else if (returnFileName.equals("jpeg") || returnFileName.equals("jpg")){ contentType = "image/jpeg"; } else if (returnFileName.equals("js")){ contentType = "application/x-javascript"; } else if (returnFileName.equals("atom")){ contentType = "application/atom+xml"; } else if (returnFileName.equals("rss")){ contentType = "application/rss+xml"; } else if (returnFileName.equals("mml")){ contentType = "text/mathml"; } else if (returnFileName.equals("txt")){ contentType = "text/plain"; } else if (returnFileName.equals("jad")){ contentType = "text/vnd.sun.j2me.app-descriptor"; } else if (returnFileName.equals("wml")){ contentType = "text/vnd.wap.wml"; } else if (returnFileName.equals("htc")){ contentType = "text/x-component"; } else if (returnFileName.equals("png")){ contentType = "image/png"; } else if (returnFileName.equals("tif") || returnFileName.equals("tiff")){ contentType = "image/tiff"; } else if (returnFileName.equals("wbmp")){ contentType = "image/vnd.wap.wbmp"; } else if (returnFileName.equals("ico")){ contentType = "image/x-icon"; } else if (returnFileName.equals("jng")){ contentType = "image/x-jng"; } else if (returnFileName.equals("bmp")){ contentType = "image/x-ms-bmp"; } else if (returnFileName.equals("svg")){ contentType = "image/svg+xml"; } else if (returnFileName.equals("jar") || returnFileName.equals("var") || returnFileName.equals("ear")){ contentType = "application/java-archive"; } else if (returnFileName.equals("doc")){ contentType = "application/msword"; } else if (returnFileName.equals("pdf")){ contentType = "application/pdf"; } else if (returnFileName.equals("rtf")){ contentType = "application/rtf"; } else if (returnFileName.equals("xls")){ contentType = "application/vnd.ms-excel"; } else if (returnFileName.equals("ppt")){ contentType = "application/vnd.ms-powerpoint"; } else if (returnFileName.equals("7z")){ contentType = "application/x-7z-compressed"; } else if (returnFileName.equals("rar")){ contentType = "application/x-rar-compressed"; } else if (returnFileName.equals("swf")){ contentType = "application/x-shockwave-flash"; } else if (returnFileName.equals("rpm")){ contentType = "application/x-redhat-package-manager"; } else if (returnFileName.equals("der") || returnFileName.equals("pem") || returnFileName.equals("crt")){ contentType = "application/x-x509-ca-cert"; } else if (returnFileName.equals("xhtml")){ contentType = "application/xhtml+xml"; } else if (returnFileName.equals("zip")){ contentType = "application/zip"; } else if (returnFileName.equals("mid") || returnFileName.equals("midi") || returnFileName.equals("kar")){ contentType = "audio/midi"; } else if (returnFileName.equals("mp3")){ contentType = "audio/mpeg"; } else if (returnFileName.equals("ogg")){ contentType = "audio/ogg"; } else if (returnFileName.equals("m4a")){ contentType = "audio/x-m4a"; } else if (returnFileName.equals("ra")){ contentType = "audio/x-realaudio"; } else if (returnFileName.equals("3gpp") || returnFileName.equals("3gp")){ contentType = "video/3gpp"; } else if (returnFileName.equals("mp4") ){ contentType = "video/mp4"; } else if (returnFileName.equals("mpeg") || returnFileName.equals("mpg") ){ contentType = "video/mpeg"; } else if (returnFileName.equals("mov")){ contentType = "video/quicktime"; } else if (returnFileName.equals("flv")){ contentType = "video/x-flv"; } else if (returnFileName.equals("m4v")){ contentType = "video/x-m4v"; } else if (returnFileName.equals("mng")){ contentType = "video/x-mng"; } else if (returnFileName.equals("asx") || returnFileName.equals("asf")){ contentType = "video/x-ms-asf"; } else if (returnFileName.equals("wmv")){ contentType = "video/x-ms-wmv"; } else if (returnFileName.equals("avi")){ contentType = "video/x-msvideo"; } return contentType; } // UTF8轉(zhuǎn)碼 public static String toUtf8String(String s) { StringBuffer sb = new StringBuffer(); int len = s.toCharArray().length; for (int i = 0; i < len; i++) { char c = s.charAt(i); if (c >= 0 && c <= 255) { sb.append(c); } else { byte[] b; try { b = Character.toString(c).getBytes("utf-8"); } catch (Exception ex) { System.out.println(ex); b = new byte[0]; } for (int j = 0; j < b.length; j++) { int k = b[j]; if (k < 0) k += 256; sb.append("%" + Integer.toHexString(k).toUpperCase()); } } } String s_utf8 = sb.toString(); sb.delete(0, sb.length()); sb.setLength(0); sb = null; return s_utf8; } public static InputStream skipFully(InputStream in,long howMany)throws Exception{ long remainning = howMany; long len = 0; while(remainning>0){ len = in.skip(len); remainning -= len; } return in; } }
注有些類比如IoUtil方法來(lái)自于CSDN的網(wǎng)友總結(jié),另外此類還不支持多Range配置如[a-b,c-d,-e]等。
希望本文所述對(duì)大家Java程序設(shè)計(jì)有所幫助。
- 很簡(jiǎn)單的Java斷點(diǎn)續(xù)傳實(shí)現(xiàn)原理
- Java如何實(shí)現(xiàn)HTTP斷點(diǎn)續(xù)傳功能
- java實(shí)現(xiàn)文件斷點(diǎn)續(xù)傳下載功能
- RxJava+Retrofit+OkHttp實(shí)現(xiàn)多文件下載之?dāng)帱c(diǎn)續(xù)傳
- java斷點(diǎn)續(xù)傳功能實(shí)例(java獲取遠(yuǎn)程文件)
- Java實(shí)現(xiàn)的斷點(diǎn)續(xù)傳功能的示例代碼
- 基于Ok+Rxjava+retrofit實(shí)現(xiàn)斷點(diǎn)續(xù)傳下載
- 基于Java實(shí)現(xiàn)多線程下載并允許斷點(diǎn)續(xù)傳
- 命令行使用支持?jǐn)帱c(diǎn)續(xù)傳的java多線程下載器
- java實(shí)現(xiàn)文件的斷點(diǎn)續(xù)傳
相關(guān)文章
java基本教程之synchronized關(guān)鍵字 java多線程教程
這篇文章主要介紹了java的synchronized原理、synchronized基本規(guī)則、synchronized方法 和 synchronized代碼塊、實(shí)例鎖和全局鎖2014-01-01Java多線程中關(guān)于join方法的使用實(shí)例解析
本文通過(guò)實(shí)例代碼給大家實(shí)例介紹了Java多線程中關(guān)于join方法的使用,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下2017-01-01使用JAXBContext 設(shè)置xml節(jié)點(diǎn)屬性
這篇文章主要介紹了使用JAXBContext 設(shè)置xml節(jié)點(diǎn)屬性的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-08-08Java中的String、StringBuilder、StringBuffer三者的區(qū)別詳解
這篇文章主要介紹了Java中的String、StringBuilder、StringBuffer三者的區(qū)別詳解,就是String,StringBuilder以及StringBuffer這三個(gè)類之間有什么區(qū)別呢,自己從網(wǎng)上搜索了一些資料,有所了解了之后在這里整理一下,便于大家觀看,需要的朋友可以參考下2023-12-12Jsoup解析html實(shí)現(xiàn)招聘信息查詢功能
這篇文章主要為大家詳細(xì)介紹了Jsoup解析html實(shí)現(xiàn)招聘信息查詢功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-04-04解決Shiro 處理ajax請(qǐng)求攔截登錄超時(shí)的問(wèn)題
這篇文章主要介紹了解決Shiro 處理ajax請(qǐng)求攔截登錄超時(shí)的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-09-09spring mvc 使用kaptcha配置生成驗(yàn)證碼實(shí)例
本篇文章主要介紹了spring mvc 使用kaptcha生成驗(yàn)證碼實(shí)例,詳細(xì)的介紹了使用Kaptcha 生成驗(yàn)證碼的步驟,有興趣的可以了解一下2017-04-04淺析Java迭代器Iterator和Iterable的區(qū)別
Java語(yǔ)言中,Iterator和Iterable都是用來(lái)遍歷集合類數(shù)據(jù)結(jié)構(gòu)的接口,雖然它們有很多相似的地方,但在具體實(shí)現(xiàn)中卻有著一些不同之處,本文將詳細(xì)分析它們的區(qū)別,并提供相應(yīng)的代碼示例,需要的朋友可以參考下2023-07-07