用Java实现HTTP断点续传功能(副附详细的源代码)

《用Java实现HTTP断点续传功能(副附详细的源代码)》由会员分享，可在线阅读，更多相关《用Java实现HTTP断点续传功能(副附详细的源代码)（14页珍藏版）》请在装配图网上搜索。

1、本资料由-大学生创业|创业|创业网用Java实现HTTP断点续传功能.2007年06月25日 星期一 16:13(一)断点续传的原理其实断点续传的原理很简单，就是在Http的请求上和一般的下载有所不同而已。打个比方，浏览器请求服务器上的一个文时，所发出的请求如下：假设服务器域名为，文件名为down.zip。GET /down.zip HTTP/1.1Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, application/vnd.ms-excel, application/msword, application/vnd.m

2、s-powerpoint, */*Accept-Language: zh-cnAccept-Encoding: gzip, deflateUser-Agent: Mozilla/4.0 (compatible; MSIE 5.01; Windows NT 5.0)Connection: Keep-Alive服务器收到请求后，按要求寻找请求的文件，提取文件的信息，然后返回给浏览器，返回信息如下200Content-Length=106786028Accept-Ranges=bytesDate=Mon, 30 Apr 2001 12:56:11 GMTETag=W/02ca57e173c11:95

3、bContent-Type=application/octet-streamServer=Microsoft-IIS/5.0Last-Modified=Mon, 30 Apr 2001 12:56:11 GMT所谓断点续传，也就是要从文件已经下载的地方开始继续下载。所以在客户端浏览器传给Web服务器的时候要多加一条信息-从哪里开始（客户端提供一个文件偏移）。下面是用自己编的一个浏览器来传递请求信息给Web服务器，要求从2000070字节开始。GET /down.zip HTTP/1.0User-Agent: NetFoxRANGE: bytes=2000070-Accept: text/htm

4、l, image/gif, image/jpeg, *; q=.2, */*; q=.2仔细看一下就会发现多了一行RANGE: bytes=2000070-这一行的意思就是告诉服务器down.zip这个文件从2000070字节开始传，前面的字节不用传了。服务器收到这个请求以后，返回的信息如下：206Content-Length=106786028Content-Range=bytes 2000070-106786027/106786028Date=Mon, 30 Apr 2001 12:55:20 GMTETag=W/02ca57e173c11:95bContent-Type=applicat

5、ion/octet-streamServer=Microsoft-IIS/5.0Last-Modified=Mon, 30 Apr 2001 12:55:20 GMT和前面服务器返回的信息比较一下，就会发现增加了一行：Content-Range=bytes 2000070-106786027/106786028返回的代码也改为206了，而不再是200了。206 Partial Content服务器已经成功处理了部分 GET 请求。类似于 FlashGet 或者迅雷这类的 HTTP下载工具都是使用此类响应实现断点续传或者将一个大文档分解为多个下载段同时下载。该请求必须包含 Range 头信息来指

6、示客户端希望得到的内容范围，并且可能包含 If-Range 来作为请求条件。响应必须包含如下的头部域：Content-Range 用以指示本次响应中返回的内容的范围；如果是 Content-Type 为 multipart/byteranges 的多段下载，则每一 multipart 段中都应包含 Content-Range 域用以指示本段的内容范围。假如响应中包含 Content-Length，那么它的数值必须匹配它返回的内容范围的真实字节数。DateETag 和/或 Content-Location，假如同样的请求本应该返回200响应。Expires, Cache-Control，和/或

7、Vary，假如其值可能与之前相同变量的其他响应对应的值不同的话。假如本响应请求使用了 If-Range 强缓存验证，那么本次响应不应该包含其他实体头；假如本响应的请求使用了 If-Range 弱缓存验证，那么本次响应禁止包含其他实体头；这避免了缓存的实体内容和更新了的实体头信息之间的不一致。否则，本响应就应当包含所有本应该返回200响 应中应当返回的所有实体头部域。假如 ETag 或 Last-Modified 头部不能精确匹配的话，则客户端缓存应禁止将206响应返回的内容与之前任何缓存过的内容组合在一起。任何不支持 Range 以及 Content-Range 头的缓存都禁止缓存206响应返

8、回的内容。知道了以上原理，就可以进行断点续传的编程了。(二)Java实现断点续传的关键几点 (1)用什么方法实现提交RANGE: bytes=2000070-。当然用最原始的Socket是肯定能完成的，不过那样太费事了，其实Java的net包中提供了这种功能。代码如下：URL url = new URL(HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection();/设置User-AgenthttpConnection.setRequestProperty(User-Agent,NetFox);/设置断点续

9、传的开始位置httpConnection.setRequestProperty(RANGE,bytes=2000070);/获得输入流InputStream input = httpConnection.getInputStream();从输入流中取出的字节流就是down.zip文件从2000070开始的字节流。大家看，其实断点续传用Java实现起来还是很简单的吧。接下来要做的事就是怎么保存获得的流到文件中去了。保存文件采用的方法。我采用的是IO包中的RandAccessFile类。操作相当简单，假设从2000070处开始保存文件，代码如下：RandomAccess oSavedFile =

10、new RandomAccessFile(down.zip,rw);long nPos = 2000070;/定位文件指针到nPos位置oSavedFile.seek(nPos);byte b = new byte1024;int nRead;/从输入流中读入字节流，然后写到文件中while(nRead=input.read(b,0,1024) 0)oSavedFile.write(b,0,nRead);怎么样，也很简单吧。接下来要做的就是整合成一个完整的程序了。包括一系列的线程控制等等。(三)断点续传内核的实现主要用了6个类，包括一个测试类。SiteFileFetch.java负责整个文件的

11、抓取，控制内部线程(FileSplitterFetch类)。FileSplitterFetch.java负责部分文件的抓取。FileAccess.java负责文件的存储。SiteInfoBean.java要抓取的文件的信息，如文件保存的目录，名字，抓取文件的URL等。Utility.java工具类，放一些简单的方法。TestMethod.java测试类。下面是源程序： /*SiteFileFetch.java*/package NetFox;import java.io.*;import .*;public class SiteFileFetch extends Thread SiteInfo

12、Bean siteInfoBean = null; /文件信息Beanlong nStartPos; /开始位置long nEndPos; /结束位置FileSplitterFetch fileSplitterFetch; /子线程对象long nFileLength; /文件长度boolean bFirst = true; /是否第一次取文件boolean bStop = false; /停止标志File tmpFile; /文件下载的临时信息DataOutputStream output; /输出到文件的输出流public SiteFileFetch(SiteInfoBean bean)

13、throws IOExceptionsiteInfoBean = bean;/tmpFile = File.createTempFile (zhong,1111,new File(bean.getSFilePath();tmpFile = new File(bean.getSFilePath()+File.separator + bean.getSFileName()+.info);if(tmpFile.exists ()bFirst = false;read_nPos();elsenStartPos = new longbean.getNSplitter();nEndPos = new lo

14、ngbean.getNSplitter();public void run()/获得文件长度/分割文件/实例FileSplitterFetch/启动FileSplitterFetch线程/等待子线程返回tryif(bFirst)nFileLength = getFileSize();if(nFileLength = -1)System.err.println(File Length is not known!);else if(nFileLength = -2)System.err.println(File is not access!);elsefor(int i=0;i<nStart

15、Pos.length;i+)nStartPosi = (long)(i*(nFileLength/nStartPos.length);for(int i=0;i<nEndPos.length-1;i+)nEndPosi = nStartPosi+1;nEndPosnEndPos.length-1 = nFileLength;/启动子线程fileSplitterFetch = new FileSplitterFetchnStartPos.length;for(int i=0;i<nStartPos.length;i+)fileSplitterFetchi = new FileSpli

16、tterFetch(siteInfoBean.getSSiteURL(),siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName(),nStartPosi,nEndPosi,i);Utility.log(Thread + i + , nStartPos = + nStartPosi + , nEndPos = + nEndPosi);fileSplitterFetchi.start();/ fileSplitterFetchnPos.length-1 = new FileSplitterFetch(sit

17、eInfoBean.getSSiteURL(),siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName(),nPosnPos.length-1,nFileLength,nPos.length-1);/ Utility.log(Thread + (nPos.length-1) + , nStartPos = + nPosnPos.length-1 + ,nEndPos = + nFileLength);/ fileSplitterFetchnPos.length-1.start();/等待子线程结束/int

18、 count = 0;/是否结束while循环boolean breakWhile = false;while(!bStop)write_nPos();Utility.sleep(500);breakWhile = true;for(int i=0;i<nStartPos.length;i+)if(!fileSplitterFetchi.bDownOver)breakWhile = false;break;if(breakWhile)break;/count+;/if(count>4)/ siteStop();System.err.println(文件下载结束！);catch(Ex

19、ception e)e.printStackTrace ();/获得文件长度public long getFileSize()int nFileLength = -1;tryURL url = new URL(siteInfoBean.getSSiteURL();HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();httpConnection.setRequestProperty(User-Agent,NetFox);int responseCode=httpConnection.getResp

20、onseCode();if(responseCode>=400)processErrorCode(responseCode);return -2; /-2 represent access is errorString sHeader;for(int i=1;i+)/DataInputStream in = new DataInputStream(httpConnection.getInputStream ();/Utility.log(in.readLine();sHeader=httpConnection.getHeaderFieldKey(i);if(sHeader!=null)i

21、f(sHeader.equals(Content-Length)nFileLength = Integer.parseInt(httpConnection.getHeaderField(sHeader);break;elsebreak;catch(IOException e)e.printStackTrace ();catch(Exception e)e.printStackTrace ();Utility.log(nFileLength);return nFileLength;/保存下载信息（文件指针位置）private void write_nPos()tryoutput = new Da

22、taOutputStream(new FileOutputStream(tmpFile);output.writeInt(nStartPos.length);for(int i=0;i<nStartPos.length;i+)/ output.writeLong(nPosi);output.writeLong(fileSplitterFetchi.nStartPos);output.writeLong(fileSplitterFetchi.nEndPos);output.close();catch(IOException e)e.printStackTrace ();catch(Exce

23、ption e)e.printStackTrace ();/读取保存的下载信息（文件指针位置）private void read_nPos()tryDataInputStream input = new DataInputStream(new FileInputStream(tmpFile);int nCount = input.readInt();nStartPos = new longnCount;nEndPos = new longnCount;for(int i=0;i<nStartPos.length;i+)nStartPosi = input.readLong();nEndP

24、osi = input.readLong();input.close();catch(IOException e)e.printStackTrace ();catch(Exception e)e.printStackTrace ();private void processErrorCode(int nErrorCode)System.err.println(Error Code : + nErrorCode);/停止文件下载public void siteStop()bStop = true;for(int i=0;i<nStartPos.length;i+)fileSplitterF

25、etchi.splitterStop();/*FileSplitterFetch.java*/package NetFox;import java.io.*;import .*;public class FileSplitterFetch extends Thread String sURL; /File URLlong nStartPos; /File Snippet Start Positionlong nEndPos; /File Snippet End Positionint nThreadID; /Threads IDboolean bDownOver = false; /Downi

26、ng is overboolean bStop = false; /Stop identicalFileAccessI fileAccessI = null; /File Access interfacepublic FileSplitterFetch(String sURL,String sName,long nStart,long nEnd,int id) throws IOExceptionthis.sURL = sURL;this.nStartPos = nStart;this.nEndPos = nEnd;nThreadID = id;fileAccessI = new FileAc

27、cessI(sName,nStartPos);public void run()while(nStartPos < nEndPos & !bStop)tryURL url = new URL(sURL);HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();httpConnection.setRequestProperty(User-Agent,NetFox);String sProperty = bytes=+nStartPos+-;httpConnection.setRequestPro

28、perty(RANGE,sProperty);Utility.log(sProperty);InputStream input = httpConnection.getInputStream();/logResponseHead(httpConnection);byte b = new byte1024;int nRead;while(nRead=input.read(b,0,1024) > 0 & nStartPos < nEndPos & !bStop)nStartPos += fileAccessI.write(b,0,nRead);/if(nThreadID = 1)/ U

29、tility.log(nStartPos = + nStartPos + , nEndPos = + nEndPos);Utility.log(Thread + nThreadID + is over!);bDownOver = true;/nPos = fileAccessI.write (b,0,nRead);catch(Exception e)e.printStackTrace ();/打印回应的头信息public void logResponseHead(HttpURLConnection con)for(int i=1;i+)String header=con.getHeaderFi

30、eldKey(i);if(header!=null)/responseHeaders.put(header,httpConnection.getHeaderField(header);Utility.log(header+ : +con.getHeaderField(header);elsebreak;public void splitterStop()bStop = true;/*FileAccess.java*/package NetFox;import java.io.*;public class FileAccessI implements SerializableRandomAcce

31、ssFile oSavedFile;long nPos;public FileAccessI() throws IOExceptionthis(,0);public FileAccessI(String sName,long nPos) throws IOExceptionoSavedFile = new RandomAccessFile(sName,rw);this.nPos = nPos;oSavedFile.seek(nPos);public synchronized int write(byte b,int nStart,int nLen)int n = -1;tryoSavedFil

32、e.write(b,nStart,nLen);n = nLen;catch(IOException e)e.printStackTrace ();return n;/*SiteInfoBean.java*/package NetFox;public class SiteInfoBean private String sSiteURL; /Sites URLprivate String sFilePath; /Saved Files Pathprivate String sFileName; /Saved Files Nameprivate int nSplitter; /Count of Sp

33、lited Downloading Filepublic SiteInfoBean()/default value of nSplitter is 5this(,5);public SiteInfoBean(String sURL,String sPath,String sName,int nSpiltter)sSiteURL= sURL;sFilePath = sPath;sFileName = sName;this.nSplitter = nSpiltter;public String getSSiteURL()return sSiteURL;public void setSSiteURL

34、(String value)sSiteURL = value;public String getSFilePath()return sFilePath;public void setSFilePath(String value)sFilePath = value;public String getSFileName()return sFileName;public void setSFileName(String value)sFileName = value;public int getNSplitter()return nSplitter;public void setNSplitter(

35、int nCount)nSplitter = nCount;/*Utility.java*/package NetFox;public class Utility public Utility()public static void sleep(int nSecond)tryThread.sleep(nSecond);catch(Exception e)e.printStackTrace ();public static void log(String sMsg)System.err.println(sMsg);public static void log(int sMsg)System.er

36、r.println(sMsg);/*TestMethod.java*/package NetFox;public class TestMethod public TestMethod() /xx/weblogic60b2_win.exetrySiteInfoBean bean = new SiteInfoBean(http:/localhost/xx/weblogic60b2_win.exe,L:temp,weblogic60b2_win.exe,5);/SiteInfoBean bean = new SiteInfoBean(http:/localhost:8080/down.zip,L:temp,weblogic60b2_win.exe,5);SiteFileFetch fileFetch = new SiteFileFetch(bean);fileFetch.start();catch(Exception e)e.printStackTrace ();public static void main(String args)new TestMethod();在线代理|网页代理|代理网页| 减肥药排行榜|淘宝最好的减肥药|什么减肥药效果最好|减肥瘦身药|