*Android 多线程下载 仿下载助手

界面效果

线程池 ThreadPoolExecutor

    在以下介绍实现下载原理的时候。我想尝试倒着来说。这样是否好理解一点？ 
    我们都知道。下载助手，比方360， 百度的 手机助手，下载APP 的时候 ，都能够同一时候下载多个。所以，下载肯定是多线程的。所以我们就须要一个线程工具类 来管理我们的线程，这个工具类的核心，就是 线程池。

 
线程池ThreadPoolExecutor ，先简单学习下这个线程池的使用

    上面是 ThreadPoolExecutor的參数介绍。 

    第一个參数 corePoolSize ： 空暇时 存在的线程数目、 
    第二个參数 maximumPoolSize ：同意同一时候存在的最大线程数、 
    第三个參数 keepAliveTime： 这个參数是 同意空暇线程存活的时间、 
    第四个參数 unit ： 是 时间的单位 、 
    第五个參数 workQueue ：这个是一个容器，它里面存放的是、 threadpool.execute(new Runnable()) 运行的线程.new Runnable()、 
    第六个參数 handler：当运行被堵塞时，该处理程序将被堵塞。由于线程的边界和队列容量达到了 。

工具类 ThreadManager

介绍完了 线程池參数，那我们就先创建一个线程管理的工具类 ThreadManager

    这个线程池工具类 主要就是 生成一个线程池。 以及 取消线程池中的任务，查询线程池中是否包括某一任务。

下载任务 DownloadTask

    我们的如今线程 DownloadTask 就 通过 ThreadManager .getDownloadPool（）.execute() 方法 交给线程池去管理。

    有了线程池管理我们的线程。 那我们下一步 就是 DownloadTask 这个类去下载了。

    下载的原理 非常easy。就是 通过 目标的URL 拿到流，然后写到本地。

    由于下载在 run（） 里面运行，这个DownloadTask 类 我们就看run() 方法的实现，所以 关键代码 就是以下一点点

   这个在我们刚接触Java 的时候 肯定都写过了。 这就是往本地写数据的代码。所以run（）方法中的 前面 就是拿到 stream 输入流， 以及 把file 创建出来。

刷新进度。状态

    关于控制 button中text 显示 暂停 ，下载。还是进度，就靠 notifyDownloadProgressed(info);和 notifyDownloadStateChanged（info）两个方法， 这两个方法 实际上调用的是两个接口，仅仅要我们在我们须要改变界面的类里 实现这两个接口，就能够接收到 包括最新信息的info对象。而我们在哪个类里改变button 上面 显示的文字呢？ 当然是在 我们的adapter 里面了，大家都知道 是在 adapter 的getView() 方法里面 载入的每一条数据的布局。

    那就一起看下是不是这样子呢？

    里面代码有点多，那就看startObserver（）方法做了什么。

这里 是 注冊了observer, Observer 是什么东西？在DownloadManager 中我们定义了 

public interface DownloadObserver {

    public void onDownloadStateChanged(DownloadInfo info);

    public void onDownloadProgressed(DownloadInfo info);
}

    一个接口，里面有两个抽象方法 一个是 进度。还有一个是下载状态。 那回过头来，屡一下。 我们在 下载的关键代码里面调用了 

    DownloadObserver onDownloadProgressed() 

    DownloadObserver.onDownloadStateChanged()

    两个抽象方法，而我们在 adapter中实现了 这两个方法 就能够轻松的控制 去 刷新 和改变 下载状态了。

    细心的朋友 也许 发现问题了，对，我们还没有注冊Observer，就在 DownloadManager 中去调用了。 

这里 在看下DownloadManager 中 调用的方法

/** 当下载状态发送改变的时候回调 */
public void notifyDownloadStateChanged(DownloadInfo info) {
    synchronized (mObservers) {
        for (DownloadObserver observer : mObservers) {
            observer.onDownloadStateChanged(info);
        }
    }
}

/** 当下载进度发送改变的时候回调 */
public void notifyDownloadProgressed(DownloadInfo info) {
    synchronized (mObservers) {
        for (DownloadObserver observer : mObservers) {
            observer.onDownloadProgressed(info);
        }
    }
}

    是的。这里我们遍历一个observer容器。然后去刷新 。所以我们还须要把Observer对象加入到集合mObservers中，所以肯定有这样一个方法将observer加入到集合中 。 

/* 注冊观察者 / 
public void registerObserver(DownloadObserver observer) { 
synchronized (mObservers) { 
if (!mObservers.contains(observer)) { 
mObservers.add(observer); 
} 
} 
}

/** 反注冊观察者 */
public void unRegisterObserver(DownloadObserver observer) {
    synchronized (mObservers) {
        if (mObservers.contains(observer)) {
            mObservers.remove(observer);
        }
    }
}

     所以最后一步，由于 adapter 方法中有 startObserver， 所以 我们在 主界面 MainActivity 的类中调用 adapter.startObser() 将 实现了 接口的adapter 对象 加入到 Observer 容器中 就能够了。

    OK。大功告成。

=============================================

DownloadManager 代码

    这里 贴一下DownloadManager 代码

    有两点 须要说明。关于 点击暂停后。再继续下载 有两种方式能够实现

    第一种 点击暂停的时候 记录下载了 多少，然后 再点击 继续下载 时，告诉服务器， 让服务器接着 上次的数据 往本地传递，

    代码 就是 我们 DownloadTask 下载时候，推断一下

    服务器 处理的代码 也非常easy 就是一句话

    String range = req.getParameter(“range”); 拿到 range 推断 range 存在不存在。 
    假设不存在

  如果存在 那么跳过range 个字节

    还有一种方式是本地处理，这个demo 中就是本地处理的， 可是有一个问题。 由于 Java api的原因 。inputStream.skip（） 方法 并不能准确的 跳过多少个字节。

而是 小于你想要跳过的字节，所以 你要去遍历 一直到 满足你要跳过的字节 在继续写。 由于 这个方案有一个缺点。就是在下载非常大的文件，

比方文件大小20M ,当已经下载了15M 此时你去暂停。在继续下载，那么要跳过前面的15M 将会话费非常多时间。

    所以这个仅限于学习。实际中 假设要下载大的文件。不能用这个方案。

完美版 过几天 再发。

    代码下载 ： 
    AndroidStudio 版 
    Eclipse 版

-------------------------------------------各级格机格机格机--------------------------------------

-------------------------------改进版 :点击打开链接------------------------