Android 断点续传原理以及实现

Android 断点续传原理以及实现

0.  前言

在Android开发中，断点续传听起来挺容易，在下载一个文件时点击暂停任务暂停，点击开始会继续下载文件。但是真正实现起来知识点还是蛮多的，因此今天有时间实现了一下，并进行记录。

1.  断点续传原理

在本地下载过程中要使用数据库实时存储到底存储到文件的哪个位置了，这样点击开始继续传递时，才能通过HTTP的GET请求中的setRequestProperty()方法可以告诉服务器，数据从哪里开始，到哪里结束。同时在本地的文件写入时，RandomAccessFile的seek()方法也支持在文件中的任意位置进行写入操作。同时通过广播将子线程的进度告诉Activity的ProcessBar。

2.  Activity的按钮响应

当点击开始按钮时，将url写在了FileInfo类的对象info中并通过Intent从Activity传递到了Service中。这里使用setAction()来区分是开始按钮还是暂停按钮。

public class FileInfo implements Serializable{ 
  private String url; //URL 
  private int length; //长度或结束位置 
  private int start; //开始位置 
  private int now;//当前进度 
//构造方法，set/get略 
} 
//开始按钮逻辑，停止逻辑大致相同 
strat.setOnClickListener(new View.OnClickListener() { 
   @Override 
   public void onClick(View view) { 
    Intent intent = new Intent(MainActivity.this,DownLoadService.class); 
    intent.setAction(DownLoadService.ACTION_START); 
    intent.putExtra("fileUrl",info); 
    startService(intent); 
  } 
}); 

3.  在Service中的子线程中获取文件大小

在Service中的onStartCommand()中，将FileInfo对象从Intent中取出，如果是开始命令，则开启一个线程，根据该url去获得要下载文件的大小，将该大小写入对象并通过Handler传回Service，同时在本地创建一个相同大小的本地文件。暂停命令最后会讲到。

public void run() { 
      HttpURLConnection urlConnection = null; 
      RandomAccessFile randomFile = null; 
      try { 
        URL url = new URL(fileInfo.getUrl()); 
        urlConnection = (HttpURLConnection) url.openConnection(); 
        urlConnection.setConnectTimeout(3000); 
        urlConnection.setRequestMethod("GET"); 
        int length = -1; 
        if (urlConnection.getResponseCode() == HttpStatus.SC_OK) { 
          //获得文件长度 
          length = urlConnection.getContentLength(); 
        } 
        if (length <= 0) { 
          return; 
        } 
        //创建相同大小的本地文件 
        File dir = new File(DOWNLOAD_PATH); 
        if (!dir.exists()) { 
          dir.mkdir(); 
        } 
        File file = new File(dir, FILE_NAME); 
        randomFile = new RandomAccessFile(file, "rwd"); 
        randomFile.setLength(length); 
        //长度给fileInfo对象 
        fileInfo.setLength(length); 
        //通过Handler将对象传递给Service 
        mHandle.obtainMessage(0, fileInfo).sendToTarget(); 
      } catch (Exception e) { 
        e.printStackTrace(); 
      } finally { //流的回收逻辑略 
      } 
    } 
  } 

4.  数据库操作封装

在Service的handleMessage()方法中拿到有length属性的FileInfo对象，并使用自定义的DownLoadUtil类进行具体的文件下载逻辑。这里传入上下文，因为数据库处理操作需要用到。

downLoadUtil = new DownLoadUtil(DownLoadService.this,info);

downLoadUtil.download();

这里有一个数据库操作的接口ThreadDAO，内部有增删改查等逻辑，用于记录下载任务的信息。自定义一个ThreadDAOImpl类将这里的逻辑实现，内部数据库创建关于继承SQLiteOpenHelper的自定义类的逻辑就不贴了，比较简单，该类会在ThreadDAOImpl类的构造方法中创建实例。完成底层数据库操作的封装。

public interface ThreadDAO { 
  //插入一条数据 
  public void insert(FileInfo info); 
  //根据URL删除一条数据 
  public void delete(String url); 
  //根据URL更新一条进度 
  public void update(String url,int finished); 
  //根据URL找到一条数据 
  public List<FileInfo> get(String url); 
  //是否存在 
  public boolean isExits(String url); 
} 

5.  具体的文件下载逻辑

public class DownLoadUtil { 
  //构造方法略 
  public void download(){ 
    List<FileInfo> lists = threadDAO.get(fileInfo.getUrl()); 
    FileInfo info = null; 
    if(lists.size() == 0){ 
      //第一次下载，创建子线程下载 
      new MyThread(fileInfo).start(); 
    }else{ 
      //中间开始的 
      info = lists.get(0); 
      new MyThread(info).start(); 
    } 
  } 
 
  class MyThread extends Thread{ 
    private FileInfo info = null; 
    public MyThread(FileInfo threadInfo) { 
      this.info = threadInfo; 
    } 
    @Override 
    public void run() { 
      //向数据库添加线程信息 
      if(!threadDAO.isExits(info.getUrl())){ 
        threadDAO.insert(info); 
      } 
      HttpURLConnection urlConnection = null; 
      RandomAccessFile randomFile =null; 
      InputStream inputStream = null; 
      try { 
        URL url = new URL(info.getUrl()); 
        urlConnection = (HttpURLConnection) url.openConnection(); 
        urlConnection.setConnectTimeout(3000); 
        urlConnection.setRequestMethod("GET"); 
        //设置下载位置 
        int start = info.getStart() + info.getNow(); 
        urlConnection.setRequestProperty("Range","bytes=" + start + "-" + info.getLength()); 
 
        //设置文件写入位置 
        File file = new File(DOWNLOAD_PATH,FILE_NAME); 
        randomFile = new RandomAccessFile(file, "rwd"); 
        randomFile.seek(start); 
 
        //向Activity发广播 
        Intent intent = new Intent(ACTION_UPDATE); 
        finished += info.getNow(); 
 
        if (urlConnection.getResponseCode() == HttpStatus.SC_PARTIAL_CONTENT) { 
          //获得文件流 
          inputStream = urlConnection.getInputStream(); 
          byte[] buffer = new byte[512]; 
          int len = -1; 
          long time = System.currentTimeMillis(); 
          while ((len = inputStream.read(buffer))!= -1){ 
            //写入文件 
            randomFile.write(buffer,0,len); 
            //把进度发送给Activity 
            finished += len; 
            //看时间间隔，时间间隔大于500ms再发 
            if(System.currentTimeMillis() - time >500){ 
              time = System.currentTimeMillis(); 
              intent.putExtra("now",finished *100 /fileInfo.getLength()); 
              context.sendBroadcast(intent); 
            } 
            //判断是否是暂停状态 
            if(isPause){ 
              threadDAO.update(info.getUrl(),finished); 
              return; //结束循环 
            } 
          } 
          //删除线程信息 
          threadDAO.delete(info.getUrl()); 
        } 
      }catch (Exception e){ 
        e.printStackTrace(); 
      }finally {//回收工作略 
      } 
    } 
  } 
} 

上面也讲到使用自定义的DownLoadUtil类进行具体的文件下载逻辑，这也是最关键的部分了，在该类的构造方法中进行ThreadDAOImpl实例的创建。并在download()中通过数据库查询的操作，判断是否是第一次开始下载任务，如果是，则开启一个子线程MyThread进行下载任务，否则将进度信息从数据库中取出，并将该信息传递给MyThread。

在MyThread中，通过info.getStart() + info.getNow()设置开始下载的位置，如果是第一次下载两个数将都是0，如果是暂停后再下载，则info.getNow()会取出非0值，该值来自数据库存储。使用setRequestProperty告知服务器从哪里开始传递数据，传递到哪里结束，本地使用RandomAccessFile的seek()方法进行数据的本地存储。使用广播将进度的百分比传递给Activity，Activity再改变ProcessBar进行UI调整。

这里很关键的一点是在用户点击暂停后会在Service中调用downLoadUtil.isPause = true，因此上面while循环会结束，停止下载并通过数据库的update()保存进度值。从而在续传时取出该值，重新对服务器发起文件起始点的下载任务请求，同时也在本地文件的相应位置继续写入操作。

6.  效果如下所示

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# Android  # 断点续传原理  # 断点续传原理详细介绍  # 断点续传原理详解和实例  # 详解Android使用OKHttp3实现下载(断点续传、显示进度)  # android实现多线程下载文件（支持暂停、取消、断点续传）  # android使用OkHttp实现下载的进度监听和断点续传  # Android多线程断点续传下载功能实现代码  # Android多线程+单线程+断点续传+进度条显示下载功能  # Android 断点续传的原理剖析与实例讲解  # Android实现网络多线程断点续传下载实例  # Android编程开发实现多线程断点续传下载器实例  # Android快速实现断点续传的方法  # 自定义  # 断点续传  # 会在  # 讲到  # 将该  # 都是  # 判断是否  # 有一  # 是在  # 本地下载  # 就不  # 也在  # 而在  # 并在  # 从哪里  # 希望能  # 到哪里  # 所示  # 谢谢大家  # 后会 

相关文章： 做企业网站制作流程,企业网站制作基本流程有哪些？  如何快速搭建高效简练网站？  专业公司网站制作公司,用什么语言做企业网站比较好？  北京网页设计制作网站有哪些,继续教育自动播放怎么设置？  北京专业网站制作设计师招聘,北京白云观官方网站？  黑客入侵网站服务器的常见手法有哪些？  百度网页制作网站有哪些,谁能告诉我百度网站是怎么联系？  SQL查询语句优化的实用方法总结  建站之星代理如何获取技术支持？  深圳网站制作的公司有哪些,dido官方网站？  家庭建站与云服务器建站，如何选择更优？  建站之星如何通过成品分离优化网站效率？  制作网站的网址是什么,请问后缀为.com和.com.cn还有.cn的这三种网站是分别是什么类型的网站？  如何用wdcp快速搭建高效网站？  C++如何将C风格字符串（char*）转换为std::string？（代码示例）  建站之星云端配置指南：模板选择与SEO优化一键生成  网站专业制作公司,网站编辑是做什么的？好做吗？工作前景如何？  外汇网站制作流程,如何在工商银行网站上做外汇买卖？  c# 在高并发场景下，委托和接口调用的性能对比  网站制作公司排行榜,抖音怎样做个人官方网站  上海网站制作网页,上海本地的生活网站有哪些？最好包括生活的各个方面的？  寿县云建站：智能SEO优化与多行业模板快速上线指南  黑客如何通过漏洞一步步攻陷网站服务器？  一键制作网站软件下载安装,一键自动采集网页文档制作步骤？  如何选择适配移动端的WAP自助建站平台？  北京网站制作的公司有哪些,北京白云观官方网站？  制作无缝贴图网站有哪些,3dmax无缝贴图怎么调？  云南网站制作公司有哪些,云南最好的招聘网站是哪个？  小视频制作网站有哪些,有什么看国内小视频的网站，求推荐？  在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么？  javascript中的try catch异常捕获机制用法分析  微信小程序 input输入框控件详解及实例（多种示例）  详解jQuery中基本的动画方法  建站主机选择指南：服务器配置与SEO优化实战技巧  网站建设设计制作营销公司南阳,如何策划设计和建设网站？  网站制作公司,橙子建站是合法的吗？  子杰智能建站系统｜零代码开发与AI生成SEO优化指南  如何快速上传建站程序避免常见错误？  定制建站流程解析：需求评估与SEO优化功能开发指南  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗？  沈阳制作网站公司排名,沈阳装饰协会官方网站？  整人网站在线制作软件,整蛊网站退不出去必须要打我是白痴才能出去？  如何生成腾讯云建站专用兑换码？  桂林网站制作公司有哪些,桂林马拉松怎么报名？  php json中文编码为null的解决办法  如何基于PHP生成高效IDC网络公司建站源码？  建站主机如何选？性能与价格怎样平衡？  无锡制作网站公司有哪些,无锡优八网络科技有限公司介绍？  如何在香港免费服务器上快速搭建网站？  网站制作的步骤包括,正确网址格式怎么写？