3.数据更新通知的发送过程 在前面这篇文章 Android应用程序组件Content Provider应用实例 介绍的应用程序Acticle中，当调用ArticlesAdapter类的insertArticle往ArticlesProvider中增加一个文章信息条目时： 
        
                
  1.            publicclassArticlesAdapter{     
    2.             
  2.            ......     
    3.             
  3.                 
    4.             
  4.            publiclonginsertArticle(Articlearticle){     
    5.             
  5.            ContentValuesvalues=newContentValues();     
    6.             
  6.            values.put(Articles.TITLE,article.getTitle());     
    7.             
  7.            values.put(Articles.ABSTRACT,article.getAbstract());     
    8.             
  8.            values.put(Articles.URL,article.getUrl());     
    9.             
  9.                 
    10.             
  10.            Uriuri=resolver.insert(Articles.CONTENT_URI,values);     
    11.             
  11.            StringitemId=uri.getPathSegments().get(1);     
    12.             
  12.                 
    13.             
  13.            returnInteger.valueOf(itemId).longValue();     
    14.             
  14.            }     
    15.             
  15.                 
    16.             
  16.            ......     
    17.             
  17.            }     
    18.
便会进入到应用程序ArticlesProvider中的ArticlesProvider类的insert函数中： 
        
                
  1.            publicclassArticlesProviderextendsContentProvider{     
    2.             
  2.            ......     
    3.             
  3.                 
    4.             
  4.            @Override     
    5.             
  5.            publicUriinsert(Uriuri,ContentValuesvalues){     
    6.             
  6.            if(uriMatcher.match(uri)!=Articles.ITEM){     
    7.             
  7.            thrownewIllegalArgumentException("ErrorUri:"+uri);     
    8.             
  8.            }     
    9.             
  9.                 
    10.             
  10.            SQLiteDatabasedb=dbHelper.getWritableDatabase();     
    11.             
  11.                 
    12.             
  12.            longid=db.insert(DB_TABLE,Articles.ID,values);     
    13.             
  13.            if(id<0){     
    14.             
  14.            thrownewSQLiteException("Unabletoinsert"+values+"for"+uri);     
    15.             
  15.            }     
    16.             
  16.                 
    17.             
  17.            UrinewUri=ContentUris.withAppendedId(uri,id);     
    18.             
  18.            resolver.notifyChange(newUri,null);     
    19.             
  19.                 
    20.             
  20.            returnnewUri;     
    21.             
  21.            }     
    22.             
  22.                 
    23.             
  23.            ......     
    24.             
  24.            }     
    25.
从上面传来的参数uri的值为"content://shy.luo.providers.articles/item"。假设当这个函数把数据成功增加到SQLite数据库之后，返回来的id值为n，于是通过调用ContentUris.withAppendedId("content://shy.luo.providers.articles/item", n)得到的newUri的值就为"content://shy.luo.providers.articles/item/n"。这时候就会调用下面语句来通知那些注册了监控"content://shy.luo.providers.articles/item/n"这个URI的ContentObserver，它监控的数据发生变化了： 
        
                
  1.            resolver.notifyChange(newUri,null);     
    2.
下面我们就开始分析这个数据变化通知的发送过程，首先来看一下这个过程的时序图，然后再详细分析每一个步骤：

Step 1. ContentResolver.notifyChange
这个函数定义在frameworks/base/core/java/android/content/ContentResolver.java文件中： 
        
                
  1.            publicabstractclassContentResolver{     
    2.             
  2.            ......     
    3.             
  3.                 
    4.             
  4.            publicvoidnotifyChange(Uriuri,ContentObserverobserver){     
    5.             
  5.            notifyChange(uri,observer,true/*synctonetwork*/);     
    6.             
  6.            }     
    7.             
  7.                 
    8.             
  8.            publicvoidnotifyChange(Uriuri,ContentObserverobserver,booleansyncToNetwork){     
    9.             
  9.            try{     
    10.             
  10.            getContentService().notifyChange(     
    11.             
  11.            uri,observer==null?null:observer.getContentObserver(),     
    12.             
  12.            observer!=null&&observer.deliverSelfNotifications(),syncToNetwork);     
    13.             
  13.            }catch(RemoteExceptione){     
    14.             
  14.            }     
    15.             
  15.            }     
    16.             
  16.                 
    17.             
  17.            ......     
    18.             
  18.            }     
    19.
这里调用了ContentService的远接程口来调用它的notifyChange函数来发送数据更新通知。

Step 2.ContentService.notifyChange 这个函数定义在frameworks/base/core/java/android/content/ContentService.java文件中： 
        
                
  1.            publicfinalclassContentServiceextendsIContentService.Stub{     
    2.             
  2.            ......     
    3.             
  3.                 
    4.             
  4.            publicvoidnotifyChange(Uriuri,IContentObserverobserver,     
    5.             
  5.            booleanobserverWantsSelfNotifications,booleansyncToNetwork){     
    6.             
  6.            ......     
    7.             
  7.                 
    8.             
  8.            try{     
    9.             
  9.            ArrayList<ObserverCall>calls=newArrayList<ObserverCall>();     
    10.             
  10.            synchronized(mRootNode){     
    11.             
  11.            mRootNode.collectObserversLocked(uri,0,observer,observerWantsSelfNotifications,     
    12.             
  12.            calls);     
    13.             
  13.            }     
    14.             
  14.            finalintnumCalls=calls.size();     
    15.             
  15.            for(inti=0;i<numCalls;i++){     
    16.             
  16.            ObserverCalloc=calls.get(i);     
    17.             
  17.            try{     
    18.             
  18.            oc.mObserver.onChange(oc.mSelfNotify);     
    19.             
  19.            ......     
    20.             
  20.            }catch(RemoteExceptionex){     
    21.             
  21.            ......     
    22.             
  22.            }     
    23.             
  23.            }     
    24.             
  24.            ......     
    25.             
  25.            }finally{     
    26.             
  26.            ......     
    27.             
  27.            }     
    28.             
  28.            }     
    29.             
  29.                 
    30.             
  30.            ......     
    31.             
  31.            }     
    32.

这个函数主要做了两件事情，第一件事情是调用ContentService的成员变量mRootNode的collectObserverLocked函数来收集那些注册了监控"content://shy.luo.providers.articles/item/n"这个URI的ContentObserver，第二件事情是分别调用了这些ContentObserver的onChange函数来通知它们监控的数据发生变化了。

Step 3. ObserverNode.collectObserversLocked 这个函数定义在frameworks/base/core/java/android/content/ContentService.java文件中： 
        
                
  1.            publicfinalclassContentServiceextendsIContentService.Stub{     
    2.             
  2.            ......     
    3.             
  3.                 
    4.             
  4.            publicstaticfinalclassObserverNode{     
    5.             
  5.            ......     
    6.             
  6.                 
    7.             
  7.            privatevoidcollectMyObserversLocked(booleanleaf,IContentObserverobserver,     
    8.             
  8.            booleanselfNotify,ArrayList<ObserverCall>calls){     
    9.             
  9.            intN=mObservers.size();     
    10.             
  10.            IBinderobserverBinder=observer==null?null:observer.asBinder();     
    11.             
  11.            for(inti=0;i<N;i++){     
    12.             
  12.            ObserverEntryentry=mObservers.get(i);     
    13.             
  13.                 
    14.             
  14.            //Don'tnotifytheobserverifitsentthenotificationandisn'tinteresed     
    15.             
  15.            //inselfnotifications     
    16.             
  16.            if(entry.observer.asBinder()==observerBinder&&!selfNotify){     
    17.             
  17.            continue;     
    18.             
  18.            }     
    19.             
  19.                 
    20.             
  20.            //Makesuretheobserverisinterestedinthenotification     
    21.             
  21.            if(leaf||(!leaf&&entry.notifyForDescendents)){     
    22.             
  22.            calls.add(newObserverCall(this,entry.observer,selfNotify));     
    23.             
  23.            }     
    24.             
  24.            }     
    25.             
  25.            }     
    26.             
  26.                 
    27.             
  27.            publicvoidcollectObserversLocked(Uriuri,intindex,IContentObserverobserver,     
    28.             
  28.            booleanselfNotify,ArrayList<ObserverCall>calls){     
    29.             
  29.            Stringsegment=null;     
    30.             
  30.            intsegmentCount=countUriSegments(uri);     
    31.             
  31.            if(index>=segmentCount){     
    32.             
  32.            //Thisistheleafnode,notifyallobservers     
    33.             
  33.            collectMyObserversLocked(true,observer,selfNotify,calls);     
    34.             
  34.            }elseif(index<segmentCount){     
    35.             
  35.            segment=getUriSegment(uri,index);     
    36.             
  36.            //Notifyanyobserversatthislevelwhoareinterestedindescendents     
    37.             
  37.            collectMyObserversLocked(false,observer,selfNotify,calls);     
    38.             
  38.            }     
    39.             
  39.                 
    40.             
  40.            intN=mChildren.size();     
    41.             
  41.            for(inti=0;i<N;i++){     
    42.             
  42.            ObserverNodenode=mChildren.get(i);     
    43.             
  43.            if(segment==null||node.mName.equals(segment)){     
    44.             
  44.            //Wefoundthechild,     
    45.             
  45.            node.collectObserversLocked(uri,index+1,observer,selfNotify,calls);     
    46.             
  46.            if(segment!=null){     
    47.             
  47.            break;     
    48.             
  48.            }     
    49.             
  49.            }     
    50.             
  50.            }     
    51.             
  51.            }     
    52.             
  52.            }     
    53.             
  53.            }     
    54.

第一次调用collectObserversLocked时，是在mRootNode的这个ObserverNode节点中进行收集ContentObserver的。这时候传进来的uri的值为"content://shy.luo.providers.articles/item/n"，index的值为0。调用countUriSegments("content://shy.luo.providers.articles/item/n")函数得到的返回值为3，于是就会调用下面语句： 
        
                
  1.            segment=getUriSegment("content://shy.luo.providers.articles/item/n",0);     
    2.             
  2.            //Notifyanyobserversatthislevelwhoareinterestedindescendents     
    3.             
  3.            collectMyObserversLocked(false,observer,selfNotify,calls);     
    4.
这里得到的segment为"shy.luo.providers.articles"。在我们这个情景中，假设mRootNode这个节点中没有注册ContentObserver，于是调用collectMyObserversLocked函数就不会收集到ContentObserver。

在接下来的for循环中，在mRootNode的孩子节点列表mChildren中查找名称等于"shy.luo.providers.articles"的OberverNode节点。在上面分析ContentObserver的注册过程时，我们已经往mRootNode的孩子节点列表mChildren中增加了一个名称为"shy.luo.providers.articles"的OberverNode节点，因此，这里会成功找到它，并且调用它的collectObserversLocked函数来继续收集ContentObserver。 第二次进入到collectObserversLocked函数时，是在名称为"shy.luo.providers.articles"的OberverNode节点中收集ContentObserver的。这时候传来的uri值不变，但是index的值为1，于是执行下面语句： 
        
                
  1.            segment=getUriSegment("content://shy.luo.providers.articles/item/n",1);     
    2.             
  2.            //Notifyanyobserversatthislevelwhoareinterestedindescendents     
    3.             
  3.            collectMyObserversLocked(false,observer,selfNotify,calls);     
    4.

这里得到的segment为"item"。在我们这个情景中，我们没有在名称为"shy.luo.providers.articles"的OberverNode节点中注册有ContentObserver，因此这里调用collectMyObserversLocked函数也不会收集到ContentObserver。

在接下来的for循环中，在名称为"shy.luo.providers.articles"的ObserverNode节点的孩子节点列表mChildren中查找名称等于"item"的OberverNode节点。在上面分析ContentObserver的注册过程时，我们已经往名称为"shy.luo.providers.articles"的ObserverNode节点的孩子节点列表mChildren中增加了一个名称为"item"的OberverNode节点，因此，这里会成功找到它，并且调用它的collectObserversLocked函数来继续收集ContentObserver。 第三次进入到collectObserversLocked函数时，是在名称为"shy.luo.providers.articles"的OberverNode节点的子节点中名称为"item"的ObserverNode节点中收集ContentObserver的。这时候传来的uri值不变，但是index的值为2，于是执行下面语句：
  1. segment=getUriSegment("content://shy.luo.providers.articles/item/n",2);
  2. //Notifyanyobserversatthislevelwhoareinterestedindescendents
  3. collectMyObserversLocked(false,observer,selfNotify,calls);

这里得到的segment为"n"。前面我们已经在名称为"shy.luo.providers.articles"的OberverNode节点的子节点中名称为"item"的ObserverNode节点中注册了一个ContentObserver，即ArticlesObserver，因此这里调用collectMyObserversLocked函数会收集到这个ContentObserver。注意，这次调用collectMyObserversLocked函数时，虽然传进去的参数leaf为false，但是由于我们注册ArticlesObserver时，指定了notifyForDescendents参数为true，因此，这里可以把它收集回来。

在接下来的for循环中，继续在该节点的子节点列表mChildren中查找名称等于"n"的OberverNode节点。在我们这个情景中，不存在这个名称为"n"的子节点了，于是收集ContentObserver的工作就结束了，收集结果是只有一个ContentObserver，即我们在前面注册的ArticlesObserver。 返回到Step2中，调用下面语句来通知相应的ContentObserver，它们监控的数据发生变化了：
  1. for(inti=0;i<numCalls;i++){
  2. ObserverCalloc=calls.get(i);
  3. try{
  4. oc.mObserver.onChange(oc.mSelfNotify);
  5. ......
  6. }catch(RemoteExceptionex){
  7. ......
  8. }
  9. }

前面我们在分析ContentObserver的注册过程的Step3时，介绍到注册到ContentService服务中的ContentObserver是一个在ContentObserver内部定义的一个类Transport的对象的远程接口，于是这里调用这个接口的onChange函数时，就会进入到ContentObserver的内部类Transport的onChange函数中去。

更多相关文章

  1. Android SQLite数据库升级的问题
  2. 使用SharedPreferences存储和读取数据
  3. Android:Content Provider数据共享
  4. android中usb数据通信速率慢问题解决办法
  5. Android sqlite 数据库操作
  6. Android 自定义Listview 如何绑定Sqlite数据库数据
  7. Android的数据存储
  8. Android APN的设置问题 默认“已起用数据” 关闭

随机推荐

  1. Mybatis 配置 自定义缓存 ehcache
  2. C语言复习（二）
  3. ThingJS官方示例（十一）：基于数据矢量及贴图u
  4. 用Python实现手机抓包，获取当当图书差评数
  5. Android(安卓)OTA升级包制作脚本详解（四，生
  6. 使用内存NewSQL数据平台来处理实时数据流
  7. 这款可视化工具也太好用了吧
  8. Android上打包jar并在真机上运行
  9. Python数据可视化：浅谈数据分析岗
  10. 11种数据分析方法，别再说你不会了