前言

最近在项目中涉及到了即时聊天，因此不可避免地要用到实时刷新的功能，因为在以前的项目中见到别人使用CursorLoader+CursorAdapter+ContentProvider的机制来实现实时刷新，于是没有多研究就直接照搬了这个机制，直到后来出现了发送消息后不能更新到界面上的问题，查了很久也查不出原因，于是就想从这个机制本身出发，看看有可能是在哪个环节出了问题。

使用

1.让Activity或Fragment实现LoaderManager.LoaderCallbacks< D >接口

由于我们的数据存储在数据库中，因此这里的泛型应该替换为Cursor 
    这个接口中有三个方法：

// 这个方法在初始化Loader时回调，我们要在这个方法中实例化CursorLoader
public Loader onCreateLoader(int id, Bundle args);
// 加载数据完成后回调到这个方法，我们一般在这里调用CursorAdapter的changeCursor或swapCursor进行界面刷新的操作
public void onLoadFinished(Loader loader, D data);
// 这个方法是在重启Loader时调用，一般可以不管
public void onLoaderReset(Loader loader);

2.创建对应的ContentProvider

@Override
public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {
synchronized (DBLOCK) {
SQLiteDatabase db = WeChatDBManager.getInstance(getContext()).getDatabase();
SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder();
Cursor cursor = null;
switch (sUriMatcher.match(uri)) {
case CODE_CHAT_HISTORY:
queryBuilder.setDistinct(false);
queryBuilder.setTables(uri.getQuery());
cursor = queryBuilder.query(db,
projection,
selection,
selectionArgs,
null,
null,
sortOrder
);
break;
}
// 对查询到的结果集对应的Uri设置观察者
if (cursor != null)
cursor.setNotificationUri(getContext().getContentResolver(), uri);
return cursor;
}
}

@Override
public Uri insert(Uri uri, ContentValues values) {
…
// 通知对应的Uri数据发生改变
getContext().getContentResolver().notifyChange(uri, null);
}

@Override  
public int delete(Uri uri, String selection, String\[\] selectionArgs) {  
    ...  
    // 通知对应的Uri数据发生改变  
    getContext().getContentResolver().notifyChange(uri, null);  
}

@Override  
public int update(Uri uri, ContentValues values, String selection, String\[\] selectionArgs) {  
    ...  
    // 通知对应的Uri数据发生改变  
    getContext().getContentResolver().notifyChange(uri, null);  
}

3.调用getLoaderManager().initLoader(int id, Bundle args, LoaderManager.LoaderCallbacks< D> callback)初始化

原理

1.initLoader

public Loader initLoader(int id, Bundle args, LoaderManager.LoaderCallbacks callback) {
if (mCreatingLoader) {
throw new IllegalStateException("Called while creating a loader");
}

    LoaderInfo info = mLoaders.get(id);

    if (DEBUG) Log.v(TAG, "initLoader in " + this + ": args=" + args);

    if (info == null) {  
        // 创建Loader  
        info = createAndInstallLoader(id, args,  (LoaderManager.LoaderCallbacks<Object>)callback);  
        if (DEBUG) Log.v(TAG, "  Created new loader " + info);  
    } else {  
        if (DEBUG) Log.v(TAG, "  Re-using existing loader " + info);  
        info.mCallbacks = (LoaderManager.LoaderCallbacks<Object>)callback;  
    }

    if (info.mHaveData && mStarted) {  
        // Loader中已经有数据，这里最终会回调到onLoadFinished方法  
        info.callOnLoadFinished(info.mLoader, info.mData);  
    }

  return (Loader<D>)info.mLoader  

}

这里主要关注createAndInstallLoader方法

private LoaderInfo createAndInstallLoader(int id, Bundle args,
LoaderManager.LoaderCallbacks