Android实现断点下载的方法

 更新时间:2016年03月01日 10:04:00   转载 投稿:lijiao  
这篇文章主要为大家详细介绍了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;//线程ID

  private int startPos;//下载起始位置

  private int endPos;//下载结束位置

  private int completeSize;//下载完成量

  private String url;//资源URL

  public 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;
  }

  @Override
  public String toString() {
    // TODO Auto-generated method stub
    return "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 stub
    super(context, "download.db", null, 1);
  }

  @Override
  public void onCreate(SQLiteDatabase db) {
    // TODO Auto-generated method stub
    db.execSQL(sql);
  }

  @Override
  public 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 block
      e.printStackTrace();
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.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 stub
      threadId=tId;
      startPos=sp;
      endPos = ep;
      completeSize = cSize;
      url = address;
    }

    @Override
    public void run() {
      // TODO Auto-generated method stub
      HttpURLConnection 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 block
        e.printStackTrace();
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }finally{
        try {
          is.close();
          randomAccessFile.close();
          connection.disconnect();
          dao.closeDB();
        } catch (IOException e) {
          // TODO Auto-generated catch block
          e.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();
      }
    };
  };
  @Override
  protected 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);
  }

  @Override
  public void onClick(View v) {
    // TODO Auto-generated method stub
    if(v==start){
      new Thread(new Runnable() {

        @Override
        public void run() {
          // TODO Auto-generated method stub
          LoadInfo 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;
    }
  }  
}

运行效果

总体比较简单,基本实现了 断点下载的功能,而且开启了多个线程去实现分块下载,对初学的同学有一定的帮助。

这些代码我也是从网上各种搜集而来,自己亲自动手敲了一遍,并做了一些小的改动,对整个断点下载的过程有了一个深刻的认识。因此平时要多敲代码,善于总结,必能有所收获。

相关文章

  • Android activity堆栈及管理实例详解

    Android activity堆栈及管理实例详解

    这篇文章主要介绍了Android activity堆栈及管理实例详解的相关资料,非常不错,具有参考借鉴价值,对android activity堆栈相关知识感兴趣的朋友一起学习吧
    2016-09-09
  • Android自定义View之酷炫数字圆环

    Android自定义View之酷炫数字圆环

    这篇文章主要介绍了Android自定义View之酷炫数字圆环,实现效果很酷,值得大家学习,感兴趣的小伙伴们可以参考一下
    2016-01-01
  • Android编程之数据库的创建方法详解

    Android编程之数据库的创建方法详解

    这篇文章主要介绍了Android编程之数据库的创建方法,结合实例形式分析了Android数据库创建的步骤、实现技巧与相关注意事项,需要的朋友可以参考下
    2017-08-08
  • Android Studio打包jar及aar包的方法

    Android Studio打包jar及aar包的方法

    这篇文章主要介绍了Android Studio打包jar及aar包的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-07-07
  • Android自定义View展开菜单功能的实现

    Android自定义View展开菜单功能的实现

    这篇文章主要介绍了Android自定义View展开菜单功能的实现,需要的朋友可以参考下
    2017-06-06
  • 在Android中访问WebService接口的方法

    在Android中访问WebService接口的方法

      最近公司有个项目需要从Android平台访问WebService接口,实现向发布的函数传递对象。在网上找了一些资料,发现使用ksoap2可以调用WebService传递对象。
    2013-05-05
  • Android使用ViewPager实现滚动广告

    Android使用ViewPager实现滚动广告

    这篇文章主要为大家详细介绍了Android使用ViewPager实现滚动广告,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-11-11
  • 4种Android屏幕自适应解决方案

    4种Android屏幕自适应解决方案

    在开发android项目的时候,我们常常会考虑这样的问题:为不同的手机屏幕显示出最佳的界面,以提升用户的体验。本文介绍的是4种Android屏幕自适应解决方案,有兴趣的可以了解一下。
    2016-10-10
  • Android 中WebView 截图的实现方式

    Android 中WebView 截图的实现方式

    这篇文章主要介绍了Android 中WebView 截图的实现方式,WebView 作为一种特殊的控件,自然不能像其他系统 View 或者截屏的方式来获取截图。本文通过实例代码给大家介绍的非常详细,需要的朋友参考下吧
    2017-12-12
  • Android网络数据开关用法简单示例

    Android网络数据开关用法简单示例

    这篇文章主要介绍了Android网络数据开关用法,通过自定义函数调用系统服务实现开关功能,具有一定参考借鉴价值,需要的朋友可以参考下
    2016-06-06

最新评论