url url = new url("http://www.jizhuomi.com/android/down.zip");  
httpurlconnection httpconnection = (httpurlconnection)url.openconnection();  
//設(shè)置user-agent  
httpconnection.setrequestproperty("user-agent","netfox");  
//設(shè)置斷點續(xù)傳的開始位置  
httpconnection.setrequestproperty("range","bytes=2000070");  
//獲得輸入流  
inputstream input = httpconnection.getinputstream(); 
    從輸入流中取出的字節(jié)流就是down.zip文件從2000070開始的字節(jié)流。

    大家看，其實斷點續(xù)傳用java實現(xiàn)起來還是很簡單的吧。

    接下來要做的事就是怎么保存獲得的流到文件中去了。

    保存文件采用的方法：我采用的是io包中的randaccessfile類。

    操作相當(dāng)簡單，假設(shè)從2000070處開始保存文件，代碼如下：

Java代碼
randomaccess osavedfile = new randomaccessfile("down.zip","rw");  
long npos = 2000070;  
//定位文件指針到npos位置  
osavedfile.seek(npos);  
byte[] b = new byte[1024];  
int nread;  
//從輸入流中讀入字節(jié)流，然后寫到文件中  
while((nread=input.read(b,0,1024)) > 0)  
{  
  osavedfile.write(b,0,nread);  
} 
    怎么樣，也很簡單吧。

    接下來要做的就是整合成一個完整的程序了。包括一系列的線程控制等等。

    三、斷點續(xù)傳內(nèi)核的實現(xiàn)

    主要用了6個類，包括一個測試類。

    sitefilefetch.java負(fù)責(zé)整個文件的抓取，控制內(nèi)部線程（filesplitterfetch類）。

    filesplitterfetch.java負(fù)責(zé)部分文件的抓取。

    fileaccess.java負(fù)責(zé)文件的存儲。

    siteinfobean.java要抓取的文件的信息，如文件保存的目錄，名字，抓取文件的url等。

    utility.java工具類，放一些簡單的方法。

    testmethod.java測試類。

    四、實例源碼

    下面是源程序：

Java代碼
/* 
**sitefilefetch.java 
*/ 
package netfox;  
import java.io.*;  
import java.net.*;  
  
public class sitefilefetch extends thread {  
  
siteinfobean siteinfobean = null; //文件信息bean  
long[] nstartpos; //開始位置  
long[] nendpos; //結(jié)束位置  
filesplitterfetch[] filesplitterfetch; //子線程對象  
long nfilelength; //文件長度  
boolean bfirst = true; //是否第一次取文件  
boolean bstop = false; //停止標(biāo)志  
file tmpfile; //文件下載的臨時信息  
dataoutputstream output; //輸出到文件的輸出流  
 
public sitefilefetch(siteinfobean bean) throws ioexception  
{  
siteinfobean = 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();  
}  
else 
{  
nstartpos = new long[bean.getnsplitter()];  
nendpos = new long[bean.getnsplitter()];  
}   
}  
  
public void run()  
{  
//獲得文件長度  
//分割文件  
//實例filesplitterfetch  
//啟動filesplitterfetch線程  
//等待子線程返回  
try{  
if(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!");  
}  
else 
{  
for(int i=0;i<nstartpos.length;i++)  
{  
nstartpos = (long)(i*(nfilelength/nstartpos.length));  
}  
for(int i=0;i<nendpos.length-1;i++)  
{  
nendpos = nstartpos[i+1];  
}  
nendpos[nendpos.length-1] = nfilelength;  
}  
}  
//啟動子線程  
filesplitterfetch = new filesplitterfetch[nstartpos.length];  
for(int i=0;i<nstartpos.length;i++)  
{  
filesplitterfetch = new filesplitterfetch(siteinfobean.getssiteurl(),  
siteinfobean.getsfilepath() + file.separator + siteinfobean.getsfilename(),  
nstartpos,nendpos,i);  
utility.log("thread " + i + " , nstartpos = " + nstartpos + ", nendpos = " + nendpos);  
filesplitterfetch.start();  
}  
// filesplitterfetch[npos.length-1] = new filesplitterfetch(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();  
 
//等待子線程結(jié)束  
//int count = 0;  
//是否結(jié)束while循環(huán)  
boolean breakwhile = false;  
  
while(!bstop)  
{  
write_npos();  
utility.sleep(500);  
breakwhile = true;  
  
for(int i=0;i<nstartpos.length;i++)  
{  
if(!filesplitterfetch.bdownover)  
{  
breakwhile = false;  
break;  
}  
}  
if(breakwhile)  
break;  
  
//count++;  
//if(count>4)  
// sitestop();  
}  
  
system.err.println("文件下載結(jié)束！");  
}  
catch(exception e){e.printstacktrace ();}  
}  
  
//獲得文件長度  
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<nstartpos.length;i++)  
{  
// output.writelong(npos);  
output.writelong(filesplitterfetch.nstartpos);  
output.writelong(filesplitterfetch.nendpos);  
}  
output.close();  
}  
catch(ioexception e){e.printstacktrace ();}  
catch(exception e){e.printstacktrace ();}  
}  
  
//讀取保存的下載信息（文件指針位置）  
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<nstartpos.length;i++)  
{  
nstartpos = input.readlong();  
nendpos = 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++)  
filesplitterfetch.splitterstop();  
}  
}  
/* 
**filesplitterfetch.java 
*/ 
package netfox;  
  
import java.io.*;  
import java.net.*;  
  
public class filesplitterfetch extends thread {  
  
string surl; //file url  
long nstartpos; //file snippet start position  
long nendpos; //file snippet end position  
int nthreadid; //threads id  
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;  
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 ();}  
}  
}  
  
//打印回應(yīng)的頭信息  
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; //sites url  
private string sfilepath; //saved files path  
private string sfilename; //saved files name  
private int nsplitter; //count of splited downloading file  
  
public siteinfobean()  
{  
//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;  
}  
  
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 ();  
}  
}  
  
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();  
}  
}