怎么在Android中实现一个多线程断点续传下载功能

android 2023-05-30 18:05:17 427人浏览安东尼

摘要

本篇文章给大家分享的是有关怎么在Android中实现一个多线程断点续传下载功能，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。1、布局实现具体布局内容如下：<LinearL

本篇文章给大家分享的是有关怎么在Android中实现一个多线程断点续传下载功能，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

1、布局实现

具体布局内容如下：

<LinearLayout xmlns:android="Http://schemas.android.com/apk/res/android"  xmlns:tools="http://schemas.android.com/tools"  android:layout_width="match_parent"  android:layout_height="match_parent"  android:paddingBottom="@dimen/activity_vertical_margin"  android:paddingLeft="@dimen/activity_horizontal_margin"  android:paddingRight="@dimen/activity_horizontal_margin"  android:paddingTop="@dimen/activity_vertical_margin"  android:orientation="vertical"  tools:context=".MainActivity" >   <TextView  android:layout_width="match_parent"  android:layout_height="wrap_content"  android:text="下载路径" />   <EditText  android:id="@+id/ed_path"  android:layout_width="match_parent"  android:layout_height="wrap_content"  android:text="http://192.168.0.170:8080/WEB/youdao.exe"/>  <Button  android:layout_width="wrap_content"  android:layout_height="wrap_content"  android:text="下载"  android:onClick="download"/>   <ProgressBar  android:id="@+id/pb"  android:layout_width="match_parent"  android:layout_height="wrap_content"  />   <TextView  android:id="@+id/tv_info"  android:layout_width="match_parent"  android:layout_height="wrap_content"  android:gravity="center"  android:text="下载:0%"/>  </LinearLayout>

2、自定义ProgressBarListener监听器接口

新建自定义ProgressBarListener监听器接口，这个接口中定义两个方法，void getMax(int length)用来获取下载文件的长度，void getDownload(int length);用来获取每次下载的长度，这个方法中主要是在多线程中调用，子线程中获取到的数据传递到这两个接口方法中，然后在这两个接口方法中通过Handler将相应的长度信息传递到主线程，更新界面显示信息。

具体代码实现如下：

package com.example.inter;   public interface ProgressBarListener {    void getMax(int length);    void getDownload(int length); }

3.定义数据库的相关信息类DownloadDBHelper

在这个实例中，我们将数据库的名称定义为download.db,我们需要保存主键id,文件下载后要保存的路径，每个线程的标识id，每个线程下载的文件数据块大小，所以，在创建的数据表中共有_id, path，threadid，downloadlength，详情见下图

怎么在Android中实现一个多线程断点续传下载功能

DownloadDBHelper实现的具体代码如下：

package com.example.db;  import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteDatabase.CursorFactory; import android.database.sqlite.SQLiteOpenHelper;   public class DownloadDBHelper extends SQLiteOpenHelper {    private static final String NAME = "download.db";    public DownloadDBHelper(Context context, String name,  CursorFactory factory, int version) {  super(context, name, factory, version);  }    public DownloadDBHelper(Context context){  super(context, NAME, null, 1);  }     @Override  public void onCreate(SQLiteDatabase db) {  db.execSQL("create table download(_id integer primary key autoincrement," +   "path text," +   "threadid integer," +   "downloadlength integer)");   }    @Override  public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {   }  }

4、创建DownloadProvider类

DownloadProvider类继承自ContentProvider，提供操作数据库的方法，在这个类中，通过UriMatcher类匹配要操作的数据库，通过DownloadDBHelper对象来得到一个具体数据库实例，来对相应的数据库进行增、删、改、查操作。
具体实现如下代码所示：

package com.example.provider;  import com.example.db.DownloadDBHelper;  import android.content.ContentProvider; import android.content.ContentValues; import android.content.UriMatcher; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteOpenHelper; import android.net.Uri;   public class DownloadProvider extends ContentProvider {  //实例化UriMatcher对象  private static UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);  //配置访问规则  private static final String AUTHORITY = "download";  //自定义常量  private static final int DOWANLOAD = 10;  static{  //添加匹配的规则  matcher.addURI(AUTHORITY, "download", DOWANLOAD);  }  private SQLiteOpenHelper mOpenHelper;  @Override  public boolean onCreate() {  mOpenHelper = new DownloadDBHelper(getContext());  return false;  }   @Override  public Cursor query(Uri uri, String[] projection, String selection,  String[] selectionArgs, String sortOrder) {  // TODO Auto-generated method stub  Cursor ret = null;  SQLiteDatabase db = mOpenHelper.getReadableDatabase();  int code = matcher.match(uri);  switch (code) {  case DOWANLOAD:  ret = db.query("download", projection, selection, selectionArgs, null, null, sortOrder);  break;   default:  break;  }  return ret;  }   @Override  public String getType(Uri uri) {  // TODO Auto-generated method stub  return null;  }   @Override  public Uri insert(Uri uri, ContentValues values) {  // TODO Auto-generated method stub  SQLiteDatabase db = mOpenHelper.getWritableDatabase();  int code = matcher.match(uri);  switch (code) {  case DOWANLOAD:  db.insert("download", "_id", values);  break;   default:  break;  }  return null;  }   @Override  public int delete(Uri uri, String selection, String[] selectionArgs) {  SQLiteDatabase db = mOpenHelper.getWritableDatabase();  int code = matcher.match(uri);  switch (code) {  case DOWANLOAD:  db.delete("download", selection, selectionArgs);  break;   default:  break;  }  return 0;  }   @Override  public int update(Uri uri, ContentValues values, String selection,  String[] selectionArgs) {  SQLiteDatabase db = mOpenHelper.getWritableDatabase();  int code = matcher.match(uri);  switch (code) {  case DOWANLOAD:  db.update("download", values, selection, selectionArgs);  break;   default:  break;  }  return 0;  }  }

5、创建DownloadInfo实体类

为了使程序更加面向对象化，这里我们建立DownloadInfo实体类来对数据库中的数据进行封装，DownloadInfo实体类中的数据字段与数据库中的字段相对应
具体实现代码如下：

package com.example.domain;   public class DownloadInfo {  //主键id  private int _id;  //保存路径  private String path;  //线程的标识id  private String threadId;  //下载文件的大小  private int downloadSize;   public DownloadInfo() {  super();  }   public DownloadInfo(int _id, String path, String threadId, int downloadSize) {  super();  this._id = _id;  this.path = path;  this.threadId = threadId;  this.downloadSize = downloadSize;  }   public int get_id() {  return _id;  }  public void set_id(int _id) {  this._id = _id;  }  public String getPath() {  return path;  }  public void setPath(String path) {  this.path = path;  }  public String getThreadId() {  return threadId;  }  public void setThreadId(String threadId) {  this.threadId = threadId;  }  public int getDownloadSize() {  return downloadSize;  }  public void setDownloadSize(int downloadSize) {  this.downloadSize = downloadSize;  } }

6、定义外界调用的操作数据库的方法类DownloadDao

DownloadDao类中封装了一系列操作数据库的方法，这个类不是直接操作数据库对象，而是通过ContentResolver这个对象来调用DownloadProvider中的方法来实现操作数据库的功能，这里用到了ContentResolver与ContentProvider这两个Android中非常重要的类。ContentProvider即内容提供者，主要是向外提供数据，简单理解就是一个应用程序可以通过ContentProvider向外提供操作本应用程序的接口，其他应用程序可以调用ContentProvider提供的接口来操作本应用程序的数据。ContentResolver内容接接收者，它可以接收ContentProvider的向外提供的数据。
具体代码实现如下：

package com.example.dao;  import android.content.ContentResolver; import android.content.ContentValues; import android.content.Context; import android.database.Cursor; import android.net.Uri;  import com.example.domain.DownloadInfo;   public class DownloadDao {     private ContentResolver cr;   public DownloadDao(Context context){  this.cr = context.getContentResolver();  }    public void save(DownloadInfo info){  Uri uri = Uri.parse("content://download/download");  ContentValues values = new ContentValues();  values.put("path", info.getPath());  values.put("threadid", info.getThreadId());  cr.insert(uri, values);  }     public void update(DownloadInfo info){  Uri uri = Uri.parse("content://download/download");  ContentValues values = new ContentValues();  values.put("downloadlength", info.getDownloadSize());  values.put("threadid", info.getThreadId());  cr.update(uri, values, " path = ? and threadid = ? ", new String[]{info.getPath(), info.getThreadId()});  }    public void delete(DownloadInfo info){  Uri uri = Uri.parse("content://download/download");  cr.delete(uri, " path = ? and threadid = ? ", new String[]{info.getPath(), info.getThreadId()});  }    public void delete(String path){  Uri uri = Uri.parse("content://download/download");  cr.delete(uri, " path = ? ", new String[]{path});  }     public boolean isExist(String path){  boolean result = false;  Uri uri = Uri.parse("content://download/download");  Cursor cursor = cr.query(uri, null, " path = ? ", new String[]{path}, null);  if(cursor.moveToNext()){  result = true;  }  cursor.close();  return result;  }     public int queryCount(String path){  int count = 0;  Uri uri = Uri.parse("content://download/download");  Cursor cursor = cr.query(uri, new String[]{"downloadlength"}, " path = ? ", new String[]{path}, null);  while(cursor.moveToNext()){  int len = cursor.getInt(0);  count += len;  }  cursor.close();  return count;  }    public int query(DownloadInfo info){  int count = 0;  Uri uri = Uri.parse("content://download/download");  Cursor cursor = cr.query(uri, new String[]{"downloadlength"}, " path = ? and threadid = ?", new String[]{info.getPath(), info.getThreadId()}, null);  while(cursor.moveToNext()){  int len = cursor.getInt(0);  count += len;  }  cursor.close();  return count;  } }

7、自定义线程类DownThread

这里通过继承Thread的方式来实现自定义线程操作，在这个类中主要是实现文件的下载操作，在这个类中，定义了一系列与下载有关的实例变量来控制下载的数据，通过自定义监听器ProgressBarListener中的void getDownload(int length)方法来跟新界面显示的进度信息，同时通过调用DownloadDao的方法来记录和更新数据的下载信息。
具体实现代码如下：

package com.example.download;  import java.io.File; import java.io.InputStream; import java.io.RandoMaccessFile; import java.net.HttpURLConnection; import java.net.URL;  import android.content.Context;  import com.example.dao.DownloadDao; import com.example.domain.DownloadInfo; import com.example.inter.ProgressBarListener;   public class DownloadThread extends Thread {  //下载的线程id  private int threadId;  //下载的文件路径  private String path;  //保存的文件  private File file;  //下载的进度条更新的监听器  private ProgressBarListener listener;  //每条线程下载的数据量  private int block;  //下载的开始位置  private int startPosition;  //下载的结束位置  private int endPosition;   private DownloadDao downloadDao;   public DownloadThread(int threadId, String path, File file, ProgressBarListener listener, int block, Context context) {  this.threadId = threadId;  this.path = path;  this.file = file;  this.listener = listener;  this.block = block;  this.downloadDao = new DownloadDao(context);  this.startPosition = threadId * block;  this.endPosition = (threadId + 1) * block - 1;  }   @Override  public void run() {  super.run();  try {  //判断该线程是否有下载记录  DownloadInfo info = new DownloadInfo();  info.setPath(path);  info.setThreadId(String.valueOf(threadId));  int length = downloadDao.query(info);  startPosition += length;  //创建RandomAccessFile对象  RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");  //跳转到开始位置  accessFile.seek(startPosition);  URL url = new URL(path);  //打开http链接  HttpURLConnection conn = (HttpURLConnection) url.openConnection();  //设置超时时间  conn.setConnectTimeout(5000);  //指定请求方式为GET方式  conn.setRequestMethod("GET");  //指定下载的位置  conn.setRequestProperty("Range", "bytes="+startPosition + "-" + endPosition);  //不用再去判断状态码是否为200  InputStream in = conn.getInputStream();  byte[] buffer = new byte[1024];  int len = 0;  //该线程下载的总数据量  int count = length;  while((len = in.read(buffer)) != -1){  accessFile.write(buffer, 0, len);  //更新下载进度  listener.getDownload(len);  count += len;  info.setDownloadSize(count);  //更新下载的信息  downloadDao.update(info);  }  accessFile.close();  in.close();  } catch (Exception e) {  // TODO: handle exception  e.printStackTrace();  }  } }

8、新建下载的管理类DownloadManager

这个类主要是对下载过程的管理，包括下载设置下载后文件要保存的位置，计算多线程中每个线程的数据下载量等等，同时相比《Android多线程下载示例》一文中，它多了多下载数据的记录与更新操作。
具体实现代码如下：

package com.example.download;  import java.io.File; import java.io.RandomAccessFile; import java.net.HttpURLConnection; import java.net.URL;  import android.content.Context; import android.os.Environment;  import com.example.dao.DownloadDao; import com.example.domain.DownloadInfo; import com.example.inter.ProgressBarListener;   public class DownloadManager {  //下载线程的数量  private static final int TREAD_SIZE = 3;  private File file;  private DownloadDao downloadDao;  private Context context;  public DownloadManager(Context context) {  this.context = context;  this.downloadDao = new DownloadDao(context);  }     public void download(String path, ProgressBarListener listener) throws Exception{  URL url = new URL(path);  HttpURLConnection conn = (HttpURLConnection) url.openConnection();  conn.setConnectTimeout(5000);  conn.setRequestMethod("GET");  if(conn.getResponseCode() == 200){  int filesize = conn.getContentLength();  //设置进度条的最大长度  listener.getMax(filesize);  //判断下载记录是否存在  boolean ret = downloadDao.isExist(path);  if(ret){  //得到下载的总长度，设置进度条的刻度  int count = downloadDao.queryCount(path);  listener.getDownload(count);  }else{  //保存下载记录  for(int i = 0; i < filesize; i++){   DownloadInfo info = new DownloadInfo();   info.setPath(path);   info.setThreadId(String.valueOf(i));   //保存下载的记录信息   downloadDao.save(info);  }  }  //创建一个和服务器大小一样的文件  file = new File(Environment.getExternalStorageDirectory(), this.getFileName(path));  RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");  accessFile.setLength(filesize);  //要关闭RandomAccessFile对象  accessFile.close();   //计算出每条线程下载的数据量  int block = filesize % TREAD_SIZE == 0 ? (filesize / TREAD_SIZE) : (filesize / TREAD_SIZE +1 );   //开启线程下载  for(int i = 0; i < TREAD_SIZE; i++){  new DownloadThread(i, path, file, listener, block, context).start();  }  }  }     private String getFileName(String path){  return path.substring(path.lastIndexOf("/") + 1);  } }

9、完善MainActivity

在这个类中首先，找到页面中的各个控件，实现Button按钮的onClick事件，在onClick事件中开启一个线程进行下载操作，同时子线程中获取到的数据，通过handler与Message机制传递到主线程，更新界面显示，利用DownloadDao类中的方法来记录和更新下载数据。
具体实现代码如下：

package com.example.multi;  import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.view.Menu; import android.view.View; import android.widget.EditText; import android.widget.ProgressBar; import android.widget.TextView; import android.widget.Toast;  import com.example.dao.DownloadDao; import com.example.download.DownloadManager; import com.example.inter.ProgressBarListener;   public class MainActivity extends Activity {   protected static final int ERROR_DOWNLOAD = 0;  protected static final int SET_PROGRESS_MAX = 1;  protected static final int UPDATE_PROGRESS = 2;   private EditText ed_path;  private ProgressBar pb;  private TextView tv_info;  private DownloadManager manager;  private DownloadDao downloadDao;   //handler操作  private Handler mHandler = new Handler(){   public void handleMessage(android.os.Message msg) {  switch (msg.what) {  case ERROR_DOWNLOAD:  //提示用户下载失败  Toast.makeText(MainActivity.this, "下载失败", Toast.LENGTH_SHORT).show();  break;  case SET_PROGRESS_MAX:  //得到最大值  int max = (Integer) msg.obj;  //设置进度条的最大值  pb.setMax(max);  break;  case UPDATE_PROGRESS:  //获取当前下载的长度  int currentprogress = pb.getProgress();  //获取新下载的长度  int len = (Integer) msg.obj;  //计算当前总下载长度  int crrrentTotalProgress = currentprogress + len;  pb.setProgress(crrrentTotalProgress);    //获取总大小  int maxProgress = pb.getMax();  //计算百分比  float value = (float)currentprogress / (float)maxProgress;  int percent = (int) (value * 100);  //显示下载的百分比  tv_info.setText("下载:"+percent+"%");    if(maxProgress == crrrentTotalProgress){   //删除下载记录   downloadDao.delete(ed_path.getText().toString());  }  break;  default:  break;  }  };  };  @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);  setContentView(R.layout.activity_main);  this.ed_path = (EditText) super.findViewById(R.id.ed_path);  this.pb = (ProgressBar) super.findViewById(R.id.pb);  this.tv_info = (TextView) super.findViewById(R.id.tv_info);  this.manager = new DownloadManager(this);  this.downloadDao = new DownloadDao(this);  }   @Override  public boolean onCreateOptionsMenu(Menu menu) {  // Inflate the menu; this adds items to the action bar if it is present.  getMenuInflater().inflate(R.menu.main, menu);  return true;  }   public void download(View v){  final String path = ed_path.getText().toString();  //下载  new Thread(new Runnable() {  @Override  public void run() {  // TODO Auto-generated method stub  try {   manager.download(path, new ProgressBarListener() {   @Override   public void getMax(int length) {   // TODO Auto-generated method stub   Message message = new Message();   message.what = SET_PROGRESS_MAX;   message.obj = length;   mHandler.sendMessage(message);   }     @Override   public void getDownload(int length) {   // TODO Auto-generated method stub   Message message = new Message();   message.what = UPDATE_PROGRESS;   message.obj = length;   mHandler.sendMessage(message);   }   });  } catch (Exception e) {   // TODO: handle exception   e.printStackTrace();   Message message = new Message();   message.what = ERROR_DOWNLOAD;   mHandler.sendMessage(message);  }  }  }).start();  } }

10、增加权限

最后，别忘了给应用授权，这里要用到Android联网授权和向SD卡中写入文件的权限。
具体实现如下：

<?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android"  package="com.example.multi"  android:versionCode="1"  android:versionName="1.0" >   <uses-sdk  android:minSdkVersion="8"  android:targetSdkVersion="18" />  <uses-permission android:name="android.permission.INTERNET"/>  <uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS"/>  <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"/>  <application  android:allowBackup="true"  android:icon="@drawable/ic_launcher"  android:label="@string/app_name"  android:theme="@style/AppTheme" >  <activity  android:name="com.example.multi.MainActivity"  android:label="@string/app_name" >  <intent-filter>  <action android:name="android.intent.action.MAIN" />   <cateGory android:name="android.intent.category.LAUNCHER" />  </intent-filter>  </activity>  <provider android:name="com.example.provider.DownloadProvider" android:authorities="download"></provider>  </application>  </manifest>

四、运行效果

怎么在Android中实现一个多线程断点续传下载功能