java的http断点续传原理（2）

会计考友 · 发表于 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;
　　}
　　}
　　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:28

　//读取保存的下载信息（文件指针位置）</p>　　private void read_nPos()
　　{
　　try{
　　DataInputStream input = new DataInputStream(new FileInputStream(tmpFile));
　　int nCount = input.readInt();
　　nStartPos = new long[nCount];
　　nEndPos = new long[nCount];

　　for(int i=0;i

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

nStartPos += fileAccessI.write(b,0,nRead);</p>　　//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;
　　}
　　}
　　/*
　　**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:30

//default value of nSplitter is 5</p>　　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;
　　}
　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);
　　}

　　

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

catch(Exception e)</p>　　{
　　e.printStackTrace ();
　　}
　　}
　　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的http断点续传原理（2）