DownloadProvider 简介
DownloadProvider 是Android提供的DownloadManager的增强版，亮点是支持断点下载，提供了“开始下载”，“暂停下载”，“重新下载”，“删除下载”接口。源码下载地址

DownloadProvider 详细分析

DownloadProvider开始下载的是由DownloadManager 的 enqueue方法启动的，启动一个新的下载任务的时序图 

开始新的下载时候会调用DownloadManager的enqueue方法，然后再执行DownloadProvider的insert方法，将下载信息写入数据库，包括下载链接地址等，然后再调用DownloadService的onCreate或者onStartCommand方法。 DownloadProvider类是非常重要的类，所有操作都跟此类有关，因为要保存下载状态。 在分析DownloadProvider的insert方法前，先看看insert方法的源码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
@Override
public Uri insert(final Uri uri, final ContentValues values) {
    checkInsertPermissions(values);
    SQLiteDatabase db = mOpenHelper.getWritableDatabase();
    // note we disallow inserting into ALL_DOWNLOADS
    int match = sURIMatcher.match(uri);
    if (match != MY_DOWNLOADS) {
        Log.d(Constants.TAG, "calling insert on an unknown/invalid URI: "
                + uri);
        throw new IllegalArgumentException("Unknown/Invalid URI " + uri);
    }
    ContentValues filteredValues = new ContentValues();
    ......
    Integer dest = values.getAsInteger(Downloads.COLUMN_DESTINATION);
    if (dest != null) {
     
        ......
         
    }
    Integer vis = values.getAsInteger(Downloads.COLUMN_VISIBILITY);
    if (vis == null) {
        if (dest == Downloads.DESTINATION_EXTERNAL) {
            filteredValues.put(Downloads.COLUMN_VISIBILITY,
                    Downloads.VISIBILITY_VISIBLE_NOTIFY_COMPLETED);
        } else {
            filteredValues.put(Downloads.COLUMN_VISIBILITY,
                    Downloads.VISIBILITY_HIDDEN);
        }
    } else {
        filteredValues.put(Downloads.COLUMN_VISIBILITY, vis);
    }
    ......
    String pckg = values.getAsString(Downloads.COLUMN_NOTIFICATION_PACKAGE);
    String clazz = values.getAsString(Downloads.COLUMN_NOTIFICATION_CLASS);
    if (pckg != null && (clazz != null || isPublicApi)) {
        ......
    }
    ......
    //启动下载服务
    Context context = getContext();
    context.startService(new Intent(context, DownloadService.class));
    //插入数据库
    long rowID = db.insert(DB_TABLE, null, filteredValues);
    if (rowID == -1) {
        Log.d(Constants.TAG, "couldn't insert into downloads database");
        return null;
    }
    insertRequestHeaders(db, rowID, values);
    //启动下载服务
    context.startService(new Intent(context, DownloadService.class));
    notifyContentChanged(uri, match);
    return ContentUris.withAppendedId(Downloads.CONTENT_URI, rowID);
}

每次开始一个新的下载任务，都会插入数据库，然后启动启动下载服务类DownloadService，所以真正处理下载的是后台服务DownloadService，DownloadService中有个下载线程类DownloadThread，DownloadService时序图 

如果DownloadService没有启动将会执行onCreate()------>onStartCommand()方法，否则执行onStartCommand()方法。然后执行updateFromProvider()方法启动UpdateThread线程，准备启动DownloadThread线程。 分析UpdateThread的run方法前先看看run方法的源码：

?
1
2
3
4
5
6
7
8
9
10
11
public void run() {
    Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
    //如果数据里的存储的达到了1000以上时候，将会删除status>200即失败的记录
    trimDatabase();
    removeSpuriousFiles();
    boolean keepService = false;
    // for each update from the database, remember which download is
    // supposed to get restarted soonest in the future
    long wakeUp = Long.MAX_VALUE;

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
        //会一直在此循环，直到启动完所有下载任务
    for (;;) {
        synchronized (DownloadService.this) {
            if (mUpdateThread != this) {
                throw new IllegalStateException(
                        "multiple UpdateThreads in DownloadService");
            }
            if (!mPendingUpdate) {
                mUpdateThread = null;
                if (!keepService) {
                    stopSelf();
                }
                if (wakeUp != Long.MAX_VALUE) {
                    scheduleAlarm(wakeUp);
                }
                return;
            }
            mPendingUpdate = false;
        }
        long now = mSystemFacade.currentTimeMillis();
        keepService = false;
        wakeUp = Long.MAX_VALUE;
        Set<long> idsNoLongerInDatabase = new HashSet<long>(
                mDownloads.keySet());
        Cursor cursor = getContentResolver().query(
                Downloads.ALL_DOWNLOADS_CONTENT_URI, null, null, null,
                null);
        if (cursor == null) {
            continue;
        }
        try {
            DownloadInfo.Reader reader = new DownloadInfo.Reader(
                    getContentResolver(), cursor);
            int idColumn = cursor.getColumnIndexOrThrow(Downloads._ID);
            for (cursor.moveToFirst(); !cursor.isAfterLast(); cursor
                    .moveToNext()) {
                long id = cursor.getLong(idColumn);
                idsNoLongerInDatabase.remove(id);
                DownloadInfo info = mDownloads.get(id);
                if (info != null) {
                    updateDownload(reader, info, now);
                } else {
                    info = insertDownload(reader, now);
                }
                if (info.hasCompletionNotification()) {
                    keepService = true;
                }
                long next = info.nextAction(now);
                if (next == 0) {
                    keepService = true;
                } else if (next > 0 && next < wakeUp) {
                    wakeUp = next;
                }
            }
        } finally {
            cursor.close();
        }
        for (Long id : idsNoLongerInDatabase) {
            deleteDownload(id);
        }
        // is there a need to start the DownloadService? yes, if there
        // are rows to be deleted.
        for (DownloadInfo info : mDownloads.values()) {
            if (info.mDeleted) {
                keepService = true;
                break;
            }
        }
        mNotifier.updateNotification(mDownloads.values());
        // look for all rows with deleted flag set and delete the rows
        // from the database
        // permanently
        for (DownloadInfo info : mDownloads.values()) {
            if (info.mDeleted) {
                Helpers.deleteFile(getContentResolver(), info.mId,
                        info.mFileName, info.mMimeType);
            }
        }
    }
}</long></long>

UpdateThread线程负责从数据库中获取下载任务，该线程不会每次都新建新的对象，只有UpdateThread为空时候才会新建，在此线程的run()方法中有两个for循环，外循环是从数据获取下载任务，确保插入数据库的任务都能被启动，直到启动完所有的下载任务才会退出。内循环是遍历从数据库获取的没完成或者刚开始的下载任务，启动下载。 DownloadThrea线程是真正负责下载的线程，每次启动一个任务都会创建一个新的下载线程对象（对手机来说会耗很大的CPU,所有要加上同步锁或者线程池来控制同时下载的数量），看看DownloadThread run方法的时序图： 
从这个时序图可以看出，这里涉及的源码比较多，在这没有写，看的时候一定要对照的源码来看。其实在下载的时候会发生很多的异常，如网络异常，内存卡容量不足等，所以捕获异常很重要的，捕获后进行相关的处理，这也是体现出考虑全面的地方。

DownloadProvider 源码详细分析相关推荐

  1. LinkedHashMap 源码详细分析（JDK1.8）

    1. 概述 LinkedHashMap 继承自 HashMap,在 HashMap 基础上,通过维护一条双向链表,解决了 HashMap 不能随时保持遍历顺序和插入顺序一致的问题.除此之外,Linke ...

  2. linkedhashmap 顺序_LinkedHashMap 源码详细分析（JDK1.8）

    1. 概述 LinkedHashMap 继承自 HashMap,在 HashMap 基础上,通过维护一条双向链表,解决了 HashMap 不能随时保持遍历顺序和插入顺序一致的问题.除此之外,Linke ...

  3. FBReader源码详细分析 序言

    2019独角兽企业重金招聘Python工程师标准>>> FBReader源码详细分析 -- 序言 有关FBReader源码的分析,网络上已经有一位叫做"谋哥"的大 ...

  4. android view 源码分析,Android ViewPager源码详细分析

    1.问题 由于Android Framework源码很庞大,所以读源码必须带着问题来读!没有问题,创造问题再来读!否则很容易迷失在无数的方法与属性之中,最后无功而返. 那么,关于ViewPager有什 ...

  5. HashMap 源码详细分析(JDK1.8)

    1. 概述 本篇文章我们来聊聊大家日常开发中常用的一个集合类 - HashMap.HashMap 最早出现在 JDK 1.2中,底层基于散列算法实现.HashMap 允许 null 键和 null 值 ...

  6. vboot源码详细分析-1

    最近一直在研究bootloader之vboot,vboot短小精悍,如果只是用来进行系统的引导,而不要提供其他复杂的功能时候,我认为这是绝佳的上选.这里以MINI2440开发板配套的源码进行分析.这个 ...

  7. 一文读懂Spring动态配置多数据源---源码详细分析

    Spring动态多数据源源码分析及解读 一.为什么要研究Spring动态多数据源 代云小说网 https://www.3187.info ​ 期初,最开始的原因是:想将答题服务中发送主观题答题数据给批 ...

  8. layui源码详细分析系列之富文本编辑器模块

    所谓的富文本编辑器就是内嵌在浏览器上.所见即所得的文本编辑器,它的形式如下: layui框架中内置了layedit模块,该模块就是富文本编辑器模块,在最近两天中我自己使用原生js实现了简易的富文本编辑 ...

  9. HashMap 源码详细分析(JDK1.8) 1

    1.概述 本篇文章我们来聊聊大家日常开发中常用的一个集合类 - HashMap.HashMap 最早出现在 JDK 1.2中,底层基于散列算法实现.HashMap 允许 null 键和 null 值, ...

最新文章

  1. 【转载】MSXML应用总结 开发篇（下）
  2. 震惊！EfficientDet终于开源了！
  3. 提高使用比特币的匿名性
  4. c语言常见错误代码释义,C语言常见错误代码释义解析.doc
  5. MOVSX和MOVZX
  6. 工作笔记-SDRAM的读写
  7. SpringBoot防止重复请求，重复表单提交超级简单的注解实现
  8. 工作流实战_07_flowable 流程定义查看流程图和xml
  9. 拦截地址栏参数_selenium操作chrome时的配置参数
  10. C#中结构体排序方法（Array.sort() + ICompare）
  11. AOP下的权限控制实现
  12. 推荐学习网页标准的20个好去处
  13. linux java bin 安装_linux下安装后缀为bin的Java JDK
  14. eclipse安装反编译插件：jd-eclipse 查看源码
  15. 文本编辑控件FreeTextBoxFCKeditor下载地址
  16. arm tcm linux,认识S3C6410 - 深入理解ARM体系架构（S3C6410）_Linux编程_Linux公社-Linux系统门户网站...
  17. 双十一快件近40亿再创历史新高；疫情挑战下中国受访者对科学的信任度位居全球第一 | 美通企业日报...
  18. Android吃鸡 3dtouch,绝地求生刺激战场3Dtouch怎么用 3Dtouch设置攻略
  19. 软件测试肖sir__010之mysql之总结（8）
  20. 支付宝rsa签名 java_支付宝RSA签名

热门文章

  1. java标志清理_JVM内存管理之GC算法精解（五分钟让你彻底明白标记/清除算法）...
  2. java query接口_「软帝学院」Java零基础学习详解
  3. 大规模的服务器如何管理--批量管理工具
  4. 启动vm虚拟机里的系统时，提示此主机支持 AMD-V，但 AMD-V 处于禁用状态。
  5. 2017-2018-1 20162306 实验五实验报告
  6. sublime Text3 设置多个浏览器预览
  7. 第八章 熟练dom的几个常用方法
  8. 2015-12-15 关于就近日期
  9. libtool: Version mismatch error. 解决方法
  10. 一些Jquery操作