Android应用程序组件Content Provider的共享数据更新通知机制分析(3)

简介:
     3. 数据更新通知的发送过程
       在前面这篇文章 Android应用程序组件Content Provider应用实例 介绍的应用程序Acticle中,当调用ArticlesAdapter类的insertArticle往ArticlesProvider中增加一个文章信息条目时:

  
  
  1. public class ArticlesAdapter {   
  2.     ......   
  3.    
  4.     public long insertArticle(Article article) {   
  5.         ContentValues values = new ContentValues();   
  6.         values.put(Articles.TITLE, article.getTitle());   
  7.         values.put(Articles.ABSTRACT, article.getAbstract());   
  8.         values.put(Articles.URL, article.getUrl());   
  9.    
  10.         Uri uri = resolver.insert(Articles.CONTENT_URI, values);   
  11.         String itemId = uri.getPathSegments().get(1);   
  12.    
  13.         return Integer.valueOf(itemId).longValue();   
  14.     }   
  15.    
  16.     ......   
  17. }   
便会进入到应用程序ArticlesProvider中的ArticlesProvider类的insert函数中:

  
  
  1. public class ArticlesProvider extends ContentProvider {   
  2.     ......   
  3.    
  4.     @Override   
  5.     public Uri insert(Uri uri, ContentValues values) {   
  6.         if(uriMatcher.match(uri) != Articles.ITEM) {   
  7.             throw new IllegalArgumentException("Error Uri: " + uri);   
  8.         }   
  9.    
  10.         SQLiteDatabase db = dbHelper.getWritableDatabase();   
  11.    
  12.         long id = db.insert(DB_TABLE, Articles.ID, values);   
  13.         if(id < 0) {   
  14.             throw new SQLiteException("Unable to insert " + values + " for " + uri);   
  15.         }   
  16.    
  17.         Uri newUri = ContentUris.withAppendedId(uri, id);   
  18.         resolver.notifyChange(newUri, null);   
  19.    
  20.         return newUri;   
  21.     }   
  22.    
  23.     ......   
  24. }   
        从上面传来的参数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);   
    下面我们就开始分析这个数据变化通知的发送过程,首先来看一下这个过程的时序图,然后再详细分析每一个步骤:

 

 
 Step 1. ContentResolver.notifyChange
        这个函数定义在frameworks/base/core/java/android/content/ContentResolver.java文件中:

  
  
  1. public abstract class ContentResolver {   
  2.     ......   
  3.    
  4.     public void notifyChange(Uri uri, ContentObserver observer) {   
  5.         notifyChange(uri, observer, true /* sync to network */);   
  6.     }   
  7.    
  8.     public void notifyChange(Uri uri, ContentObserver observer, boolean syncToNetwork) {   
  9.         try {   
  10.             getContentService().notifyChange(   
  11.                 uri, observer == null ? null : observer.getContentObserver(),   
  12.                 observer != null && observer.deliverSelfNotifications(), syncToNetwork);   
  13.         } catch (RemoteException e) {   
  14.         }   
  15.     }   
  16.    
  17.     ......   
  18. }   
    这里调用了ContentService的远接程口来调用它的notifyChange函数来发送数据更新通知。

 
        Step 2. ContentService.notifyChange
        这个函数定义在frameworks/base/core/java/android/content/ContentService.java文件中:

  
  
  1. public final class ContentService extends IContentService.Stub {   
  2.     ......   
  3.    
  4.     public void notifyChange(Uri uri, IContentObserver observer,   
  5.             boolean observerWantsSelfNotifications, boolean syncToNetwork) {   
  6.         ......   
  7.    
  8.         try {   
  9.             ArrayList<ObserverCall> calls = new ArrayList<ObserverCall>();   
  10.             synchronized (mRootNode) {   
  11.                 mRootNode.collectObserversLocked(uri, 0, observer, observerWantsSelfNotifications,   
  12.                     calls);   
  13.             }   
  14.             final int numCalls = calls.size();   
  15.             for (int i=0; i<numCalls; i++) {   
  16.                 ObserverCall oc = calls.get(i);   
  17.                 try {   
  18.                     oc.mObserver.onChange(oc.mSelfNotify);   
  19.                     ......   
  20.                 } catch (RemoteException ex) {   
  21.                     ......   
  22.                 }   
  23.             }   
  24.             ......   
  25.         } finally {   
  26.             ......   
  27.         }   
  28.     }   
  29.    
  30.     ......   
  31. }   

        这个函数主要做了两件事情,第一件事情是调用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. public final class ContentService extends IContentService.Stub {   
  2.     ......   
  3.    
  4.     public static final class ObserverNode {   
  5.         ......   
  6.    
  7.         private void collectMyObserversLocked(boolean leaf, IContentObserver observer,   
  8.                 boolean selfNotify, ArrayList<ObserverCall> calls) {   
  9.             int N = mObservers.size();   
  10.             IBinder observerBinder = observer == null ? null : observer.asBinder();   
  11.             for (int i = 0; i < N; i++) {   
  12.                 ObserverEntry entry = mObservers.get(i);   
  13.    
  14.                 // Don't notify the observer if it sent the notification and isn't interesed   
  15.                 // in self notifications   
  16.                 if (entry.observer.asBinder() == observerBinder && !selfNotify) {   
  17.                     continue;   
  18.                 }   
  19.    
  20.                 // Make sure the observer is interested in the notification   
  21.                 if (leaf || (!leaf && entry.notifyForDescendents)) {   
  22.                     calls.add(new ObserverCall(this, entry.observer, selfNotify));   
  23.                 }   
  24.             }   
  25.         }   
  26.    
  27.         public void collectObserversLocked(Uri uri, int index, IContentObserver observer,   
  28.                 boolean selfNotify, ArrayList<ObserverCall> calls) {   
  29.             String segment = null;   
  30.             int segmentCount = countUriSegments(uri);   
  31.             if (index >= segmentCount) {   
  32.                 // This is the leaf node, notify all observers   
  33.                 collectMyObserversLocked(true, observer, selfNotify, calls);   
  34.             } else if (index < segmentCount){   
  35.                 segment = getUriSegment(uri, index);   
  36.                 // Notify any observers at this level who are interested in descendents   
  37.                 collectMyObserversLocked(false, observer, selfNotify, calls);   
  38.             }   
  39.    
  40.             int N = mChildren.size();   
  41.             for (int i = 0; i < N; i++) {   
  42.                 ObserverNode node = mChildren.get(i);   
  43.                 if (segment == null || node.mName.equals(segment)) {   
  44.                     // We found the child,   
  45.                     node.collectObserversLocked(uri, index + 1, observer, selfNotify, calls);   
  46.                     if (segment != null) {   
  47.                         break;   
  48.                     }   
  49.                 }   
  50.             }   
  51.         }   
  52.     }   
  53. }   

        第一次调用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. // Notify any observers at this level who are interested in descendents   
  3. collectMyObserversLocked(false, observer, selfNotify, calls);   
        这里得到的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. // Notify any observers at this level who are interested in descendents   
  3. collectMyObserversLocked(false, observer, selfNotify, calls);   

        这里得到的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. // Notify any observers at this level who are interested in descendents  
  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。
        返回到Step 2中,调用下面语句来通知相应的ContentObserver,它们监控的数据发生变化了:
  1. for (int i=0; i<numCalls; i++) {  
  2.     ObserverCall oc = calls.get(i);  
  3.     try {  
  4.         oc.mObserver.onChange(oc.mSelfNotify);  
  5.         ......  
  6.     } catch (RemoteException ex) {  
  7.         ......  
  8.     }  
  9. }  

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




本文转自 Luoshengyang 51CTO博客,原文链接:http://blog.51cto.com/shyluo/967021,如需转载请自行联系原作者
目录
相关文章
|
1月前
|
开发框架 前端开发 Android开发
Flutter 与原生模块(Android 和 iOS)之间的通信机制,包括方法调用、事件传递等,分析了通信的必要性、主要方式、数据传递、性能优化及错误处理,并通过实际案例展示了其应用效果,展望了未来的发展趋势
本文深入探讨了 Flutter 与原生模块(Android 和 iOS)之间的通信机制,包括方法调用、事件传递等,分析了通信的必要性、主要方式、数据传递、性能优化及错误处理,并通过实际案例展示了其应用效果,展望了未来的发展趋势。这对于实现高效的跨平台移动应用开发具有重要指导意义。
166 4
|
23天前
|
JSON Java API
探索安卓开发:打造你的首个天气应用
在这篇技术指南中,我们将一起潜入安卓开发的海洋,学习如何从零开始构建一个简单的天气应用。通过这个实践项目,你将掌握安卓开发的核心概念、界面设计、网络编程以及数据解析等技能。无论你是初学者还是有一定基础的开发者,这篇文章都将为你提供一个清晰的路线图和实用的代码示例,帮助你在安卓开发的道路上迈出坚实的一步。让我们一起开始这段旅程,打造属于你自己的第一个安卓应用吧!
50 14
|
26天前
|
Java Linux 数据库
探索安卓开发:打造你的第一款应用
在数字时代的浪潮中,每个人都有机会成为创意的实现者。本文将带你走进安卓开发的奇妙世界,通过浅显易懂的语言和实际代码示例,引导你从零开始构建自己的第一款安卓应用。无论你是编程新手还是希望拓展技术的开发者,这篇文章都将为你打开一扇门,让你的创意和技术一起飞扬。
|
27天前
|
Java 开发工具 Android开发
安卓与iOS开发环境对比分析
在移动应用开发的广阔天地中,安卓和iOS两大平台各自占据半壁江山。本文深入探讨了这两个平台的开发环境,从编程语言、开发工具到用户界面设计等多个角度进行比较。通过实际案例分析和代码示例,我们旨在为开发者提供一个清晰的指南,帮助他们根据项目需求和个人偏好做出明智的选择。无论你是初涉移动开发领域的新手,还是寻求跨平台解决方案的资深开发者,这篇文章都将为你提供宝贵的信息和启示。
30 8
|
24天前
|
搜索推荐 前端开发 测试技术
打造个性化安卓应用:从设计到开发的全面指南
在这个数字时代,拥有一个定制的移动应用不仅是一种趋势,更是个人或企业品牌的重要延伸。本文将引导你通过一系列简单易懂的步骤,从构思你的应用理念开始,直至实现一个功能齐全的安卓应用。无论你是编程新手还是希望拓展技能的开发者,这篇文章都将为你提供必要的工具和知识,帮助你将创意转化为现实。
|
1月前
|
安全 Android开发 数据安全/隐私保护
深入探索Android与iOS系统安全性的对比分析
在当今数字化时代,移动操作系统的安全已成为用户和开发者共同关注的重点。本文旨在通过比较Android与iOS两大主流操作系统在安全性方面的差异,揭示两者在设计理念、权限管理、应用审核机制等方面的不同之处。我们将探讨这些差异如何影响用户的安全体验以及可能带来的风险。
39 1
|
24天前
|
Java Android开发 开发者
探索安卓开发:构建你的第一个“Hello World”应用
在安卓开发的浩瀚海洋中,每个新手都渴望扬帆起航。本文将作为你的指南针,引领你通过创建一个简单的“Hello World”应用,迈出安卓开发的第一步。我们将一起搭建开发环境、了解基本概念,并编写第一行代码。就像印度圣雄甘地所说:“你必须成为你希望在世界上看到的改变。”让我们一起开始这段旅程,成为我们想要见到的开发者吧!
32 0
|
2月前
|
数据可视化 Android开发 开发者
安卓应用开发中的自定义View组件
【10月更文挑战第5天】在安卓应用开发中,自定义View组件是提升用户交互体验的利器。本篇将深入探讨如何从零开始创建自定义View,包括设计理念、实现步骤以及性能优化技巧,帮助开发者打造流畅且富有创意的用户界面。
107 0
|
2月前
|
XML 前端开发 Java
安卓应用开发中的自定义View组件
【10月更文挑战第5天】自定义View是安卓应用开发的一块基石,它为开发者提供了无限的可能。通过掌握其原理和实现方法,可以创造出既美观又实用的用户界面。本文将引导你了解自定义View的创建过程,包括绘制技巧、事件处理以及性能优化等关键步骤。
|
3月前
|
缓存 搜索推荐 Android开发
安卓应用开发中的自定义View组件实践
【9月更文挑战第10天】在安卓开发领域,自定义View是提升用户体验和实现界面个性化的重要手段。本文将通过一个实际案例,展示如何在安卓项目中创建和使用自定义View组件,包括设计思路、实现步骤以及可能遇到的问题和解决方案。文章不仅提供了代码示例,还深入探讨了自定义View的性能优化技巧,旨在帮助开发者更好地掌握这一技能。