JAVA基础：java的http断点续传原理(二)

会计考友 · 发表于 2012-8-4 12:37:27

　　//获得文件长度
　　public long getFileSize()
　　{
　　int nFileLength = -1;
　　try{
　　URL url = new URL(siteInfoBean.getSSiteURL());
　　HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
　　httpConnection.setRequestProperty("User-Agent","NetFox");
　　int responseCode=httpConnection.getResponseCode();
　　if(responseCode>=400)
　　{
　　processErrorCode(responseCode);
　　return -2; //-2 represent access is error
　　}
　　String sHeader;
　　for(int i=1;;i++)
　　{
　　//DataInputStream in = new DataInputStream(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;
　　}

　　}

会计考友 · 发表于 2012-8-4 12:37:28

catch(IOException e){e.printStackTrace ();}
　　catch(Exception e){e.printStackTrace ();}
　　Utility.log(nFileLength);
　　return nFileLength;
　　}
　　//保存下载信息（文件指针位置）
　　private void write_nPos()
　　{
　　try{
　　output = new DataOutputStream(new FileOutputStream(tmpFile));
　　output.writeInt(nStartPos.length);

　　for(int i=0;i

会计考友 · 发表于 2012-8-4 12:37:29

nStartPos = input.readLong();
( D1 g; i1 o* F1 ?& l+ E2 F　　nEndPos = input.readLong();/ Z! K4 Y: W! X+ w* z
　　}
; k2 e! N" h2 N& J3 ?' d　　input.close();
) c7 N9 C& E! k" U; ~　　}
% v" j5 N1 @6 w1 i　　catch(IOException e){e.printStackTrace ();}) ?5 s9 Z; z/ ^1 q: ?$ B9 c& s
　　catch(Exception e){e.printStackTrace ();}: M' `! Z2 G+ J" K7 G
　　} C/ ] ~0 E7 P1 y" p$ i, l" W
　　private void processErrorCode(int nErrorCode)- B8 S( }' {7 x8 u, {$ Y; a
　　{
* j/ k- g; @$ t) _　　System.err.println("Error Code : " + nErrorCode);
: c! d. }1 M7 {' g　　}# _2 {8 r) X0 T S9 E7 l+ ?5 w' Z
　　//停止文件下载0 R5 R3 i2 E3 Z) z+ R2 C
　　public void siteStop()% |4 w* u h, Y
　　{8 J% a( h6 c8 {2 o: `3 H/ D
　　bStop = true;
$ R! b5 T% J$ Z3 L+ N6 V) U) O8 ]! m2 K
　　for(int i=0;i

会计考友 · 发表于 2012-8-4 12:37:30

boolean bDownOver = false; //Downing is over
　　boolean bStop = false; //Stop identical
　　FileAccessI fileAccessI = null; //File Access interface
　　public FileSplitterFetch(String sURL,String sName,long nStart,long nEnd,int id) throws IOException
　　{
　　this.sURL = sURL;
　　this.nStartPos = nStart;
　　this.nEndPos = nEnd;
　　nThreadID = id;
　　fileAccessI = new FileAccessI(sName,nStartPos);
　　}
　　public void run()
　　{
　　while(nStartPos < nEndPos && !bStop)
　　{
　　try{
　　URL url = new URL(sURL);
　　HttpURLConnection httpConnection = (HttpURLConnection)url.openConnection ();
　　httpConnection.setRequestProperty("User-Agent","NetFox");
　　String sProperty = "bytes="+nStartPos+"-";
　　httpConnection.setRequestProperty("RANGE",sProperty);
　　Utility.log(sProperty);
　　InputStream input = httpConnection.getInputStream();
　　//logResponseHead(httpConnection);
　　byte[] b = new byte[1024];
　　int nRead;

会计考友 · 发表于 2012-8-4 12:37:31

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 + " 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.getHeaderFieldKey(i);
　　if(header!=null)
　　//responseHeaders.put(header,httpConnection.getHeaderField(header));
　　Utility.log(header+" : "+con.getHeaderField(header));
　　else
　　break;
　　}
　　}
　　public void splitterStop()
　　{
　　bStop = true;
　　}
　　}

　　/*

会计考友 · 发表于 2012-8-4 12:37:32

**FileAccess.java
　　*/
　　package NetFox;
　　import java.io.*;
　　public class FileAccessI implements Serializable{
　　RandomAccessFile oSavedFile;
　　long nPos;
　　public FileAccessI() throws IOException
　　{
　　this("",0);
　　}
　　public FileAccessI(String sName,long nPos) throws IOException
　　{
　　oSavedFile = new RandomAccessFile(sName,"rw");
　　this.nPos = nPos;
　　oSavedFile.seek(nPos);
　　}
　　public synchronized int write(byte[] b,int nStart,int nLen)
　　{
　　int n = -1;
　　try{
　　oSavedFile.write(b,nStart,nLen);
　　n = nLen;
　　}
　　catch(IOException e)
　　{
　　e.printStackTrace ();
　　}
　　return n;
　　}
　　}
　　/*
　　**SiteInfoBean.java
　　*/
　　package NetFox;
　　public class SiteInfoBean {
　　private String sSiteURL; //Site's URL
　　private String sFilePath; //Saved File's Path
　　private String sFileName; //Saved File's Name
　　private int nSplitter; //Count of Splited Downloading File
　　public SiteInfoBean()

　　{

会计考友 · 发表于 2012-8-4 12:37:33

//default value of nSplitter is 5
　　this("","","",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(String value)
　　{
　　sSiteURL = value;
　　}
　　public String getSFilePath()
　　{
　　return sFilePath;
　　}
　　public void setSFilePath(String value)
　　{
　　sFilePath = value;
　　}
　　public String getSFileName()
　　{
　　return sFileName;
　　}

会计考友 · 发表于 2012-8-4 12:37:34

public void setSFileName(String value) 　　{
　　sFileName = value;
　　}
　　public int getNSplitter()
　　{
　　return nSplitter;
　　}
　　public void setNSplitter(int nCount)
　　{
　　nSplitter = nCount;
　　}
　　}
　　/*
　　**Utility.java
　　*/
　　package NetFox;
　　public class Utility {
　　public Utility()
　　{
　　}
　　public static void sleep(int nSecond)
　　{
　　try{
　　Thread.sleep(nSecond);
　　}
　　catch(Exception e)
　　{
　　e.printStackTrace ();
　　}

　　}

会计考友 · 发表于 2012-8-4 12:37:35

public static void log(String sMsg)
　　{
　　System.err.println(sMsg);
　　}
　　public static void log(int sMsg)
　　{
　　System.err.println(sMsg);
　　}
　　}
　　/*
　　**TestMethod.java
　　*/
　　package NetFox;
　　public class TestMethod {
　　public TestMethod()
　　{ ///xx/weblogic60b2_win.exe
　　try{
　　SiteInfoBean 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();
　　}
　　}

		自动登录	找回密码
密码			立即注册

[基础知识] JAVA基础：java的http断点续传原理(二)