ThinkChat🤖让你学习和工作更高效,注册即送10W Token,即刻开启你的AI之旅 广告
数据更新的通知由ContentResolver的notifyChange函数触发。看MediaProvider的update函数的代码如下: **MediaProvider.java::update** ~~~ public int update(Uri uri, ContentValuesinitialValues, String userWhere, String[] whereArgs) { int count; int match= URI_MATCHER.match(uri); DatabaseHelper database = getDatabaseForUri(uri); //找到对应的数据库对象 SQLiteDatabase db = database.getWritableDatabase(); ...... synchronized (sGetTableAndWhereParam) { getTableAndWhere(uri, match, userWhere, sGetTableAndWhereParam); switch(match) { ...... case VIDEO_MEDIA: case VIDEO_MEDIA_ID:{ ContentValues values = newContentValues(initialValues); values.remove(ImageColumns.BUCKET_ID); values.remove(ImageColumns.BUCKET_DISPLAY_NAME); ......//调用SQLiteDatabase的update函数更新数据库 count =db.update(sGetTableAndWhereParam.table, values, sGetTableAndWhereParam.where, whereArgs); ....... }......//其他处理 }......//synchronized处理结束 if (count > 0 &&!db.inTransaction()) //调用notifyChange触发通知 getContext().getContentResolver().notifyChange(uri,null); returncount; } ~~~ 由以上代码可知,MediaProvider update函数更新完数据库后,将通过notfiyChange函数来通知观察者。notfiyChange函数的代码如下: **ContentResolver.java::notifyChange** ~~~ public void notifyChange(Uri uri, ContentObserverobserver) { //在一般情况下,observer参数为null。调用另一个notifyChange函数,直接来看它 notifyChange(uri, observer, true); } public void notifyChange(Uri uri, ContentObserverobserver, boolean syncToNetwork) { //第三个参数syncToNetwork用于控制是否需要发起一次数据同步请求 try { //调用ContentService的notifyChange函数 getContentService().notifyChange( uri, observer == null ? null : observer.getContentObserver(), observer != null && observer.deliverSelfNotifications(), syncToNetwork); } ...... } ~~~ 由以上代码可知,ContentService的notifyChange函数将被调用,其代码如下: **ContentSerivce::notifyChange** ~~~ public void notifyChange(Uri uri, IContentObserverobserver, boolean observerWantsSelfNotifications, boolean syncToNetwork) { longidentityToken = clearCallingIdentity(); try { ArrayList<ObserverCall> calls = newArrayList<ObserverCall>(); //从根节点开始搜索需要通知的观察者,结果保存在calls数组中 synchronized (mRootNode) { mRootNode.collectObserversLocked(uri, 0, observer, observerWantsSelfNotifications,calls); } final int numCalls = calls.size(); for(int i=0; i<numCalls; i++) { ObserverCall oc = calls.get(i); try { /* 调用客户端IContentObserver Bn端,即ContentObserver 内部类Transport的onChange函数。最后再由Transport调用 客户端提供的ContentObserver子类的onChange函数 */ oc.mObserver.onChange(oc.mSelfNotify); } ......//异常处理 } if (syncToNetwork) { SyncManager syncManager = getSyncManager(); if (syncManager != null) { //发起一次同步请求,相关内容留待8.4节再分析 syncManager.scheduleLocalSync(null, uri.getAuthority()); } } }finally { restoreCallingIdentity(identityToken); } } ~~~