http斷點(diǎn)續(xù)傳簡(jiǎn)單實(shí)現(xiàn)

2019-11-18 12:09:03

字體：大中小

供稿：網(wǎng)友

　　 /*
　　**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; //子線程對(duì)象
　　long nFileLength; //文件長度
　　boolean bFirst = true; //是否第一次取文件
　　boolean bStop = false; //停止標(biāo)志
　　File tmpFile; //文件下載的臨時(shí)信息
　　DataOutputStream output; //輸出到文件的輸出流
　　
　　//負(fù)責(zé)整個(gè)文件的抓取，控制內(nèi)部線程（FileSplitterFetch類）
　　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()
　　{
　　//獲得文件長度
　　//分割文件
　　//實(shí)例FileSplitterFetch
　　//啟動(dòng)FileSplitterFetch線程
　　//等待子線程返回
　　try{
　　if(bFirst)
　　{
　　nFileLength = getFileSize();
　　if(nFileLength == -1)
　　{
　　System.err.　　}
　　else if(nFileLength == -2)
　　{
　　System.err.println("File is not access!");
　　}
　　else
　　{
　　for(int i=0;i<nStartPos.length;i++)
　　{
　　nStartPos[i] = (long)(i*(nFileLength/nStartPos.length));
　　}
　　for(int i=0;i<nEndPos.length-1;i++)
　　{
　　nEndPos[i] = nStartPos[i+1];
　　}
　　nEndPos[nEndPos.length-1] = nFileLength;
　　}
　　}
　　
　　
　　//啟動(dòng)子線程
　　fileSplitterFetch = new FileSplitterFetch[nStartPos.length];
　　for(int i=0;i<nStartPos.length;i++)
　　{
　　fileSplitterFetch[i] = new FileSplitterFetch(siteInfoBean.getSSiteURL(),
　　siteInfoBean.getSFilePath() + File.separator + siteInfoBean.getSFileName(),
　　nStartPos[i],nEndPos[i],i);
　　Utility.log("Thread " + i + " , nStartPos = " + nStartPos[i] + ", nEndPos = " + nEndPos[i]);
　　fileSplitterFetch[i].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[i].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[i]);
　　output.writeLong(fileSplitterFetch[i].nStartPos);
　　output.writeLong(fileSplitterFetch[i].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[i] = input.readLong();
　　nEndPos[i] = 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[i].splitterStop();
　　
　　
　　}
　　}
　　//負(fù)責(zé)部分文件的抓取
　　**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; //Thread's 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 += fileAcces

上一篇：Java程序的國際化和本地化介紹

下一篇：Java的測(cè)試規(guī)范