Android实现断点下载的方法

最近做的项目中需要实现断点下载，即用户一次下载可以分多次进行，下载过程可以中断，在目前大多数的带离线缓存的软件都是需要实现这一功能。本文阐述了通过sqlite3简单实现了一个具有断点下载功能的demo。言归正传，开始正文。
设计
数据库表存储元数据
DBHelper.java
用于业务存储的Dao
Dao.java
抽象下载信息的Bean
LoadInfo.java
呈现下载信息View
MainActivity.java
存储下载信息Bean
DownloadInfo.java
封装好的下载类
Downloader.java

代码结构

具体实现
下载信息类：DownloadInfo.java
这里的代码很简单，就是一个用来保存下载信息的类，很简单，没啥好说的，具体看注释

package entity;public class DownloadInfo {private int threadId;//线程IDprivate int startPos;//下载起始位置private int endPos;//下载结束位置private int completeSize;//下载完成量private String url;//资源URLpublic DownloadInfo（int tId,int sp, int ep,int cSize,String address）{threadId=tId;startPos=sp;endPos=ep;completeSize = cSize;url=address;}/** * @return the threadId */public int getThreadId（） {return threadId;}/** * @param threadId the threadId to set */public void setThreadId（int threadId） {this.threadId = threadId;}/** * @return the startPos */public int getStartPos（） {return startPos;}/** * @param startPos the startPos to set */public void setStartPos（int startPos） {this.startPos = startPos;}/** * @return the endPos */public int getEndPos（） {return endPos;}/** * @param endPos the endPos to set */public void setEndPos（int endPos） {this.endPos = endPos;}/** * @return the completeSize */public int getCompleteSize（） {return completeSize;}/** * @param completeSize the completeSize to set */public void setCompleteSize（int completeSize） {this.completeSize = completeSize;}/** * @return the url */public String getUrl（） {return url;}/** * @param url the url to set */public void setUrl（String url） {this.url = url;}@Overridepublic String toString（） {// TODO Auto-generated method stubreturn "threadId:"+threadId+",startPos:"+startPos+",endPos："+endPos+",completeSize:"+completeSize+",url:"+url;}}

数据库 DBHelper.java

package db;import android.content.Context;import android.database.sqlite.SQLiteDatabase;import android.database.sqlite.SQLiteOpenHelper;public class DBHelper extends SQLiteOpenHelper {String sql ="create table download_info （id integer PRIMARY KEY AUTOINCREMENT,"+ "thread_id integer,"+ "start_pos integer,"+ "end_pos integer,"+ "complete_size integer,"+ "url char）";public DBHelper（Context context） {// TODO Auto-generated constructor stubsuper（context, "download.db", null, 1）;}@Overridepublic void onCreate（SQLiteDatabase db） {// TODO Auto-generated method stubdb.execSQL（sql）;}@Overridepublic void onUpgrade（SQLiteDatabase db, int oldVersion, int newVersion） {// TODO Auto-generated method stub}}

数据库业务管理类 Dao.java

package db;import java.util.ArrayList;import java.util.List;import android.content.Context;import android.database.Cursor;import android.database.sqlite.SQLiteDatabase;import entity.DownloadInfo;public class Dao {private DBHelper dbHelper;public Dao（Context context）{dbHelper = new DBHelper（context）;}public boolean isNewTask（String url）{SQLiteDatabase db = dbHelper.getReadableDatabase（）;String sql = "select count（*） from download_info where url=?";Cursor cursor = db.rawQuery（sql, new String[]{url}）;cursor.moveToFirst（）;int count = cursor.getInt（0）;cursor.close（）;return count == 0;}public void saveInfo（List<DownloadInfo> infos）{SQLiteDatabase db = dbHelper.getWritableDatabase（）;String sql = "insert into download_info（thread_id,start_pos,end_pos,complete_size,url） values（?,?,?,?,?）";Object[] bindArgs= null;for（DownloadInfo info:infos）{bindArgs=new Object[]{info.getThreadId（）,info.getStartPos（）,info.getEndPos（）,info.getCompleteSize（）,info.getUrl（）};db.execSQL（sql, bindArgs）;}}public List<DownloadInfo> getInfo（String url）{SQLiteDatabase db = dbHelper.getReadableDatabase（）;List<DownloadInfo> infos = new ArrayList<DownloadInfo>（）;String sql ="select thread_id,start_pos,end_pos,complete_size,url from download_info where url=?";Cursor cursor=db.rawQuery（sql, new String[]{url}）;while（cursor.moveToNext（））{DownloadInfo info = new DownloadInfo（cursor.getInt（0）, cursor.getInt（1）, cursor.getInt（2）, cursor.getInt（3）,cursor.getString（4））;infos.add（info）;}cursor.close（）;return infos;}public void deleteInfo（String url）{SQLiteDatabase db = dbHelper.getWritableDatabase（）;db.delete（"download_info", "url=?", new String[]{url}）;db.close（）;}public void updateInfo（int completeSize,int threadId,String url）{SQLiteDatabase db = dbHelper.getWritableDatabase（）;String sql ="update download_info set complete_size=? where thread_id=? and url=?";db.execSQL（sql, new Object[]{completeSize,threadId,url}）;}public void closeDB（）{dbHelper.close（）;}}

当前状态保存类 LoadInfo.java

package entity;public class LoadInfo {private int fileSize;private int completeSize;private String url;public LoadInfo（int fs,int cSize,String address）{fileSize=fs;completeSize = cSize;url=address;}/** * @return the fileSize */public int getFileSize（） {return fileSize;}/** * @param fileSize the fileSize to set */public void setFileSize（int fileSize） {this.fileSize = fileSize;}/** * @return the completeSize */public int getCompleteSize（） {return completeSize;}/** * @param completeSize the completeSize to set */public void setCompleteSize（int completeSize） {this.completeSize = completeSize;}/** * @return the url */public String getUrl（） {return url;}/** * @param url the url to set */public void setUrl（String url） {this.url = url;}}

下载助手类：Downloader.java

package com.winton.downloadmanager;import java.io.File;import java.io.IOException;import java.io.InputStream;import java.io.RandomAccessFile;import java.net.HttpURLConnection;import java.net.MalformedURLException;import java.net.URL;import java.util.ArrayList;import java.util.List;import android.content.Context;import android.os.Handler;import android.os.Message;import db.Dao;import entity.DownloadInfo;import entity.LoadInfo;public class Downloader {private String url;private String localPath;private int threadCount;private Handler mHanler;private Dao dao;private int fileSize;private List<DownloadInfo> infos;private final static int INIT = 1;private final static int DOWNLOADING =2;private final static int PAUSE =3;private int state = INIT;public Downloader（String address,String lPath,int thCount,Context context,Handler handler）{url =address;localPath = lPath;threadCount = thCount;mHanler = handler;dao = new Dao（context）;}public boolean isDownloading（）{return state == DOWNLOADING;}public LoadInfo getDownLoadInfos（）{if（isFirstDownload（url））{init（）;int range = fileSize/threadCount;infos = new ArrayList<DownloadInfo>（）;for（int i=0;i<=threadCount-1;i++）{DownloadInfo info = new DownloadInfo（i, i*range, （i+1）*range-1, 0, url）;infos.add（info）;}dao.saveInfo（infos）;return new LoadInfo（fileSize, 0, url）;}else{infos = dao.getInfo（url）;int size = 0;int completeSize =0;for（DownloadInfo info:infos）{completeSize += info.getCompleteSize（）;size += info.getEndPos（）-info.getStartPos（）+1;}return new LoadInfo（size, completeSize, url）;}}public boolean isFirstDownload（String url）{return dao.isNewTask（url）;}public void init（）{try {URL mUrl = new URL（this.url）;HttpURLConnection connection = （HttpURLConnection）mUrl.openConnection（）;connection.setConnectTimeout（5000）;connection.setRequestMethod（"GET"）;fileSize = connection.getContentLength（）;File file = new File（localPath）;if（！file.exists（））{file.createNewFile（）;}RandomAccessFile accessFile = new RandomAccessFile（file, "rwd"）;accessFile.setLength（fileSize）;accessFile.close（）;connection.disconnect（）;} catch （MalformedURLException e） {// TODO Auto-generated catch blocke.printStackTrace（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;} }public void download（）{if（infos ！= null）{if（state ==DOWNLOADING）{return;}state = DOWNLOADING;for（DownloadInfo info:infos）{new DownloadThread（info.getThreadId（）, info.getStartPos（）, info.getEndPos（）, info.getCompleteSize（）, info.getUrl（））.start（）;}}}class DownloadThread extends Thread{private int threadId;private int startPos;private int endPos;private int completeSize;private String url;public DownloadThread（int tId,int sp,int ep,int cSize,String address） {// TODO Auto-generated constructor stubthreadId=tId;startPos=sp;endPos = ep;completeSize = cSize;url = address;}@Overridepublic void run（） {// TODO Auto-generated method stubHttpURLConnection connection = null;RandomAccessFile randomAccessFile = null;InputStream is = null;try {URL mUrl = new URL（url）;connection = （HttpURLConnection）mUrl.openConnection（）;connection.setConnectTimeout（5000）;connection.setRequestMethod（"GET"）;connection.setRequestProperty（"Range", "bytes="+（startPos+completeSize）+"-"+endPos）;randomAccessFile = new RandomAccessFile（localPath, "rwd"）;randomAccessFile.seek（startPos+completeSize）;is=connection.getInputStream（）;byte[] buffer = new byte[4096];int length =-1;while（（length=is.read（buffer）） ！= -1）{randomAccessFile.write（buffer, 0, length）;completeSize +=length;dao.updateInfo（threadId, completeSize, url）;Message msg = Message.obtain（）;msg.what=1;msg.obj=url;msg.arg1=length;mHanler.sendMessage（msg）;if（state==PAUSE）{return;}}} catch （MalformedURLException e） {// TODO Auto-generated catch blocke.printStackTrace（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;}finally{try {is.close（）;randomAccessFile.close（）;connection.disconnect（）;dao.closeDB（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;}}}}public void delete（String url）{dao.deleteInfo（url）;}public void reset（）{state=INIT;}public void pause（）{state=PAUSE;}}

View呈现类：MainActivity.java

package com.winton.downloadmanager;import android.app.Activity;import android.os.Bundle;import android.os.Environment;import android.os.Handler;import android.os.Message;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import android.widget.ProgressBar;import android.widget.TextView;import android.widget.Toast;import entity.LoadInfo;public class MainActivity extends Activity implements OnClickListener{private TextView name;private ProgressBar process;private Button start,stop;private Downloader downloader;//处理下载进度UI的Handler handler = new Handler（）{public void handleMessage（android.os.Message msg） {if（msg.what==1）{name.setText（（String）msg.obj）;int lenght = msg.arg1;process.incrementProgressBy（lenght）;}if（msg.what==2）{int max =msg.arg1;process.setMax（max）;Toast.makeText（getApplicationContext（）, max+"", 1）.show（）;}};};@Overrideprotected void onCreate（Bundle savedInstanceState） {super.onCreate（savedInstanceState）;setContentView（R.layout.activity_main）;name=（TextView）findViewById（R.id.tv_name）;process=（ProgressBar）findViewById（R.id.pb_download）;start = （Button）findViewById（R.id.bt_start）;stop = （Button）findViewById（R.id.bt_stop）;start.setOnClickListener（this）;stop.setOnClickListener（this）;downloader=new Downloader（"http://img4.duitang.com/uploads/item/201206/11/20120611174542_5KRMj.jpeg", Environment.getExternalStorageDirectory（）.getPath（）+"/test1.jpg", 1, getApplicationContext（）, handler）;}@Overridepublic void onClick（View v） {// TODO Auto-generated method stubif（v==start）{new Thread（new Runnable（） {@Overridepublic void run（） {// TODO Auto-generated method stubLoadInfo loadInfo = downloader.getDownLoadInfos（）;Message msg =handler.obtainMessage（）;msg.what=2;msg.arg1=loadInfo.getFileSize（）;handler.sendMessage（msg）;downloader.download（）;}}）.start（）;return;}if（v==stop）{downloader.pause（）;return;}}}

运行效果

总体比较简单，基本实现了断点下载的功能，而且开启了多个线程去实现分块下载，对初学的同学有一定的帮助。
这些代码我也是从网上各种搜集而来，自己亲自动手敲了一遍，并做了一些小的改动，对整个断点下载的过程有了一个深刻的认识。因此平时要多敲代码，善于总结，必能有所收获。