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è)開始
{
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ì)有所幫助。
欄 目:Java編程
下一篇:java編程的30個(gè)建議
本文標(biāo)題:Java編程實(shí)現(xiàn)服務(wù)器端支持?jǐn)帱c(diǎn)續(xù)傳的方法(可支持快車、迅雷)
本文地址:http://www.jygsgssxh.com/a1/Javabiancheng/8481.html
您可能感興趣的文章
- 01-10Java咖啡館(1)——嘆咖啡
- 01-10Java Socket編程(三) 服務(wù)器Sockets
- 01-10Java進(jìn)階:Struts多模塊的技巧
- 01-10Java Socket編程(一) Socket傳輸模式
- 01-10Java Socket編程(二) Java面向連接的類
- 01-10Java運(yùn)行時(shí)多態(tài)性的實(shí)現(xiàn)
- 01-10Java經(jīng)驗(yàn)點(diǎn)滴:處理沒有被捕獲的異常
- 01-10Java Socket編程(四) 重復(fù)和并發(fā)服務(wù)器
- 01-10Java中的浮點(diǎn)數(shù)分析
- 01-10面向?qū)ο缶幊?Java中的抽象數(shù)據(jù)類型


閱讀排行
- 1C語(yǔ)言 while語(yǔ)句的用法詳解
- 2java 實(shí)現(xiàn)簡(jiǎn)單圣誕樹的示例代碼(圣誕
- 3利用C語(yǔ)言實(shí)現(xiàn)“百馬百擔(dān)”問(wèn)題方法
- 4C語(yǔ)言中計(jì)算正弦的相關(guān)函數(shù)總結(jié)
- 5c語(yǔ)言計(jì)算三角形面積代碼
- 6什么是 WSH(腳本宿主)的詳細(xì)解釋
- 7C++ 中隨機(jī)函數(shù)random函數(shù)的使用方法
- 8正則表達(dá)式匹配各種特殊字符
- 9C語(yǔ)言十進(jìn)制轉(zhuǎn)二進(jìn)制代碼實(shí)例
- 10C語(yǔ)言查找數(shù)組里數(shù)字重復(fù)次數(shù)的方法
本欄相關(guān)
- 01-10Java咖啡館(1)——嘆咖啡
- 01-10JVM的垃圾回收機(jī)制詳解和調(diào)優(yōu)
- 01-10Java Socket編程(三) 服務(wù)器Sockets
- 01-10Java進(jìn)階:Struts多模塊的技巧
- 01-10J2SE 1.5版本的新特性一覽
- 01-10Java Socket編程(一) Socket傳輸模式
- 01-10Java運(yùn)行時(shí)多態(tài)性的實(shí)現(xiàn)
- 01-10Java Socket編程(二) Java面向連接的類
- 01-10Java Socket編程(四) 重復(fù)和并發(fā)服務(wù)
- 01-10Java經(jīng)驗(yàn)點(diǎn)滴:處理沒有被捕獲的異常
隨機(jī)閱讀
- 01-10delphi制作wav文件的方法
- 01-11ajax實(shí)現(xiàn)頁(yè)面的局部加載
- 04-02jquery與jsp,用jquery
- 01-10SublimeText編譯C開發(fā)環(huán)境設(shè)置
- 08-05織夢(mèng)dedecms什么時(shí)候用欄目交叉功能?
- 01-10使用C語(yǔ)言求解撲克牌的順子及n個(gè)骰子
- 01-11Mac OSX 打開原生自帶讀寫NTFS功能(圖文
- 08-05dedecms(織夢(mèng))副欄目數(shù)量限制代碼修改
- 01-10C#中split用法實(shí)例總結(jié)
- 08-05DEDE織夢(mèng)data目錄下的sessions文件夾有什


