java断点续传下载原神4.0版本

package javaFTPsocket; import java.io.*; import java.net.*; public class SiteFileFetch extends Thread{ SiteInfoBean siteInfoBean=null; long[] nStartPos; long[] nEndPos; FileSplitterFetch[] fileSplitterFetch; long nFileLength; boolean bFirst=true; boolean bStop=false; File tmpFile; DataOutputStream output; public SiteFileFetch(SiteInfoBean bean) throws IOException{ siteInfoBean=bean; tmpFile=new File(bean.getsFilePath()+File.separator+bean.getsFildName()+".info"); if(tmpFile.exists()){ bFirst=false; read_nPos(); }else { nStartPos=new long[bean.getnSplitter()]; nEndPos=new long[bean.getnSplitter()]; } } public void run(){ 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[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; } } fileSplitterFetch=new FileSplitterFetch[nStartPos.length]; for (int i=0;i<nStartPos.length;i++){ fileSplitterFetch[i]=new FileSplitterFetch(siteInfoBean.getsSiteURL(),siteInfoBean.getsFilePath()+File.separator+siteInfoBean.getsFildName(),nStartPos[i],nEndPos[i],i); Utility.log("Thread"+i+",nStartPos="+nStartPos[i]+",nEndPos="+nEndPos[i]); fileSplitterFetch[i].start(); } 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; } System.err.println("文件下载结束！"); }catch (Exception e){ e.printStackTrace(); } } public long getFileSize() { int nFileLength=-1; try{ URL url=new URL(siteInfoBean.getsSiteURL()); HttpURLConnection httpURLConnection=(HttpURLConnection) url.openConnection(); httpURLConnection.setRequestProperty("User-Agent","NetFox"); int responseCode=httpURLConnection.getResponseCode(); if(responseCode>=400){ processErroorCode(responseCode); return -2; } String sHeader; for(int i=1;;i++){ sHeader=httpURLConnection.getHeaderFieldKey(i); if(sHeader!=null){ if(sHeader.equals("Content-Length")){ nFileLength=Integer.parseInt(httpURLConnection.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(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 processErroorCode(int nErrorCode){ System.err.println("Error Code:"+nErrorCode); } public void siteStop(){ bStop=true; for (int i=0;i<nStartPos.length;i++) fileSplitterFetch[i].splitterStop(); } }