/**?* 下載器類(lèi)?* 變量包括文件大小，開(kāi)啟線程數(shù)，下載地址，保存路徑，保存下載信息的信息類(lèi)和保存下載器信息的類(lèi)?* @author Administrator?*?*/public class Downloader implements OndownloadCallBack{ /** * 定義下載地址，文件總大小，線程數(shù)（可以進(jìn)行分組按比例開(kāi)啟），存儲(chǔ)地址， * 還要有一個(gè)context用來(lái)向數(shù)據(jù)庫(kù)存儲(chǔ)數(shù)據(jù)信息時(shí)用到，可以使用Application，不用傳 */ private String urlstr; //文件大小 private int filesize; //本地存放路徑 private String localfile; private int threadcount; //每個(gè)線程下載器所下載的信息集合 private List<DownloadInfo> dinfos; private DownloadDataDB downDB; //定義下載狀態(tài) init(初始狀態(tài)),downloading(正在下載),pause(暫停); private static final int INIT_STATE=0; private static final int DOWNLOADING_STATE=1; private static final int PAUSE_STATE=2; private int state=INIT_STATE; public Downloader(String urlstr, String localfile) { this.urlstr = urlstr; this.localfile = localfile; downDB=DownloadDataDB.getInstance(); } /** * 從數(shù)據(jù)庫(kù)讀取是否為空判斷是否是第一次 * @return */ private boolean isFirstDownload(){ List<DownloadInfo> list=DownloadDataDB.getInstance().getInfo(urlstr); if(list!=null&&!list.isEmpty()){ return false; } return true; } /** * 獲取下載的信息并將信息保存（包括線程） * 首先判斷是不是第一次下載，不是的話先從數(shù)據(jù)庫(kù)讀取數(shù)據(jù) */ public LoadDownloaderInfo getDownloadInfo(){ if(isFirstDownload()){ init(); Log.d("--filesize", filesize+"");//注此處日志為0 int result=filesize/Costant.THREAD_READ; Log.d("---->result", result+""); int re=filesize%Costant.THREAD_READ; if(re==0){ threadcount=4; }else{ threadcount=4; } int range=filesize/threadcount; dinfos=new ArrayList<DownloadInfo>(); for(int i=0;i<threadcount-1;i++){ DownloadInfo info=new DownloadInfo(1000+i, i*range, (i+1)*range-1, 0, urlstr); dinfos.add(info); } dinfos.add(new DownloadInfo(1000+(threadcount-1), (threadcount-1)*range, filesize, 0, urlstr)); downDB.saveData(dinfos); //一個(gè)文件存儲(chǔ)進(jìn)一個(gè)下載管理器來(lái)管理包含的所有線程和完成度 LoadDownloaderInfo loadinfo=new LoadDownloaderInfo(urlstr, filesize, 0); return loadinfo; }else{ dinfos=downDB.getInfo(urlstr); int size=0; int complete=0; for(DownloadInfo dinfo:dinfos){ complete+=dinfo.getCompletedSize(); size+=dinfo.getEndpos()-dinfo.getStartpos()+1; } return new LoadDownloaderInfo(urlstr, size, complete); } } private void init() { HttpUtils.requestDownloadMessage(0, urlstr, 0, 0, localfile,this); } public void download(){ if(dinfos!=null){ if(state==DOWNLOADING_STATE){ return; } for(DownloadInfo dinfo:dinfos){ HttpUtils.requestDownloadMessage(dinfo.getThreadinfo(), dinfo.getUrl(), dinfo.getStartpos()+dinfo.getCompletedSize(), dinfo.getEndpos(), localfile, this); } } } @Override public void getFileSize(int fileSize) { this.filesize=fileSize; Log.d("--filesize--before", filesize+"");//此處有值 } @Override public void getResponse(String url, int completedSize, int len, int threadid) { // TODO Auto-generated method stub } @Override public void getString(String str) { // TODO Auto-generated method stub }}