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快速实现断点续传的方法  # 自定义  # 断点续传  # 会在  # 讲到  # 将该  # 都是  # 判断是否  # 有一  # 是在  # 本地下载  # 就不  # 也在  # 而在  # 并在  # 从哪里  # 希望能  # 到哪里  # 所示  # 谢谢大家  # 后会 

相关文章： 公司网站制作需要多少钱,找人做公司网站需要多少钱？  微网站制作教程,我微信里的网站怎么才能复制到浏览器里？  如何解决ASP生成WAP建站中文乱码问题？  手机网站制作与建设方案,手机网站如何建设？  建站之星备案是否影响网站上线时间？  如何在香港免费服务器上快速搭建网站？  如何基于云服务器快速搭建网站及云盘系统？  电商网站制作价格怎么算,网上拍卖流程以及规则？  如何在景安云服务器上绑定域名并配置虚拟主机？  建站之星代理平台如何选择最佳方案？  网站制作需要会哪些技术,建立一个网站要花费多少？  如何使用Golang table-driven基准测试_多组数据测量函数效率  学校建站服务器如何选型才能满足性能需求？  建站之星在线客服如何快速接入解答？  建站之星伪静态规则如何设置？  SAX解析器是什么，它与DOM在处理大型XML文件时有何不同？  如何通过商城免费建站系统源码自定义网站主题？  邀请函制作网站有哪些,有没有做年会邀请函的网站啊？在线制作，模板很多的那种？  ,在苏州找工作，上哪个网站比较好？  如何在搬瓦工VPS快速搭建网站？  如何在万网主机上快速搭建网站？  长春网站建设制作公司,长春的网络公司怎么样主要是能做网站的？  如何用IIS7快速搭建并优化网站站点？  定制建站哪家更专业可靠？推荐榜单揭晓  小建面朝正北，A点实际方位是否存在偏差？  如何用低价快速搭建高质量网站？  如何通过.red域名打造高辨识度品牌网站？  大连 网站制作,大连天途有线官网？  网站制作哪家好,cc、.co、.cm哪个域名更适合做网站？  深圳企业网站制作设计,在深圳如何网上全流程注册公司？  已有域名建站全流程解析：网站搭建步骤与建站工具选择  个人摄影网站制作流程,摄影爱好者都去什么网站？  b2c电商网站制作流程,b2c水平综合的电商平台？  小型网站制作HTML,*游戏网站怎么搭建？  建站之星展会模版如何一键下载生成？  如何获取开源自助建站系统免费下载链接？  韩国代理服务器如何选？解析IP设置技巧与跨境访问优化指南  建站主机数据库如何配置才能提升网站性能？  免费制作海报的网站,哪位做平面的朋友告诉我用什么软件做海报比较好?ps还是cd还是ai这几个软件我都会些我是做网页的？  韩国服务器如何优化跨境访问实现高效连接？  网站制作和推广的区别,想自己建立一个网站做推广，有什么快捷方法马上做好一个网站？  东莞专业制作网站的公司,东莞大学生网的网址是什么？  如何用虚拟主机快速搭建网站？详细步骤解析  建站之星图片链接生成指南：自助建站与智能设计教程  广德云建站网站建设方案与建站流程优化指南  成都网站制作公司哪家好,四川省职工服务网是做什么用？  宝塔面板创建网站无法访问？如何快速排查修复？  重庆市网站制作公司,重庆招聘网站哪个好？  建站之星安装后界面空白如何解决？  建站主机选购指南与交易推荐：核心配置解析