android实现多线程下载文件（支持暂停、取消、断点续传）

filelength = conn.getcontentlength();
//根据文件大小，先创建一个空文件
//“r“——以只读方式打开。调用结果对象的任何 write 方法都将导致抛出 ioexception。
//“rw“——打开以便读取和写入。如果该文件尚不存在，则尝试创建该文件。
//“rws“—— 打开以便读取和写入，对于 “rw”，还要求对文件的内容或元数据的每个更新都同步写入到底层存储设备。
//“rwd“——打开以便读取和写入，对于 “rw”，还要求对文件内容的每个更新都同步写入到底层存储设备。
randomaccessfile raf = new randomaccessfile(filepath, "rwd");
raf.setlength(filelength);
raf.close();
//计算各个线程下载的数据段
int blocklength = filelength / threadcount;

url url = new url(loadurl);
httpurlconnection conn = (httpurlconnection) url.openconnection();
conn.setrequestmethod("get");
conn.setrequestproperty("range", "bytes=" + startposition + "-" + endposition);
conn.setconnecttimeout(5000);
//若请求头加上range这个参数，则返回状态码为206，而不是200
if (conn.getresponsecode() == 206) {
  inputstream is = conn.getinputstream();
  randomaccessfile raf = new randomaccessfile(filepath, "rwd");
  raf.seek(startposition);//跳到指定位置开始写数据
}

 protected void onpause() {
    if (mthreads != null)
      statedownload = download_pause;
  }
  protected void onstart() {
    if (mthreads != null)
      synchronized (download_pause) {
        statedownload = download_ing;
        download_pause.notifyall();
      }
  }

  synchronized (download_pause) {
    if (statedownload.equals(download_pause)) {
      download_pause.wait();
    }
  }

  while ((len = is.read(buffer)) != -1) {
    //是否继续下载
    if (!isgoon)
      break;
  }

  sharedpreferences sp = mcontext.getsharedpreferences(sp_name, context.mode_private);
  //获取上次取消下载的进度，若没有则返回0
  currlength = sp.getint(curr_length, 0);
  for (int i = 0; i < threadcount; i++) {
    //开始位置，获取上次取消下载的进度，默认返回i*blocklength,即第i个线程开始下载的位置
    int startposition = sp.getint(sp_name + (i + 1), i * blocklength);
    //结束位置，-1是为了防止上一个线程和下一个线程重复下载衔接处数据
    int endposition = (i + 1) * blocklength - 1;
    //将最后一个线程结束位置扩大，防止文件下载不完全，大了不影响，小了文件失效
    if ((i + 1) == threadcount)
    endposition = endposition * 2;
    mthreads[i] = new downthread(i + 1, startposition, endposition);
    mthreads[i].start();
  }

<uses-permission android:name="android.permission.internet" />
<uses-permission android:name="android.permission.write_external_storage" />

import android.content.context;
import android.content.sharedpreferences;
import android.os.handler;
import android.os.message;

import java.io.inputstream;
import java.io.randomaccessfile;
import java.net.httpurlconnection;
import java.net.url;

/**
 * created by tianzhao on 2017/2/21 09:25.
 * 多线程下载文件
 */

public class downloadfile {


  private static final string sp_name = "download_file";
  private static final string curr_length = "curr_length";
  private static final int default_thread_count = 4;//默认下载线程数
  //以下为线程状态
  private static final string download_init = "1";
  private static final string download_ing = "2";
  private static final string download_pause = "3";

  private context mcontext;

  private string loadurl;//网络获取的url
  private string filepath;//下载到本地的path
  private int threadcount = default_thread_count;//下载线程数

  private int filelength;//文件总大小
  //使用volatile防止多线程不安全
  private volatile int currlength;//当前总共下载的大小
  private volatile int runningthreadcount;//正在运行的线程数
  private thread[] mthreads;
  private string statedownload = download_init;//当前线程状态

  private downloadlistener mdownloadlistener;

  public void setondownloadlistener(downloadlistener mdownloadlistener) {
    this.mdownloadlistener = mdownloadlistener;
  }

  interface downloadlistener {
    //返回当前下载进度的百分比
    void getprogress(int progress);

    void oncomplete();

    void onfailure();
  }

  public downloadfile(context mcontext, string loadurl, string filepath) {
    this(mcontext, loadurl, filepath, default_thread_count, null);
  }

  public downloadfile(context mcontext, string loadurl, string filepath, downloadlistener mdownloadlistener) {
    this(mcontext, loadurl, filepath, default_thread_count, mdownloadlistener);
  }

  public downloadfile(context mcontext, string loadurl, string filepath, int threadcount) {
    this(mcontext, loadurl, filepath, threadcount, null);
  }

  public downloadfile(context mcontext, string loadurl, string filepath, int threadcount, downloadlistener mdownloadlistener) {
    this.mcontext = mcontext;
    this.loadurl = loadurl;
    this.filepath = filepath;
    this.threadcount = threadcount;
    runningthreadcount = 0;
    this.mdownloadlistener = mdownloadlistener;
  }

  /**
   * 开始下载
   */
  protected void download() {
    //在线程中运行，防止anr
    new thread(new runnable() {
      @override
      public void run() {
        try {
          //初始化数据
          if (mthreads == null)
            mthreads = new thread[threadcount];

          //建立连接请求
          url url = new url(loadurl);
          httpurlconnection conn = (httpurlconnection) url.openconnection();
          conn.setconnecttimeout(5000);
          conn.setrequestmethod("get");
          int code = conn.getresponsecode();//获取返回码
          if (code == 200) {//请求成功,根据文件大小开始分多线程下载
            filelength = conn.getcontentlength();
            //根据文件大小，先创建一个空文件
            //“r“——以只读方式打开。调用结果对象的任何 write 方法都将导致抛出 ioexception。
            //“rw“——打开以便读取和写入。如果该文件尚不存在，则尝试创建该文件。
            //“rws“—— 打开以便读取和写入，对于 “rw”，还要求对文件的内容或元数据的每个更新都同步写入到底层存储设备。
            //“rwd“——打开以便读取和写入，对于 “rw”，还要求对文件内容的每个更新都同步写入到底层存储设备。
            randomaccessfile raf = new randomaccessfile(filepath, "rwd");
            raf.setlength(filelength);
            raf.close();
            //计算各个线程下载的数据段
            int blocklength = filelength / threadcount;

            sharedpreferences sp = mcontext.getsharedpreferences(sp_name, context.mode_private);
            //获取上次取消下载的进度，若没有则返回0
            currlength = sp.getint(curr_length, 0);
            for (int i = 0; i < threadcount; i++) {
              //开始位置，获取上次取消下载的进度，默认返回i*blocklength,即第i个线程开始下载的位置
              int startposition = sp.getint(sp_name + (i + 1), i * blocklength);
              //结束位置，-1是为了防止上一个线程和下一个线程重复下载衔接处数据
              int endposition = (i + 1) * blocklength - 1;
              //将最后一个线程结束位置扩大，防止文件下载不完全，大了不影响，小了文件失效
              if ((i + 1) == threadcount)
                endposition = endposition * 2;

              mthreads[i] = new downthread(i + 1, startposition, endposition);
              mthreads[i].start();
            }
          } else {
            handler.sendemptymessage(failure);
          }
        } catch (exception e) {
          e.printstacktrace();
          handler.sendemptymessage(failure);
        }
      }
    }).start();
  }

  /**
   * 取消下载
   */
  protected void cancel() {
    if (mthreads != null) {
      //若线程处于等待状态，则while循环处于阻塞状态，无法跳出循环，必须先唤醒线程，才能执行取消任务
      if (statedownload.equals(download_pause))
        onstart();
      for (thread dt : mthreads) {
        ((downthread) dt).cancel();
      }
    }
  }

  /**
   * 暂停下载
   */
  protected void onpause() {
    if (mthreads != null)
      statedownload = download_pause;
  }

  /**
   * 继续下载
   */
  protected void onstart() {
    if (mthreads != null)
      synchronized (download_pause) {
        statedownload = download_ing;
        download_pause.notifyall();
      }
  }

  protected void ondestroy() {
    if (mthreads != null)
      mthreads = null;
  }

  private class downthread extends thread {

    private boolean isgoon = true;//是否继续下载
    private int threadid;
    private int startposition;//开始下载点
    private int endposition;//结束下载点
    private int currposition;//当前线程的下载进度

    private downthread(int threadid, int startposition, int endposition) {
      this.threadid = threadid;
      this.startposition = startposition;
      currposition = startposition;
      this.endposition = endposition;
      runningthreadcount++;
    }

    @override
    public void run() {
      sharedpreferences sp = mcontext.getsharedpreferences(sp_name, context.mode_private);
      try {
        url url = new url(loadurl);
        httpurlconnection conn = (httpurlconnection) url.openconnection();
        conn.setrequestmethod("get");
        conn.setrequestproperty("range", "bytes=" + startposition + "-" + endposition);
        conn.setconnecttimeout(5000);
        //若请求头加上range这个参数，则返回状态码为206，而不是200
        if (conn.getresponsecode() == 206) {
          inputstream is = conn.getinputstream();
          randomaccessfile raf = new randomaccessfile(filepath, "rwd");
          raf.seek(startposition);//跳到指定位置开始写数据
          int len;
          byte[] buffer = new byte[1024];
          while ((len = is.read(buffer)) != -1) {
            //是否继续下载
            if (!isgoon)
              break;
            //回调当前进度
            if (mdownloadlistener != null) {
              currlength += len;
              int progress = (int) ((float) currlength / (float) filelength * 100);
              handler.sendemptymessage(progress);
            }

            raf.write(buffer, 0, len);
            //写完后将当前指针后移，为取消下载时保存当前进度做准备
            currposition += len;
            synchronized (download_pause) {
              if (statedownload.equals(download_pause)) {
                download_pause.wait();
              }
            }
          }
          is.close();
          raf.close();
          //线程计数器-1
          runningthreadcount--;
          //若取消下载，则直接返回
          if (!isgoon) {
            //此处采用sharedpreferences保存每个线程的当前进度，和三个线程的总下载进度
            if (currposition < endposition) {
              sp.edit().putint(sp_name + threadid, currposition).apply();
              sp.edit().putint(curr_length, currlength).apply();
            }
            return;
          }
          if (runningthreadcount == 0) {
            sp.edit().clear().apply();
            handler.sendemptymessage(success);
            handler.sendemptymessage(100);
            mthreads = null;
          }
        } else {
          sp.edit().clear().apply();
          handler.sendemptymessage(failure);
        }
      } catch (exception e) {
        sp.edit().clear().apply();
        e.printstacktrace();
        handler.sendemptymessage(failure);
      }
    }

    public void cancel() {
      isgoon = false;
    }
  }

  private final int success = 0x00000101;
  private final int failure = 0x00000102;

  private handler handler = new handler() {
    @override
    public void handlemessage(message msg) {

      if (mdownloadlistener != null) {
        if (msg.what == success) {
          mdownloadlistener.oncomplete();
        } else if (msg.what == failure) {

          mdownloadlistener.onfailure();
        } else {
          mdownloadlistener.getprogress(msg.what);
        }
      }
    }
  };
}

import android.os.bundle;
import android.os.environment;
import android.support.v7.app.appcompatactivity;
import android.view.view;
import android.widget.textview;
import android.widget.toast;

public class mainactivity extends appcompatactivity {
  downloadfile downloadfile;
  private string loadurl = "http://gdown.baidu.com/data/wisegame/d2fbbc8e64990454/wangyiyunyinle_87.apk";
  private string filepath = environment.getexternalstoragedirectory()+"/"+"网易云音乐.apk";

  @override
  protected void oncreate(bundle savedinstancestate) {
    super.oncreate(savedinstancestate);
    setcontentview(r.layout.activity_main);
    final textview tvprogress = (textview) findviewbyid(r.id.tv_progress);
    downloadfile = new downloadfile(this,loadurl, filepath, 3);
    downloadfile.setondownloadlistener(new downloadfile.downloadlistener() {
      @override
      public void getprogress(int progress) {
        tvprogress.settext("当前进度 ："+progress+" %");
      }

      @override
      public void oncomplete() {
        toast.maketext(mainactivity.this,"下载完成",toast.length_short).show();
      }

      @override
      public void onfailure() {
        toast.maketext(mainactivity.this,"下载失败",toast.length_short).show();
      }
    });
    findviewbyid(r.id.bt).setonclicklistener(new view.onclicklistener() {
      @override
      public void onclick(view v) {
        downloadfile.download();
      }
    });
    findviewbyid(r.id.bt_pause).setonclicklistener(new view.onclicklistener() {
      @override
      public void onclick(view v) {
        downloadfile.onpause();
      }
    });
    findviewbyid(r.id.bt_start).setonclicklistener(new view.onclicklistener() {
      @override
      public void onclick(view v) {
        downloadfile.onstart();
      }
    });
    findviewbyid(r.id.bt_cancel).setonclicklistener(new view.onclicklistener() {
      @override
      public void onclick(view v) {
        downloadfile.cancel();
      }
    });
  }

  @override
  protected void ondestroy() {
    downloadfile.ondestroy();
    super.ondestroy();
  }
}