仓酷云

标题: JAVA教程之用Java完成断点续传 [打印本页]

作者: 乐观 时间: 2015-1-18 11:21
标题: JAVA教程之用Java完成断点续传
自己的整个学习思路完全被老师的讲课思路所牵制，这样几节课听下来，恐怕自己的见解都应该是书里的知识点了，根本谈不上自身发现问题，分析问题，和解决问题能力的切实提高。(一)断点续传的道理
实在断点续传的道理很复杂，就是在Http的哀求上和一样平常的下载有所分歧罢了。
打个例如，扫瞄器哀求服务器上的一个文时，所收回的哀求以下：
假定服务器域名为wwww.sjtu.edu.cn，文件名为down.zip。
GET/down.zipHTTP/1.1
Accept:image/gif,image/x-xbitmap,image/jpeg,image/pjpeg,application/vnd.ms-
excel,application/msword,application/vnd.ms-powerpoint,*/*
Accept-Language:zh-cn
Accept-Encoding:gzip,deflate
User-Agent:Mozilla/4.0(compatible;MSIE5.01;WindowsNT5.0)
Connection:Keep-Alive

服务器收到哀求后，按请求寻觅哀求的文件，提取文件的信息，然后前往给扫瞄器，前往信息以下：

200
Content-Length=106786028
Accept-Ranges=bytes
Date=Mon,30Apr200112:56:11GMT
ETag=W/"02ca57e173c11:95b"
Content-Type=application/octet-stream
Server=Microsoft-IIS/5.0
Last-Modified=Mon,30Apr200112:56:11GMT

所谓断点续传，也就是要从文件已下载的中央入手下手持续下载。以是在客户端扫瞄器传给
Web服务器的时分要多加一条信息--从那里入手下手。
上面是用本人编的一个"扫瞄器"来传送哀求信息给Web服务器，请求从2000070字节入手下手。
GET/down.zipHTTP/1.0
User-Agent:NetFox
RANGE:bytes=2000070-
Accept:text/html,image/gif,image/jpeg,*;q=.2,*/*;q=.2

细心看一下就会发明多了一行RANGE:bytes=2000070-
这一行的意义就是告知服务器down.zip这个文件从2000070字节入手下手传，后面的字节不必传了。
服务器收到这个哀求今后，前往的信息以下：
206
Content-Length=106786028
Content-Range=bytes2000070-106786027/106786028
Date=Mon,30Apr200112:55:20GMT
ETag=W/"02ca57e173c11:95b"
Content-Type=application/octet-stream
Server=Microsoft-IIS/5.0
Last-Modified=Mon,30Apr200112:55:20GMT

和后面服务器前往的信息对照一下，就会发明增添了一行：
Content-Range=bytes2000070-106786027/106786028
前往的代码也改成206了，而不再是200了。

晓得了以上道理，就能够举行断点续传的编程了。

(二)Java完成断点续传的关头几点

(1)用甚么办法完成提交RANGE:bytes=2000070-。
固然用最原始的Socket是一定能完成的，不外那样太省事了，实在Java的net包中供应了这类功效。代码以下：
URLurl=newURL("http://www.sjtu.edu.cn/down.zip");
HttpURLConnectionhttpConnection=(HttpURLConnection)url.openConnection

();
//设置User-Agent
httpConnection.setRequestProperty("User-Agent","NetFox");
//设置断点续传的入手下手地位
httpConnection.setRequestProperty("RANGE","bytes=2000070");
//取得输出流
InputStreaminput=httpConnection.getInputStream();

从输出流中掏出的字撙节就是down.zip文件从2000070入手下手的字撙节。
人人看，实在断点续传用Java完成起来仍是很复杂的吧。
接上去要做的事就是怎样保留取得的流到文件中往了。

保留文件接纳的办法。
我接纳的是IO包中的RandAccessFile类。
操纵相称复杂，假定从2000070处入手下手保留文件，代码以下：
RandomAccessoSavedFile=newRandomAccessFile("down.zip","rw");
longnPos=2000070;
//定位文件指针到nPos地位
oSavedFile.seek(nPos);
byte[]b=newbyte[1024];
intnRead;
//从输出流中读进字撙节，然后写到文件中
while((nRead=input.read(b,0,1024))>0)
{
oSavedFile.write(b,0,nRead);
}

怎样，也很复杂吧。
接上去要做的就是整分解一个完全的程序了。包含一系列的线程把持等等。

(三)断点续传内核的完成
次要用了6个类，包含一个测试类。
SiteFileFetch.java卖力全部文件的抓取，把持外部线程(FileSplitterFetch类)。
FileSplitterFetch.java卖力部分文件的抓取。
FileAccess.java卖力文件的存储。
SiteInfoBean.java要抓取的文件的信息，如文件保留的目次，名字，抓取文件的URL等。
Utility.java工具类，放一些复杂的办法。
TestMethod.java测试类。

上面是源程序：
/*
**SiteFileFetch.java
*/
packageNetFox;
importjava.io.*;
importjava.net.*;

publicclassSiteFileFetchextendsThread{

SiteInfoBeansiteInfoBean=null;//文件信息Bean
long[]nStartPos;//入手下手地位
long[]nEndPos;//停止地位
FileSplitterFetch[]fileSplitterFetch;//子线程对象
longnFileLength;//文件长度
booleanbFirst=true;//是不是第一次取文件
booleanbStop=false;//中断标记
FiletmpFile;//文件下载的一时信息
DataOutputStreamoutput;//输入到文件的输入流

publicSiteFileFetch(SiteInfoBeanbean)throwsIOException
{
siteInfoBean=bean;
//tmpFile=File.createTempFile("zhong","1111",newFile(bean.getSFilePath()));
tmpFile=newFile(bean.getSFilePath()+File.separator+bean.getSFileName()+".info");
if(tmpFile.exists())
{
bFirst=false;
read_nPos();
}
else
{
nStartPos=newlong[bean.getNSplitter()];
nEndPos=newlong[bean.getNSplitter()];
}

}

publicvoidrun()
{
//取得文件长度
//支解文件
//实例FileSplitterFetch
//启动FileSplitterFetch线程
//守候子线程前往
try{
if(bFirst)
{
nFileLength=getFileSize();
if(nFileLength==-1)
{
System.err.println("FileLengthisnotknown!");
}
elseif(nFileLength==-2)
{
System.err.println("Fileisnotaccess!");
}
else
{
for(inti=0;i<nStartPos.length;i++)
{
nStartPos[i]=(long)(i*(nFileLength/nStartPos.length));
}
for(inti=0;i<nEndPos.length-1;i++)
{
nEndPos[i]=nStartPos[i+1];
}
nEndPos[nEndPos.length-1]=nFileLength;
}
}

//启动子线程
fileSplitterFetch=newFileSplitterFetch[nStartPos.length];
for(inti=0;i<nStartPos.length;i++)
{
fileSplitterFetch[i]=newFileSplitterFetch(siteInfoBean.getSSiteURL(),
siteInfoBean.getSFilePath()+File.separator+siteInfoBean.getSFileName(),
nStartPos[i],nEndPos[i],i);
Utility.log("Thread"+i+",nStartPos="+nStartPos[i]+",nEndPos="+nEndPos[i]);
fileSplitterFetch[i].start();
}
//fileSplitterFetch[nPos.length-1]=newFileSplitterFetch(siteInfoBean.getSSiteURL(),
siteInfoBean.getSFilePath()+File.separator+siteInfoBean.getSFileName(),nPos[nPos.length-1],nFileLength,nPos.length-1);
//Utility.log("Thread"+(nPos.length-1)+",nStartPos="+nPos[nPos.length-1]+",
nEndPos="+nFileLength);
//fileSplitterFetch[nPos.length-1].start();

//守候子线程停止
//intcount=0;
//是不是停止while轮回
booleanbreakWhile=false;

while(!bStop)
{
write_nPos();
Utility.sleep(500);
breakWhile=true;

for(inti=0;i<nStartPos.length;i++)
{
if(!fileSplitterFetch[i].bDownOver)
{
breakWhile=false;
break;
}
}
if(breakWhile)
break;

//count++;
//if(count>4)
//siteStop();
}

System.err.println("文件下载停止！");
}
catch(Exceptione){e.printStackTrace();}
}

//取得文件长度
publiclonggetFileSize()
{
intnFileLength=-1;
try{
URLurl=newURL(siteInfoBean.getSSiteURL());
HttpURLConnectionhttpConnection=(HttpURLConnection)url.openConnection();
httpConnection.setRequestProperty("User-Agent","NetFox");

intresponseCode=httpConnection.getResponseCode();
if(responseCode>=400)
{
processErrorCode(responseCode);
return-2;//-2representaccessiserror
}

StringsHeader;

for(inti=1;;i++)
{
//DataInputStreamin=newDataInputStream(httpConnection.getInputStream());
//Utility.log(in.readLine());
sHeader=httpConnection.getHeaderFieldKey(i);
if(sHeader!=null)
{
if(sHeader.equals("Content-Length"))
{
nFileLength=Integer.parseInt(httpConnection.getHeaderField(sHeader));
break;
}
}
else
break;
}
}
catch(IOExceptione){e.printStackTrace();}
catch(Exceptione){e.printStackTrace();}

Utility.log(nFileLength);

returnnFileLength;
}

//保留下载信息（文件指针地位）
privatevoidwrite_nPos()
{
try{
output=newDataOutputStream(newFileOutputStream(tmpFile));
output.writeInt(nStartPos.length);
for(inti=0;i<nStartPos.length;i++)
{
//output.writeLong(nPos[i]);
output.writeLong(fileSplitterFetch[i].nStartPos);
output.writeLong(fileSplitterFetch[i].nEndPos);
}
output.close();
}
catch(IOExceptione){e.printStackTrace();}
catch(Exceptione){e.printStackTrace();}
}

//读取保留的下载信息（文件指针地位）
privatevoidread_nPos()
{
try{
DataInputStreaminput=newDataInputStream(newFileInputStream(tmpFile));
intnCount=input.readInt();
nStartPos=newlong[nCount];
nEndPos=newlong[nCount];
for(inti=0;i<nStartPos.length;i++)
{
nStartPos[i]=input.readLong();
nEndPos[i]=input.readLong();
}
input.close();
}
catch(IOExceptione){e.printStackTrace();}
catch(Exceptione){e.printStackTrace();}
}

privatevoidprocessErrorCode(intnErrorCode)
{
System.err.println("ErrorCode:"+nErrorCode);
}

//中断文件下载
publicvoidsiteStop()
{
bStop=true;
for(inti=0;i<nStartPos.length;i++)
fileSplitterFetch[i].splitterStop();

}
}
/*
**FileSplitterFetch.java
*/
packageNetFox;

importjava.io.*;
importjava.net.*;

publicclassFileSplitterFetchextendsThread{

StringsURL;//FileURL
longnStartPos;//FileSnippetStartPosition
longnEndPos;//FileSnippetEndPosition
intnThreadID;//ThreadsID
booleanbDownOver=false;//Downingisover
booleanbStop=false;//Stopidentical
FileAccessIfileAccessI=null;//FileAccessinterface

publicFileSplitterFetch(StringsURL,StringsName,longnStart,longnEnd,intid)throwsIOException
{
this.sURL=sURL;
this.nStartPos=nStart;
this.nEndPos=nEnd;
nThreadID=id;
fileAccessI=newFileAccessI(sName,nStartPos);
}

publicvoidrun()
{
while(nStartPos<nEndPos&&!bStop)
{

try{
URLurl=newURL(sURL);
HttpURLConnectionhttpConnection=(HttpURLConnection)url.openConnection();
httpConnection.setRequestProperty("User-Agent","NetFox");
StringsProperty="bytes="+nStartPos+"-";
httpConnection.setRequestProperty("RANGE",sProperty);
Utility.log(sProperty);

InputStreaminput=httpConnection.getInputStream();
//logResponseHead(httpConnection);

byte[]b=newbyte[1024];
intnRead;
while((nRead=input.read(b,0,1024))>0&&nStartPos<nEndPos&&!bStop)
{
nStartPos+=fileAccessI.write(b,0,nRead);
//if(nThreadID==1)
//Utility.log("nStartPos="+nStartPos+",nEndPos="+nEndPos);
}

Utility.log("Thread"+nThreadID+"isover!");
bDownOver=true;
//nPos=fileAccessI.write(b,0,nRead);
}
catch(Exceptione){e.printStackTrace();}
}
}

//打印回应的头信息
publicvoidlogResponseHead(HttpURLConnectioncon)
{
for(inti=1;;i++)
{
Stringheader=con.getHeaderFieldKey(i);
if(header!=null)
//responseHeaders.put(header,httpConnection.getHeaderField(header));
Utility.log(header+":"+con.getHeaderField(header));
else
break;
}
}

publicvoidsplitterStop()
{
bStop=true;
}

}

/*
**FileAccess.java
*/
packageNetFox;
importjava.io.*;

publicclassFileAccessIimplementsSerializable{

RandomAccessFileoSavedFile;
longnPos;

publicFileAccessI()throwsIOException
{
this("",0);
}

publicFileAccessI(StringsName,longnPos)throwsIOException
{
oSavedFile=newRandomAccessFile(sName,"rw");
this.nPos=nPos;
oSavedFile.seek(nPos);
}

publicsynchronizedintwrite(byte[]b,intnStart,intnLen)
{
intn=-1;
try{
oSavedFile.write(b,nStart,nLen);
n=nLen;
}
catch(IOExceptione)
{
e.printStackTrace();
}

returnn;
}

}

/*
**SiteInfoBean.java
*/
packageNetFox;

publicclassSiteInfoBean{

privateStringsSiteURL;//SitesURL
privateStringsFilePath;//SavedFilesPath
privateStringsFileName;//SavedFilesName
privateintnSplitter;//CountofSplitedDownloadingFile

publicSiteInfoBean()
{
//defaultvalueofnSplitteris5
this("","","",5);
}

publicSiteInfoBean(StringsURL,StringsPath,StringsName,intnSpiltter)
{
sSiteURL=sURL;
sFilePath=sPath;
sFileName=sName;
this.nSplitter=nSpiltter;

}

publicStringgetSSiteURL()
{
returnsSiteURL;
}

publicvoidsetSSiteURL(Stringvalue)
{
sSiteURL=value;
}

publicStringgetSFilePath()
{
returnsFilePath;
}

publicvoidsetSFilePath(Stringvalue)
{
sFilePath=value;
}

publicStringgetSFileName()
{
returnsFileName;
}

publicvoidsetSFileName(Stringvalue)
{
sFileName=value;
}

publicintgetNSplitter()
{
returnnSplitter;
}

publicvoidsetNSplitter(intnCount)
{
nSplitter=nCount;
}
}

/*
**Utility.java
*/
packageNetFox;

publicclassUtility{

publicUtility()
{

}

publicstaticvoidsleep(intnSecond)
{
try{
Thread.sleep(nSecond);
}
catch(Exceptione)
{
e.printStackTrace();
}
}

publicstaticvoidlog(StringsMsg)
{
System.err.println(sMsg);
}

publicstaticvoidlog(intsMsg)
{
System.err.println(sMsg);
}
}

/*
**TestMethod.java
*/
packageNetFox;

publicclassTestMethod{

publicTestMethod()
{///xx/weblogic60b2_win.exe
try{
SiteInfoBeanbean=newSiteInfoBean("http://localhost/xx/weblogic60b2_win.exe","L: emp","weblogic60b2_win.exe",5);
//SiteInfoBeanbean=newSiteInfoBean("http://localhost:8080/down.zip","L: emp","weblogic60b2_win.exe",5);
SiteFileFetchfileFetch=newSiteFileFetch(bean);
fileFetch.start();
}
catch(Exceptione){e.printStackTrace();}

}

publicstaticvoidmain(String[]args)
{
newTestMethod();
}
}

关于第二点：俺问问你，如果是企业级项目的话，诸如RMI，EJB，等一些关键技术，这些难道都不需要学么？如果光是使用jsp,servlet，javabean的话。

作者: 因胸联盟 时间: 2015-1-20 21:04
Jive的资料在很多网站上都有，大家可以找来研究一下。相信你读完代码后，会有脱胎换骨的感觉。遗憾的是Jive从2.5以后就不再无条件的开放源代码，同时有licence限制。不过幸好还有中国一流的Java程序员关注它，外国人不开源了，中国人就不能开源吗？这里向大家推荐一个汉化的Jive版本—J道。Jive(J道版)是由中国Java界大名鼎鼎的banq在Jive 2.1版本基础上改编而成, 全中文，增加了一些实用功能，如贴图，用户头像和用户资料查询等，而且有一个开发团队在不断升级。你可以访问banq的网站

作者: 小妖女 时间: 2015-1-30 05:14
还好，SUN提供了Javabean可以把你的JSP中的 Java代码封装起来，便于调用也便于重用。

作者: 冷月葬花魂 时间: 2015-2-2 10:44
Pet Store.（宠物店）是SUN公司为了演示其J2EE编程规范而推出的开放源码的程序，应该很具有权威性，想学J2EE和EJB的朋友不要错过了。

作者: 活着的死人 时间: 2015-2-6 16:44
Pet Store.（宠物店）是SUN公司为了演示其J2EE编程规范而推出的开放源码的程序，应该很具有权威性，想学J2EE和EJB的朋友不要错过了。

作者: 愤怒的大鸟 时间: 2015-2-7 18:51
让你能够真正掌握接口或抽象类的应用，从而在原来的Java语言基础上跃进一步，更重要的是，设计模式反复向你强调一个宗旨：要让你的程序尽可能的可重用。

作者: 再见西城 时间: 2015-2-21 10:28
不过，每次的执行编译后的字节码需要消耗一定的时间，这同时也在一定程度上降低了 Java 程序的运行效率。

作者: 再现理想 时间: 2015-2-26 13:18
是一种使用者不需花费很多时间学习的语言

作者: 不帅 时间: 2015-3-8 10:58
《JAVA语言程序设计》或《JAVA从入门到精通》这两本书开始学，等你编程有感觉的时候也可以回看一下。《JAVA读书笔记》这本书，因为讲的代码很多，也很容易看懂，涉及到面也到位。是你学习技术巩固的好书，学完后就看看《JAVA编程思想》这本书，找找一个自己写的代码跟书上的代码有什么不一样。

作者: 谁可相欹 时间: 2015-3-10 07:26
你一定会高兴地说，哈哈，原来成为Java高手就这么简单啊!记得Tomjava也曾碰到过一个项目经理，号称Java很简单，只要三个月就可以学会。

作者: 仓酷云 时间: 2015-3-17 05:10
应用在电视机、电话、闹钟、烤面包机等家用电器的控制和通信。由于这些智能化家电的市场需求没有预期的高，Sun公司放弃了该项计划。随着1990年代互联网的发展

作者: 精灵巫婆 时间: 2015-3-23 21:15
一直感觉JAVA很大，很杂，找不到学习方向，前两天在网上找到了这篇文章，感觉不错，给没有方向的我指了一个方向，先不管对不对，做下来再说。

欢迎光临仓酷云 (http://ckuyun.com/)