首页 > 开发 > Java > 正文

Java编程实现服务器端支持断点续传的方法(可支持快车、迅雷)

2024-07-13 09:56:09
字体：大 中 小
来源：转载
供稿：网友

这篇文章主要介绍了Java编程实现服务器端支持断点续传的方法,涉及Java文件传输的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下

本文实例讲述了Java编程实现服务器端支持断点续传的方法。分享给大家供大家参考，具体如下：

大家知道Tomcat之流对静态资源可以实现断点续传支持，但是如果是一个被控制的流，如有权限控制，或下载地址仅是个代理的时候，这时候需要自己实现断点续传的支持，小弟不才，这里提供基本断点续传[a-,-b,a-b]的简单实现，经验证，可支持迅雷7和火狐的多次断点续传。现贴出代码，大家共同分享：

Servlet

 

 
  1. import java.io.BufferedOutputStream; 
  2. import java.io.File; 
  3. import java.io.IOException; 
  4. import java.io.RandomAccessFile; 
  5. import java.io.UnsupportedEncodingException; 
  6. import java.net.URI; 
  7. import java.net.URISyntaxException; 
  8. import java.net.URLDecoder; 
  9. import javax.servlet.ServletException; 
  10. import javax.servlet.ServletOutputStream; 
  11. import javax.servlet.http.HttpServletRequest; 
  12. import javax.servlet.http.HttpServletResponse; 
  13. import com.bsteel.cloud.storage.servlet.base.BaseServlet; 
  14. import com.bsteel.cloud.storage.utils.FileUtil; 
  15. /** 
  16. * 文件下载(支持断点续传【迅雷/快车/旋风/Firefox/Chrome】) 
  17. * @author jdkleo 
  18. * 
  19. */ 
  20. public class FileIoServlet extends BaseServlet { 
  21. private static final long serialVersionUID = 1L; 
  22. @Override 
  23. protected void doGet(HttpServletRequest req, HttpServletResponse resp) 
  24. throws ServletException, IOException { 
  25. this.doPost(req, resp); 
  26. } 
  27. @Override 
  28. protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException{ 
  29. download(request,response); 
  30. } 
  31. /** 
  32. * 文件下载 
  33. * @param request 
  34. * @param response 
  35. * @throws UnsupportedEncodingException  
  36. */ 
  37. private void download(HttpServletRequest request,HttpServletResponse response) throws UnsupportedEncodingException { 
  38. File downloadFile = getFile(request); 
  39. long pos = FileUtil.headerSetting(downloadFile, request, response); 
  40. // log.info("跳过"+pos); 
  41. ServletOutputStream os = null;  
  42. BufferedOutputStream out = null; 
  43. RandomAccessFile raf = null; 
  44. byte b[] = new byte[1024];//暂存容器 
  45. try { 
  46. os = response.getOutputStream(); 
  47. out = new BufferedOutputStream(os); 
  48. raf = new RandomAccessFile(downloadFile, "r"); 
  49. raf.seek(pos); 
  50. try { 
  51. int n = 0; 
  52. while ((n = raf.read(b, 0, 1024)) != -1) { 
  53. out.write(b, 0, n); 
  54. } 
  55. out.flush(); 
  56. } catch(IOException ie) { 
  57. } 
  58. } catch (Exception e) { 
  59. log.error(e.getMessage(), e); 
  60. } finally { 
  61. if (out != null) { 
  62. try { 
  63. out.close(); 
  64. } catch (IOException e) { 
  65. log.error(e.getMessage(), e); 
  66. } 
  67. } 
  68. if (raf != null) { 
  69. try { 
  70. raf.close(); 
  71. } catch (IOException e) { 
  72. log.error(e.getMessage(), e); 
  73. } 
  74. } 
  75. } 
  76. } 
  77. private File getFile(HttpServletRequest request) throws UnsupportedEncodingException { 
  78. String uriStr = request.getParameter("uri"); 
  79. if (null != uriStr){ 
  80. uriStr = URLDecoder.decode(uriStr,"UTF-8"); 
  81. if (uriStr.startsWith("file://")){ 
  82. uriStr = uriStr.substring(7); 
  83. return new File(uriStr); 
  84. }else if (uriStr.startsWith("hbase://")){ 
  85. try { 
  86. return new File(new URI(uriStr)); 
  87. } catch (URISyntaxException e) { 
  88. log.error(e.getMessage(),e); 
  89. } 
  90. } 
  91. } 
  92. throw new RuntimeException("it's not a real uri"); 
  93. } 
  94. } 

Range支持

 

 
  1. import java.io.File; 
  2. import javax.servlet.http.HttpServletRequest; 
  3. import javax.servlet.http.HttpServletResponse; 
  4. /** 
  5. * 文件处理工具 
  6. * @author jdkleo 
  7. * 
  8. */ 
  9. public class FileUtil { 
  10. /** 
  11. * 断点续传支持 
  12. * @param file 
  13. * @param request 
  14. * @param response 
  15. * @return 跳过多少字节 
  16. */ 
  17. public static long headerSetting(File file,HttpServletRequest request, HttpServletResponse response) { 
  18. long len = file.length();//文件长度 
  19. if ( null == request.getHeader("Range") ){ 
  20. setResponse(new RangeSettings(len),file.getName(),response); 
  21. return 0; 
  22. } 
  23. String range = request.getHeader("Range").replaceAll("bytes=", ""); 
  24. RangeSettings settings = getSettings(len,range); 
  25. setResponse(settings,file.getName(),response); 
  26. return settings.getStart(); 
  27. } 
  28. private static void setResponse(RangeSettings settings,String fileName, HttpServletResponse response) { 
  29. response.addHeader("Content-Disposition", "attachment; filename=/"" + IoUtil.toUtf8String(fileName) + "/""); 
  30. response.setContentType( IoUtil.setContentType(fileName));// set the MIME type. 
  31. if (!settings.isRange()) 
  32. { 
  33. response.addHeader("Content-Length", String.valueOf(settings.getTotalLength())); 
  34. } 
  35. else 
  36. { 
  37. long start = settings.getStart(); 
  38. long end = settings.getEnd(); 
  39. long contentLength = settings.getContentLength(); 
  40. response.setStatus(javax.servlet.http.HttpServletResponse.SC_PARTIAL_CONTENT); 
  41. response.addHeader("Content-Length", String.valueOf(contentLength)); 
  42. String contentRange = new StringBuffer("bytes ").append(start).append("-").append(end).append("/").append(settings.getTotalLength()).toString(); 
  43. response.setHeader("Content-Range", contentRange); 
  44. } 
  45. } 
  46. private static RangeSettings getSettings(long len, String range) { 
  47. long contentLength = 0; 
  48. long start = 0; 
  49. long end = 0; 
  50. if (range.startsWith("-"))// -500，最后500个 
  51. { 
  52. contentLength = Long.parseLong(range.substring(1));//要下载的量 
  53. end = len-1; 
  54. start = len - contentLength; 
  55. } 
  56. else if (range.endsWith("-"))//从哪个开始 
  57. { 
  58. start = Long.parseLong(range.replace("-", "")); 
  59. end = len -1; 
  60. contentLength = len - start; 
  61. } 
  62. else//从a到b 
  63. { 
  64. String[] se = range.split("-"); 
  65. start = Long.parseLong(se[0]); 
  66. end = Long.parseLong(se[1]); 
  67. contentLength = end-start+1; 
  68. } 
  69. return new RangeSettings(start,end,contentLength,len); 
  70. } 
  71. } 

Range封装

 

 
  1. public class RangeSettings{ 
  2. private long start; 
  3. private long end; 
  4. private long contentLength; 
  5. private long totalLength; 
  6. private boolean range; 
  7. public RangeSettings(){ 
  8. super(); 
  9. } 
  10. public RangeSettings(long start, long end, long contentLength,long totalLength) { 
  11. this.start = start; 
  12. this.end = end; 
  13. this.contentLength = contentLength; 
  14. this.totalLength = totalLength; 
  15. this.range = true; 
  16. } 
  17. public RangeSettings(long totalLength) { 
  18. this.totalLength = totalLength; 
  19. } 
  20. public long getStart() { 
  21. return start; 
  22. } 
  23. public void setStart(long start) { 
  24. this.start = start; 
  25. } 
  26. public long getEnd() { 
  27. return end; 
  28. } 
  29. public void setEnd(long end) { 
  30. this.end = end; 
  31. } 
  32. public long getContentLength() { 
  33. return contentLength; 
  34. } 
  35. public void setContentLength(long contentLength) { 
  36. this.contentLength = contentLength; 
  37. } 
  38. public long getTotalLength() { 
  39. return totalLength; 
  40. } 
  41. public void setTotalLength(long totalLength) { 
  42. this.totalLength = totalLength; 
  43. } 
  44. public boolean isRange() { 
  45. return range; 
  46. } 
  47. } 

IO流相关处理工具类

 

 
  1. import java.io.InputStream; 
  2. public class IoUtil { 
  3. public static String setContentType(String returnFileName){ 
  4. String contentType = "application/octet-stream"; 
  5. if (returnFileName.lastIndexOf(".") < 0) 
  6. return contentType; 
  7. returnFileName = returnFileName.toLowerCase(); 
  8. returnFileName = returnFileName.substring(returnFileName.lastIndexOf(".")+1); 
  9. if (returnFileName.equals("html") || returnFileName.equals("htm") || returnFileName.equals("shtml")){ 
  10. contentType = "text/html"; 
  11. } else if (returnFileName.equals("css")){ 
  12. contentType = "text/css"; 
  13. } else if (returnFileName.equals("xml")){ 
  14. contentType = "text/xml"; 
  15. } else if (returnFileName.equals("gif")){ 
  16. contentType = "image/gif"; 
  17. } else if (returnFileName.equals("jpeg") || returnFileName.equals("jpg")){ 
  18. contentType = "image/jpeg"; 
  19. } else if (returnFileName.equals("js")){ 
  20. contentType = "application/x-javascript"; 
  21. } else if (returnFileName.equals("atom")){ 
  22. contentType = "application/atom+xml"; 
  23. } else if (returnFileName.equals("rss")){ 
  24. contentType = "application/rss+xml"; 
  25. } else if (returnFileName.equals("mml")){ 
  26. contentType = "text/mathml";  
  27. } else if (returnFileName.equals("txt")){ 
  28. contentType = "text/plain"; 
  29. } else if (returnFileName.equals("jad")){ 
  30. contentType = "text/vnd.sun.j2me.app-descriptor"; 
  31. } else if (returnFileName.equals("wml")){ 
  32. contentType = "text/vnd.wap.wml"; 
  33. } else if (returnFileName.equals("htc")){ 
  34. contentType = "text/x-component"; 
  35. } else if (returnFileName.equals("png")){ 
  36. contentType = "image/png"; 
  37. } else if (returnFileName.equals("tif") || returnFileName.equals("tiff")){ 
  38. contentType = "image/tiff"; 
  39. } else if (returnFileName.equals("wbmp")){ 
  40. contentType = "image/vnd.wap.wbmp"; 
  41. } else if (returnFileName.equals("ico")){ 
  42. contentType = "image/x-icon"; 
  43. } else if (returnFileName.equals("jng")){ 
  44. contentType = "image/x-jng"; 
  45. } else if (returnFileName.equals("bmp")){ 
  46. contentType = "image/x-ms-bmp"; 
  47. } else if (returnFileName.equals("svg")){ 
  48. contentType = "image/svg+xml"; 
  49. } else if (returnFileName.equals("jar") || returnFileName.equals("var") || returnFileName.equals("ear")){ 
  50. contentType = "application/java-archive"; 
  51. } else if (returnFileName.equals("doc")){ 
  52. contentType = "application/msword"; 
  53. } else if (returnFileName.equals("pdf")){ 
  54. contentType = "application/pdf"; 
  55. } else if (returnFileName.equals("rtf")){ 
  56. contentType = "application/rtf"; 
  57. } else if (returnFileName.equals("xls")){ 
  58. contentType = "application/vnd.ms-excel";  
  59. } else if (returnFileName.equals("ppt")){ 
  60. contentType = "application/vnd.ms-powerpoint"; 
  61. } else if (returnFileName.equals("7z")){ 
  62. contentType = "application/x-7z-compressed"; 
  63. } else if (returnFileName.equals("rar")){ 
  64. contentType = "application/x-rar-compressed"; 
  65. } else if (returnFileName.equals("swf")){ 
  66. contentType = "application/x-shockwave-flash"; 
  67. } else if (returnFileName.equals("rpm")){ 
  68. contentType = "application/x-redhat-package-manager"; 
  69. } else if (returnFileName.equals("der") || returnFileName.equals("pem") || returnFileName.equals("crt")){ 
  70. contentType = "application/x-x509-ca-cert"; 
  71. } else if (returnFileName.equals("xhtml")){ 
  72. contentType = "application/xhtml+xml"; 
  73. } else if (returnFileName.equals("zip")){ 
  74. contentType = "application/zip"; 
  75. } else if (returnFileName.equals("mid") || returnFileName.equals("midi") || returnFileName.equals("kar")){ 
  76. contentType = "audio/midi"; 
  77. } else if (returnFileName.equals("mp3")){ 
  78. contentType = "audio/mpeg"; 
  79. } else if (returnFileName.equals("ogg")){ 
  80. contentType = "audio/ogg"; 
  81. } else if (returnFileName.equals("m4a")){ 
  82. contentType = "audio/x-m4a"; 
  83. } else if (returnFileName.equals("ra")){ 
  84. contentType = "audio/x-realaudio"; 
  85. } else if (returnFileName.equals("3gpp") || returnFileName.equals("3gp")){ 
  86. contentType = "video/3gpp"; 
  87. } else if (returnFileName.equals("mp4") ){ 
  88. contentType = "video/mp4"; 
  89. } else if (returnFileName.equals("mpeg") || returnFileName.equals("mpg") ){ 
  90. contentType = "video/mpeg"; 
  91. } else if (returnFileName.equals("mov")){ 
  92. contentType = "video/quicktime"; 
  93. } else if (returnFileName.equals("flv")){ 
  94. contentType = "video/x-flv"; 
  95. } else if (returnFileName.equals("m4v")){ 
  96. contentType = "video/x-m4v"; 
  97. } else if (returnFileName.equals("mng")){ 
  98. contentType = "video/x-mng"; 
  99. } else if (returnFileName.equals("asx") || returnFileName.equals("asf")){ 
  100. contentType = "video/x-ms-asf"; 
  101. } else if (returnFileName.equals("wmv")){ 
  102. contentType = "video/x-ms-wmv"; 
  103. } else if (returnFileName.equals("avi")){ 
  104. contentType = "video/x-msvideo"; 
  105. } 
  106. return contentType; 
  107. } 
  108. // UTF8转码 
  109. public static String toUtf8String(String s) { 
  110. StringBuffer sb = new StringBuffer(); 
  111. int len = s.toCharArray().length; 
  112. for (int i = 0; i < len; i++) { 
  113. char c = s.charAt(i); 
  114. if (c >= 0 && c <= 255) { 
  115. sb.append(c); 
  116. } else { 
  117. byte[] b; 
  118. try { 
  119. b = Character.toString(c).getBytes("utf-8"); 
  120. } catch (Exception ex) { 
  121. System.out.println(ex); 
  122. b = new byte[0]; 
  123. } 
  124. for (int j = 0; j < b.length; j++) { 
  125. int k = b[j]; 
  126. if (k < 0) 
  127. k += 256; 
  128. sb.append("%" + Integer.toHexString(k).toUpperCase()); 
  129. } 
  130. } 
  131. } 
  132. String s_utf8 = sb.toString(); 
  133. sb.delete(0, sb.length()); 
  134. sb.setLength(0); 
  135. sb = null; 
  136. return s_utf8; 
  137. } 
  138. public static InputStream skipFully(InputStream in,long howMany)throws Exception{ 
  139. long remainning = howMany; 
  140. long len = 0; 
  141. while(remainning>0){ 
  142. len = in.skip(len); 
  143. remainning -= len; 
  144. } 
  145. return in; 
  146. } 
  147. } 

注有些类比如IoUtil方法来自于CSDN的网友总结，另外此类还不支持多Range配置如[a-b,c-d,-e]等。

希望本文所述对大家Java程序设计有所帮助。


注：相关教程知识阅读请移步到JAVA教程频道。

上一篇：java图片格式转换的三段代码

下一篇：Java各种排序算法汇总(冒泡,选择,归并,希尔及堆排序等)

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表
学习交流
更多

如何查找有故障的配件

如何查找有故障的配件...
热门图片
更多
猜你喜欢的新闻
猜你喜欢的关注

新闻热点

最牛同桌！我考了696分我同桌考了703分
2024-06-26 22:28:41
650分！高二女生考入北大：遗憾不能上高三
2024-06-26 22:26:16
男生估分600只考了397 妈妈：高考虽重要，但不代表所有
2024-06-26 22:23:01
唐尚珺回应是否会直播带货：有人出100万想和他合作！
2024-06-25 19:29:23
名校抢人名场面：清华、北大太拼了！
2024-06-25 19:22:14
男生高考语文满分！网友：第一次听说
2024-06-25 19:19:15

疑难解答

图片精选

网友关注

关于本站 - 网上投稿 - 商务合作 - 隐私政策 - 网站地图
Copyright © 2008 - 2024 VEVB.COM. All Rights Reserved.武林网 版权所有