`

java多线程下载服务器端支持

阅读更多
转自http://m.oschina.net/blog/167665

Java 服务器端支持断点续传的源代码【支持快车、迅雷】(仅支持 HTTP 协议)
网上关于 Java 支持 HTTP 断点续传的文章不少,但关于 Java 服务器端支持 HTTP 断点续传的却比较少。
本文是 Java 服务器端支持 HTTP 断点续传的源代码,支持快车、迅雷。
本文使用一个简单的 Servlet 来作为支持断点续传的下载示例,在 Java Web 项目下部署好后,可以使用诸如 http://localhost/cds/http 的链接来调用 Servlet,进而被快车/迅雷监听进行下载。
ArcSyncHttpDownloadServlet 源代码:
package com.defonds.cds.common; 

import java.io.BufferedOutputStream; 
import java.io.File; 
import java.io.IOException; 
import java.io.OutputStream; 
import java.io.RandomAccessFile; 

import javax.servlet.ServletException; 
import javax.servlet.http.HttpServlet; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 

import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 

import com.defonds.cds.common.util.CommonUtil; 

//HTTP 断点续传 demo(客户端测试工具:快车、迅雷) 
public class ArcSyncHttpDownloadServlet extends HttpServlet { 
private static final long serialVersionUID = 1L; 
final static Log log = LogFactory.getLog(ArcSyncHttpDownloadServlet.class); 

@Override 
protected void doGet(HttpServletRequest req, HttpServletResponse resp) 
throws ServletException, IOException { 
this.doPost(req, resp); 
} 

@Override 
protected void doPost(HttpServletRequest request, HttpServletResponse response) { 
File downloadFile = new File("D:/defonds/book/pattern/SteveJobsZH.pdf");//要下载的文件 
long fileLength = downloadFile.length();//记录文件大小 
long pastLength = 0;//记录已下载文件大小 
int rangeSwitch = 0;//0:从头开始的全文下载;1:从某字节开始的下载(bytes=27000-);2:从某字节开始到某字节结束的下载(bytes=27000-39000) 
long toLength = 0;//记录客户端需要下载的字节段的最后一个字节偏移量(比如bytes=27000-39000,则这个值是为39000) 
long contentLength = 0;//客户端请求的字节总量 
String rangeBytes = "";//记录客户端传来的形如“bytes=27000-”或者“bytes=27000-39000”的内容 
RandomAccessFile raf = null;//负责读取数据 
OutputStream os = null;//写出数据 
OutputStream out = null;//缓冲 
byte b[] = new byte[1024];//暂存容器 

if (request.getHeader("Range") != null) {// 客户端请求的下载的文件块的开始字节 
response.setStatus(javax.servlet.http.HttpServletResponse.SC_PARTIAL_CONTENT); 
log.info("request.getHeader(\"Range\")=" + request.getHeader("Range")); 
rangeBytes = request.getHeader("Range").replaceAll("bytes=", ""); 
if (rangeBytes.indexOf('-') == rangeBytes.length() - 1) {//bytes=969998336- 
rangeSwitch = 1; 
rangeBytes = rangeBytes.substring(0, rangeBytes.indexOf('-')); 
pastLength = Long.parseLong(rangeBytes.trim()); 
contentLength = fileLength - pastLength + 1;//客户端请求的是 969998336 之后的字节 
} else {//bytes=1275856879-1275877358 
rangeSwitch = 2; 
String temp0 = rangeBytes.substring(0,rangeBytes.indexOf('-')); 
String temp2 = rangeBytes.substring(rangeBytes.indexOf('-') + 1, rangeBytes.length()); 
pastLength = Long.parseLong(temp0.trim());//bytes=1275856879-1275877358,从第 1275856879 个字节开始下载 
toLength = Long.parseLong(temp2);//bytes=1275856879-1275877358,到第 1275877358 个字节结束 
contentLength = toLength - pastLength + 1;//客户端请求的是 1275856879-1275877358 之间的字节 
} 
} else {//从开始进行下载 
contentLength = fileLength;//客户端要求全文下载 
} 

/** 
* 如果设设置了Content-Length,则客户端会自动进行多线程下载。如果不希望支持多线程,则不要设置这个参数。 
* 响应的格式是: 
* Content-Length: [文件的总大小] - [客户端请求的下载的文件块的开始字节] 
* ServletActionContext.getResponse().setHeader("Content-Length", 
* new Long(file.length() - p).toString()); 
*/ 
response.reset();//告诉客户端允许断点续传多线程连接下载,响应的格式是:Accept-Ranges: bytes 
response.setHeader("Accept-Ranges", "bytes");//如果是第一次下,还没有断点续传,状态是默认的 200,无需显式设置;响应的格式是:HTTP/1.1 200 OK 
if (pastLength != 0) { 
//不是从最开始下载, 
//响应的格式是: 
//Content-Range: bytes [文件块的开始字节]-[文件的总大小 - 1]/[文件的总大小] 
log.info("----------------------------不是从开始进行下载!服务器即将开始断点续传..."); 
switch (rangeSwitch) { 
case 1 : {//针对 bytes=27000- 的请求 
String contentRange = new StringBuffer("bytes ").append(new Long(pastLength).toString()).append("-").append(new Long(fileLength - 1).toString()).append("/").append(new Long(fileLength).toString()).toString(); 
response.setHeader("Content-Range", contentRange); 
break; 
} 
case 2 : {//针对 bytes=27000-39000 的请求 
String contentRange = rangeBytes + "/" + new Long(fileLength).toString(); 
response.setHeader("Content-Range", contentRange); 
break; 
} 
default : { 
break; 
} 
} 
} else { 
//是从开始下载 
log.info("----------------------------是从开始进行下载!"); 
} 

try { 
response.addHeader("Content-Disposition", "attachment; filename=\"" + downloadFile.getName() + "\""); 
response.setContentType( CommonUtil.setContentType(downloadFile.getName()));// set the MIME type. 
response.addHeader("Content-Length", String.valueOf(contentLength)); 
os = response.getOutputStream(); 
out = new BufferedOutputStream(os); 
raf = new RandomAccessFile(downloadFile, "r"); 
try { 
switch (rangeSwitch) { 
case 0 : {//普通下载,或者从头开始的下载 
//同1 
} 
case 1 : {//针对 bytes=27000- 的请求 
raf.seek(pastLength);//形如 bytes=969998336- 的客户端请求,跳过 969998336 个字节 
int n = 0; 
while ((n = raf.read(b, 0, 1024)) != -1) { 
out.write(b, 0, n); 
} 
break; 
} 
case 2 : {//针对 bytes=27000-39000 的请求 
raf.seek(pastLength - 1);//形如 bytes=1275856879-1275877358 的客户端请求,找到第 1275856879 个字节 
int n = 0; 
long readLength = 0;//记录已读字节数 
while (readLength <= contentLength - 1024) {//大部分字节在这里读取 
n = raf.read(b, 0, 1024); 
readLength += 1024; 
out.write(b, 0, n); 
} 
if (readLength <= contentLength) {//余下的不足 1024 个字节在这里读取 
n = raf.read(b, 0, (int)(contentLength - readLength)); 
out.write(b, 0, n); 
} 
// 
// raf.seek(pastLength);//形如 bytes=1275856879-1275877358 的客户端请求,找到第 1275856879 个字节 
// while (raf.getFilePointer() < toLength) { 
// out.write(raf.read()); 
// } 
break; 
} 
default : { 
break; 
} 
} 
out.flush(); 
} catch(IOException ie) { 
/** 
* 在写数据的时候, 
* 对于 ClientAbortException 之类的异常, 
* 是因为客户端取消了下载,而服务器端继续向浏览器写入数据时, 
* 抛出这个异常,这个是正常的。 
* 尤其是对于迅雷这种吸血的客户端软件, 
* 明明已经有一个线程在读取 bytes=1275856879-1275877358, 
* 如果短时间内没有读取完毕,迅雷会再启第二个、第三个。。。线程来读取相同的字节段, 
* 直到有一个线程读取完毕,迅雷会 KILL 掉其他正在下载同一字节段的线程, 
* 强行中止字节读出,造成服务器抛 ClientAbortException。 
* 所以,我们忽略这种异常 
*/ 
//ignore 
} 
} 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); 
} 
} 
} 
} 
} 


ArcSyncHttpDownloadServlet 的 web.xml 配置清单: 
[html] view plaincopyprint? 
<!-- HTTP 断点续传 demo:127.0.0.1/cds/http --> 
<servlet> 
<servlet-name>httpServlet</servlet-name> 
<servlet-class>com.defonds.cds.common.ArcSyncHttpDownloadServlet</servlet-class> 
</servlet> 
<servlet-mapping> 
<servlet-name>httpServlet</servlet-name> 
<url-pattern>/http</url-pattern> 
</servlet-mapping> 


ArcSyncHttpDownloadServlet 调用到的工具类 com.defonds.cds.common.util.CommonUtil 源代码: 
[java] view plaincopyprint? 
package com.defonds.cds.common.util; 

public class CommonUtil { 

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; 
} 


}

分享到:
评论

相关推荐

    java 多线程服务器

    java 实现绘制指针时钟 和多线程服务器java 实现绘制指针时钟 和多线程服务器java 实现绘制指针时钟 和多线程服务器java 实现绘制指针时钟 和多线程服务器java 实现绘制指针时钟 和多线程服务器java 实现绘制指针...

    java多线程服务器

    一个进程可以创建多个线程,线程与线程间的通信方式比较容易。本设计主要是编写一个多线程的网络通信程序,不同的线程处理不同类型的消息,比如有专门处理TCP的线程、专门处理UDP消息的线程等。

    java多线程下载

    1.得到服务器下载文件的大小,然后在本地设置一个临时文件和服务器端文件大小一致 a)获得访问网络地址 b)通过URL对象的openConnection()方法打开连接,返回一个连接对象 c)设置请求头 i.setRequestMethod ii....

    Java多线程-Socket编程

    Java 多线程-Socket 编程是指在 Java 语言中使用多线程技术来实现网络编程,特别是使用 Socket 编程来实现客户端和服务器端的通信。在 Java 中,多线程可以使用 Thread 类和 Runnable 接口来实现,而 Socket 编程则...

    java多线程URL方式下载单个大文件

    在Java编程中,多线程下载大文件是一种常见的优化策略,尤其对于网络资源如文件或图片的下载。这种策略能够利用多核处理器的优势,通过并发处理来提高下载速度。本篇将详细介绍如何使用Java实现基于URL的单个大文件...

    程序设计-基于Java的多线程Web服务器

    Java的Socket API是实现网络通信的基础,它可以用来创建服务器端的监听套接字,等待客户端的连接请求。 在"HttpRequest.java"中,我们可以预见到这是一个解析HTTP请求的类。HTTP请求由三部分组成:请求行(包括方法...

    java 多线程简易聊天 精简版

    Java多线程技术是编程领域中的重要概念,尤其在开发高效、并发的网络应用程序时,如简易聊天程序,它的应用尤为关键。在这个“java 多线程简易聊天 精简版”项目中,我们将深入探讨Java如何实现多线程环境下的客户端...

    JAVA之多线程服务器

    服务器端多线程,各客户端向服务器发送服务请求

    Java多线程技术精讲

    Java多线程技术是Java编程中的重要组成部分,它允许程序同时执行多个任务,极大地提高了程序的效率和响应性。在现代计算机系统中,多线程是实现并发处理的关键技术,尤其在服务器端应用和高性能计算中不可或缺。 ...

    武汉理工大学Java多线程实验源码

    Java多线程是Java编程中的核心概念,尤其在并发编程领域有着重要的地位。这个实验源码来自武汉理工大学的大二上学期Java课程,旨在帮助学生深入理解并实践Java的多线程技术。 首先,我们来看看“CTExp01”到“CTExp...

    java实现的多线程服务器

    综上所述,这个“java实现的多线程服务器”项目涵盖了Java多线程编程、网络编程、并发控制、异常处理和性能优化等多个重要知识点,对于学习和实践Java服务器开发具有很高的价值。通过深入研究和理解这个项目,开发者...

    Java 多线程下载

    这种方法可以充分利用网络资源,提高下载效率,尤其是在服务器端支持多个并发连接的情况下。 **多线程下载原理:** 1. **文件分块**:首先,客户端需要知道文件的总大小,然后根据需要将文件分割成多个部分,每个...

    java多线程加队列上传文件_后台处理

    ### Java多线程加队列上传文件_后台处理 #### 概述 本文将详细介绍一个基于Java实现的多线程文件上传系统,并结合队列管理技术来优化后台处理流程。该系统通过创建多个线程来并行处理客户端的文件上传请求,同时...

    Java多线程技术及其在网络编程中的应用.pdf

    ### Java多线程技术及其在网络编程中的应用 #### 引言 Java作为一种强大的面向对象的编程语言,由SUN公司开发,旨在支持分布式...无论是对于服务器端还是客户端的开发,理解并熟练掌握Java多线程技术都是非常必要的。

    java多线程服务器源码

    【Java多线程服务器源码】是针对初学者和入门者的一个经典实例,它展示了如何在Java中构建一个多线程的服务器程序。Java语言因为其内置的多线程支持和强大的网络编程能力,使得开发这样的程序变得更加简单和安全。 ...

    Java多线程的聊天室程序

    标题所涉及的知识点为“Java多线程的聊天室程序”,这一主题包含了对Java多线程编程、Socket编程、网络通信以及C/S架构模式的理解和应用。在实际开发中,需要掌握Java的基础知识,熟悉网络编程,了解多线程的原理和...

    Java 多线程web服务器

    Java多线程Web服务器是一种基于Java技术构建的服务器,它利用多线程模型来处理并发的HTTP请求,以实现高效且可扩展的网络服务。在Java中,多线程是并发编程的重要工具,允许程序同时执行多个任务,这对于处理来自...

    socket-支持断点续传java多线程下载

    ### socket支持断点续传Java多线程下载技术解析 #### 概述 在软件开发领域,特别是对于大型文件的下载需求,断点续传功能显得尤为重要。它能够确保在网络不稳定的情况下,用户仍然可以顺利地完成文件下载。本文将...

    java 多线程 socket聊天程序

    Java多线程Socket聊天程序是基于Java编程语言实现的一个网络通信应用,主要涉及了Java的Socket编程和多线程技术。这两个核心概念在Java中占据了非常重要的地位,特别是在开发网络应用和服务端系统时。 首先,Java ...

    java多线程学习-ftp上传

    Java多线程学习是编程领域中的重要一环,特别是在服务器端和网络编程中,多线程技术能够有效地利用系统资源,提高程序的并发性。FTP(File Transfer Protocol)上传则是通过网络将本地文件传输到远程服务器的过程。...

Global site tag (gtag.js) - Google Analytics