- 浏览: 318756 次
- 性别:
- 来自: 上海
文章分类
- 全部博客 (129)
- java (64)
- spring (6)
- Morphia (0)
- js (7)
- mongodb (9)
- linux (19)
- 11异常异常异常异常异常 (0)
- aaaaaaaaaaaaaaaaaaaaa (0)
- oracle (2)
- ftp (1)
- IP (0)
- MAC (0)
- maven (3)
- jenkins (1)
- shell (1)
- windows10 (0)
- sonar (1)
- quartz (1)
- memcached (1)
- tomcat (2)
- javascript (1)
- activemq (1)
- excel (1)
- windows (1)
- eclipse (1)
- RHEL (1)
- CENTOS (1)
- nginx (5)
- shiro (2)
- redis (1)
- mybatis (1)
- http (1)
- mysql (1)
- python (2)
- pip (1)
- spring-boot (1)
- javafx (1)
最新评论
-
yzhw:
...
Jenkins+SVN+Maven+Shell 实现项目一键发布 -
0筱蔡0:
你好 我想问下: 看您的文档 我把服务搭了起来 ,但 ...
lvs+keepalived+vsftp配置FTP服务器负载均衡 -
jiyilee:
accp_huangxin 写道写得不错!学习学习
Jenkins+SVN+Maven+Shell 实现项目一键发布 -
laputa73:
ftp集群的问题是,各个服务器之间是否要实现文件同步?服务虽然 ...
lvs+keepalived+vsftp配置FTP服务器负载均衡 -
王博009:
Java实现服务器端动态流断点续传下载支持
大家知道Tomcat之流对静态资源可以实现断点续传支持,但是如果是一个被控制的流,如有权限控制,或下载地址仅是个代理的时候,这时候需要自己实现断点续传的支持,小弟不才,这里提供基本断点续传[a-,-b,a-b]的简单实现,经验证,可支持迅雷7和火狐的多次断点续传。现贴出代码,大家共同分享:
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; /** * 文件下载(支持断点续传【迅雷\快车\旋风\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("跳过"+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 { /** * 断点续传支持 * @param file * @param request * @param response * @return 跳过多少字节 */ public static long headerSetting(File file,HttpServletRequest request, HttpServletResponse response) { long len = file.length();//文件长度 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个 { contentLength = Long.parseLong(range.substring(1));//要下载的量 end = len-1; start = len - contentLength; } else if (range.endsWith("-"))//从哪个开始 { 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流相关处理工具类
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转码 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方法来自于CSDN的网友总结,另外此类还不支持多Range配置如[a-b,c-d,-e]等。
参考地址:http://blog.csdn.net/defonds/article/details/7074352
在此共同声明。
评论
3 楼
王博009
2016-03-18
2 楼
juicewall
2014-10-28
又测了一下,迅雷极速板和chrome 35.0,360极速浏览器7.5,360安全浏览器7都可以断点就是用IE11下载暂停按钮变灰无法暂停
1 楼
juicewall
2014-10-28
用IE11下载暂停按钮变灰无法暂停,但是用极速360可以断点下载,请问IE11怎么解决啊!!
发表评论
-
LRU算法模拟实现
2021-03-11 19:07 464LRU (移除最少使用内存) 模拟算法 语言:JAVA ... -
8g内存推荐JVM配置
2021-01-25 13:08 1345-Xms4096m -Xmx4096m -Xmn307 ... -
Boot Redis连单机、哨兵、集群模式代码
2021-01-14 14:35 304redis: # #-- 单机模式 -- ... -
jedis实现分布式锁
2021-01-09 16:26 391private static final String LO ... -
俄罗斯方块javafx版
2020-07-03 10:59 701package fx; import javafx. ... -
表达式计算器
2020-06-04 14:27 212package scan.util; import j ... -
jstack信息状态集
2019-05-13 14:05 493UNINITIALIZED - Should neve ... -
Spring boot 2.0替换默认日志框架logback到 Slf4j + log4j2
2018-11-29 17:13 1289第一步 移除默认日志加载依赖 <dependen ... -
maven上传命令详解
2018-11-21 20:43 1120mvn deploy:deploy-file -Dgro ... -
java agent实现dubbo灰度发布DEMO
2018-04-25 17:11 3946核心代码DEMO,仅供参考: package com.z ... -
LOG4J在junit中自动加载
2018-04-13 13:44 841InputStream log4j = Yourclass ... -
面试经典题目,欢迎补充答案
2018-03-27 16:42 728java java中用到树结构的集合类 Future 和 ... -
Java四大引用类型
2018-03-14 14:13 692强引用: 只要引用 ... -
Java实现深克隆
2018-03-13 08:52 660引用至:http://blog.csdn.net/kent ... -
如何知晓LOG4J加载的是哪个文件
2018-01-29 17:33 509在JVM启动参数JVM_OPTS中加入自定义参数 -Dl ... -
Spring的BeanFactoryPostProcessor和BeanPostProcessor
2018-01-08 11:45 652传送门: http://blog.csdn.net/ca ... -
基于netty的websocket
2017-10-16 14:47 546基于netty的websocket,见附件。 网上抄的,但 ... -
Log4j自定义日志输出格式
2017-09-14 10:52 882代码人,废话不多,直接上代码 主要重写部分,请关注以下代 ... -
java实现路径通配符*,**,?
2017-09-08 17:25 5873* 表示匹配0或多个不是/的字符 ** 表示匹配0或多个 ... -
SpringMVC JACKSON反序列化JSON精华语句
2017-08-18 11:35 592Type paramType = types[i]; Cl ...
相关推荐
支持断点续传的下载进度对话框,已测试过的,大家放心使用
NULL 博文链接:https://xiaoming123123.iteye.com/blog/1764714
主要介绍了Java编程实现服务器端支持断点续传的方法,涉及Java文件传输的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下
最近研究了一下socket套接字 实现java多线程 断点续传文件 在网上查找了很多例子 然后学习了大家的方法 最后利用网上的例子 自己整合了一份多线程 断点续传文件的代码 并且能实现客户端发送完毕之后 接收服务器端的...
预先采用vue.js + plupload + element-ui实现了文件在浏览器端的发送,而采用了spring boot + spring + spring mvc + mybatis实现了文件在服务器端的接收和存储。 本项目为预期实现 效果图 演示地址: : ps:用git...
JSP将Java代码和特定变动内容嵌入到静态的页面中,实现以静态页面为模板,动态生成其中的部分内容。JSP引入了被称为“JSP动作”的XML标签,用来调用内建功能。另外,可以创建JSP标签库,然后像使用标准HTML或XML标签...
断点续传:支持在文件传输过程中断,重新连接后能够从断点处继续传输,提高传输效率。 安全性:可以采用加密算法、身份验证等技术确保文件传输过程中数据的安全性。 技术实现: Socket编程:利用Java的Socket API...
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 3...
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 ...
客户端和服务器端通过socket实现大文件的传输,客户端运行在android平台上,服务器端运行在PC机上。
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 ...
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 3...
4.服务器端采用C++语言自主实现,对上传文件的尺寸无限制,天生支持超大文件上传。 而基于PHP、JAVA等技术实现的文件上传服务天生无法支持超大文件上传,无法逾越2GB的最大文件尺寸瓶颈; 5.服务器端采用无缓冲即时...
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 3...
Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。 递归遍历矩阵 1个目标文件,简单! 多人聊天室 ...
Tcp服务端与客户端的JAVA实例源代码 2个目标文件 摘要:Java源码,文件操作,TCP,服务器 Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多...
Java服务器断点上传代码,通过线程池解决并发性控制,android端源代码详细解读。配备视频讲解,更有助于理解!
Tcp服务端与客户端的JAVA实例源代码 2个目标文件 摘要:Java源码,文件操作,TCP,服务器 Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多...
第1篇 Java编程基础 第1章 Java开发环境的搭建(教学视频:9分钟) 2 1.1 理解Java 2 1.2 搭建Java所需环境 3 1.2.1 下载JDK 3 1.2.2 安装JDK 4 1.2.3 配置环境 5 1.2.4 测试JDK配置...