乐观 发表于 2015-1-18 11:21:34

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;
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;
nEndPos=newlong;
}



}


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=(long)(i*(nFileLength/nStartPos.length));
}
for(inti=0;i<nEndPos.length-1;i++)
{
nEndPos=nStartPos;
}
nEndPos=nFileLength;
}
}


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


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


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


for(inti=0;i<nStartPos.length;i++)
{
if(!fileSplitterFetch.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);
output.writeLong(fileSplitterFetch.nStartPos);
output.writeLong(fileSplitterFetch.nEndPos);
}
output.close();
}
catch(IOExceptione){e.printStackTrace();}
catch(Exceptione){e.printStackTrace();}
}


//读取保留的下载信息(文件指针地位)
privatevoidread_nPos()
{
try{
DataInputStreaminput=newDataInputStream(newFileInputStream(tmpFile));
intnCount=input.readInt();
nStartPos=newlong;
nEndPos=newlong;
for(inti=0;i<nStartPos.length;i++)
{
nStartPos=input.readLong();
nEndPos=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.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;
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:18

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

小妖女 发表于 2015-1-30 05:14:55

还好,SUN提供了Javabean可以把你的JSP中的 Java代码封装起来,便于调用也便于重用。

冷月葬花魂 发表于 2015-2-2 10:44:56

Pet Store.(宠物店)是SUN公司为了演示其J2EE编程规范而推出的开放源码的程序,应该很具有权威性,想学J2EE和EJB的朋友不要 错过了。

活着的死人 发表于 2015-2-6 16:44:36

Pet Store.(宠物店)是SUN公司为了演示其J2EE编程规范而推出的开放源码的程序,应该很具有权威性,想学J2EE和EJB的朋友不要 错过了。

愤怒的大鸟 发表于 2015-2-7 18:51:13

让你能够真正掌握接口或抽象类的应用,从而在原来的Java语言基础上跃进一步,更重要的是,设计模式反复向你强调一个宗旨:要让你的程序尽可能的可重用。

再见西城 发表于 2015-2-21 10:28:34

不过,每次的执行编译后的字节码需要消耗一定的时间,这同时也在一定程度上降低了 Java 程序的运行效率。

再现理想 发表于 2015-2-26 13:18:50

是一种使用者不需花费很多时间学习的语言

不帅 发表于 2015-3-8 10:58:06

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

谁可相欹 发表于 2015-3-10 07:26:35

你一定会高兴地说,哈哈,原来成为Java高手就这么简单啊!记得Tomjava也曾碰到过一个项目经理,号称Java很简单,只要三个月就可以学会。

仓酷云 发表于 2015-3-17 05:10:03

应用在电视机、电话、闹钟、烤面包机等家用电器的控制和通信。由于这些智能化家电的市场需求没有预期的高,Sun公司放弃了该项计划。随着1990年代互联网的发展

精灵巫婆 发表于 2015-3-23 21:15:25

一直感觉JAVA很大,很杂,找不到学习方向,前两天在网上找到了这篇文章,感觉不错,给没有方向的我指了一个方向,先不管对不对,做下来再说。
页: [1]
查看完整版本: JAVA教程之用Java完成断点续传