android

Android | ContentProvider 精通篇

2021-02-15  本文已影响0人  彭旭锐

点赞关注，不再迷路，你的支持对我意义重大！

🔥 Hi，我是丑丑。本文 「Android 路线」| 导读 —— 从零到无穷大 已收录，这里有 Android 进阶成长路线笔记 & 博客，欢迎跟着彭丑丑一起成长。（联系方式在 GitHub）

前言

目录

前置知识

这篇文章的内容会涉及以下前置 / 相关知识，贴心的我都帮你准备好了，请享用~

1. ContentResolver#query(...) 源码分析

在上篇文章介绍 ContentResolver 时提到，外界（包括当前进程的其他组件）也无法直接访问 ContentProvider 的，而是需要通过ContentResolver来间接访问，主要分为 3 个步骤：

ContentResolver.java

已简化
public final Cursor query(...) {
    1、获取 IContentProvider 对象
    IContentProvider stableProvider = acquireProvider(uri);

    2、调用 ContentProvider#query(...) 查询
    Cursor qCursor = stableProvider.query(mPackageName, uri, projection, queryArgs, remoteCancellationSignal);
    
    3、返回 Cursor
    return qCursor ;
}

不仅仅是 query(...) 方法，通过 ContentResolver 的四个方法（insert、delete、update、query）都会先获取 IContentProvider 对象（步骤 1）。如果 ContentProvider 所在进程还未启动，还会触发该进程启动，相应的也会伴随着 ContentProvider 的启动。这一点我在 第 2 节 ConentProvider 的启动过程 会详细介绍 。

现在，我们先分析 ContentResolver#query(...) 的源码：

1.1 获取 IContentProvider 对象

源码中 ContentResolver#acquireProvider() 是抽象方法，具体实现在子类 ApplicationContentResolver 中，源码位于 ContextImpl 内部：

ContextImpl.java

内部类 ApplicationContentResolver：

-> 1、获取 IContentProvider 对象
@Override
protected IContentProvider acquireProvider(Context context, String auth) {
    转发给 ActivityThread
    return mMainThread.acquireProvider(context, ContentProvider.getAuthorityWithoutUserId(auth),
        resolveUserIdFromAuthority(auth), true);
}

ActivityThread.java

public final IContentProvider acquireProvider (Context c, String auth, int userId, boolean stable) {

    1.1 在 ActivityThread 中查找目标 IContentProvider 对象
    final IContentProvider provider = acquireExistingProvider(c, auth, userId, stable);
    if (provider != null) {
        return provider;
    }

    1.2 进程间调用 AMS 启动目标 ContentProvider（实际上是启动对应的进程）
    ContentProviderHolder holder = null;
    synchronized (getGetProviderLock(auth, userId)) {
        holder = ActivityManager.getService().getContentProvider(
            getApplicationThread(), auth, userId, stable);
        }

    1.3 记录 IContentProvider 对象，并修改引用计数
    holder = installProvider(c, holder, holder.info,
        true /*noisy*/, holder.noReleaseNeeded, stable);
    return holder.provider;
}

ActivityThread.java

-> 1.1 在 ActivityThread 中查找目标 IContentProvider 对象（已简化）
public final IContentProvider acquireExistingProvider(Context c, String auth, int userId, boolean stable) {
    synchronized (mProviderMap) {

        1.1.1 查找目标 IContentProvider 对象
        final ProviderKey key = new ProviderKey(auth, userId);
        final ProviderClientRecord pr = mProviderMap.get(key);
        if (pr == null) {
            return null;
        }

        1.1.2 增加引用计数
        IContentProvider provider = pr.mProvider;
        IBinder jBinder = provider.asBinder();
        ProviderRefCount prc = mProviderRefCountMap.get(jBinder);
        incProviderRefLocked(prc, stable);
        return provider;
    }
}

由以上源码可知，获取 IContentProvider 对象的过程主要分为以下步骤：

final ArrayMap<ProviderKey, ProviderClientRecord> mProviderMap = new ArrayMap<ProviderKey, ProviderClientRecord>();
final ArrayMap<IBinder, ProviderRefCount> mProviderRefCountMap = new ArrayMap<IBinder, ProviderRefCount>();
final ArrayMap<IBinder, ProviderClientRecord> mLocalProviders = new ArrayMap<IBinder, ProviderClientRecord>();

3.2 调用 IContentProvider#query(...) 查询

todo

2. ContentProvider 的启动过程

众所周知，ActivityThread#main() 是应用进程的入口方法，在 main 方法中会启动主线程的消息循环，然后在 ActivityThread#attach() 中会远程调用 AMS#attachApplication()，以将 ApplicationThread 对象提供给 AMS。

ApplicationThread 是 IApplicationThread 接口的 Binder 对象，主要用于 ActivityThread 和 AMS 之间的进程间通讯。在 AMS#attachApplication() 中会跨进程调用 ApplicationThread#bindApplication()，其中通过 ActivityThread 中的 Handler mH 分发到 handlerBindApplication()。

整个过程的关键节点浓缩为下图：

ActivityThread.java

private void handleBindApplication(AppBindData data) {
    // ...
    1、实例化 Application 对象
    Application app;
    app = data.info.makeApplication(data.restrictedBackupMode, null);
    mInitialApplication = app;

    2、初始化所有 ContentProvider
    installContentProviders(app, data.providers);

    3、调用 Application#onCreate()
    mInstrumentation.callApplicationOnCreate(app);
    ...
}

-> 1、实例化 Application 对象
public Application makeApplication(boolean forceDefaultAppClass,
            Instrumentation instrumentation) {
    ...
    1.1 Context 基础对象
    ContextImpl appContext = ContextImpl.createAppContext(mActivityThread, this);

    1.2 实例化，内部会调用 Context#attachBaseContext(...)
    app = mActivityThread.mInstrumentation.newApplication(cl, appClass, appContext);

    1.3 Context 基础对象持有代理类
    appContext.setOuterContext(app);
    ...
}

-> 2、初始化所有 ContentProvider
private void installContentProviders(Context context, List<ProviderInfo> providers) {
    final ArrayList<ContentProviderHolder> results = new ArrayList<>();

    for (ProviderInfo cpi : providers) {
        依次初始化 ContentProvider
        ContentProviderHolder cph = installProvider(context, null, cpi,
                false /*noisy*/, true /*noReleaseNeeded*/, true /*stable*/);
        if (cph != null) {
            cph.noReleaseNeeded = true;
            results.add(cph);
        }
    }
    // ...
}

关键结论：

Context#attachBaseContext() -> ContentProvider#onCreate() -> Application#onCreate()

创作不易，你的「三连」是丑丑最大的动力，我们下次见！

上一篇下一篇

猜你喜欢

热点阅读