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

简介:
  Step 1. ContentResolver.registerContentObserver
        这个函数定义在frameworks/base/core/java/android/content/ContentResolver.java文件中:
 
 
  1. public abstract class ContentResolver {   
  2.     ......   
  3.    
  4.     public final void registerContentObserver(Uri uri, boolean notifyForDescendents,   
  5.         ContentObserver observer)   
  6.     {   
  7.         try {   
  8.             getContentService().registerContentObserver(uri, notifyForDescendents,   
  9.                 observer.getContentObserver());   
  10.         } catch (RemoteException e) {   
  11.         }   
  12.     }   
  13.    
  14.     ......   
  15. }   
      当参数notifyForDescendents为true时,表示要监控所有以uri为前缀的URI对应的数据变化。这个函数做了三件事情,一是调用getContentService函数来获得前面已经启动起来了的ContentService远程接口,二是调用从参数传进来的ContentObserver对象observer的getContentObserver函数来获得一个Binder对象,三是通过调用这个ContentService远程接口的registerContentObserver函数来把这个Binder对象注册到ContentService中去。

 
        Step 2.ContentResolver.getContentService
        这个函数定义在frameworks/base/core/java/android/content/ContentResolver.java文件中:
 
 
  1. public abstract class ContentResolver {   
  2.     ......   
  3.    
  4.     public static IContentService getContentService() {   
  5.         if (sContentService != null) {   
  6.             return sContentService;   
  7.         }   
  8.         IBinder b = ServiceManager.getService(CONTENT_SERVICE_NAME);   
  9.         ......   
  10.         sContentService = IContentService.Stub.asInterface(b);   
  11.         ......   
  12.         return sContentService;   
  13.     }   
  14.    
  15.     private static IContentService sContentService;   
  16.     ......   
  17. }   

        在ContentResolver类中,有一个静态成员变量sContentService,开始时它的值为null。当ContentResolver类的getContentService函数第一次被调用时,它便会通过ServiceManager类的getService函数来获得前面已经启动起来了的ContentService服务的远程接口,然后把它保存在sContentService变量中。这样,当下次ContentResolver类的getContentService函数再次被调用时,就可以直接把这个ContentService远程接口返回给调用者了。

 
        Step 3. ContentObserver.getContentObserver
        这个函数定义在frameworks/base/core/java/android/database/ContentObserver.java文件中:
 
 
  1. public abstract class ContentObserver {   
  2.     ......   
  3.    
  4.     private Transport mTransport;   
  5.    
  6.     ......   
  7.    
  8.     private static final class Transport extends IContentObserver.Stub {   
  9.         ContentObserver mContentObserver;   
  10.    
  11.         public Transport(ContentObserver contentObserver) {   
  12.             mContentObserver = contentObserver;   
  13.         }   
  14.    
  15.         ......   
  16.     }   
  17.    
  18.     ......   
  19.    
  20.     public IContentObserver getContentObserver() {   
  21.         synchronized(lock) {   
  22.             if (mTransport == null) {   
  23.                 mTransport = new Transport(this);   
  24.             }   
  25.             return mTransport;   
  26.         }   
  27.     }   
  28.    
  29.     ......   
  30. }   

        ContentObserver类的getContentObserver函数返回的是一个成员变量mTransport,它的类型为ContentObserver的内部类Transport。从Transport类的定义我们可以知道,它有一个成员变量mContentObserver,用来保存与对应的ContentObserver对象。同时我们还可以看出,ContentObserver类的成员变量mTransport是一个Binder对象,它是要传递给ContentService服务的,以便当ContentObserver所监控的数据发生变化时,ContentService服务可以通过这个Binder对象通知相应的ContentObserver它监控的数据发生变化了。

 
        Step 4. ContentService.registerContentObserver
        这个函数定义在frameworks/base/core/java/android/content/ContentService.java文件中:
 
 
  1. public final class ContentService extends IContentService.Stub {   
  2.     ......   
  3.    
  4.     private final ObserverNode mRootNode = new ObserverNode("");   
  5.    
  6.     ......   
  7.    
  8.     public void registerContentObserver(Uri uri, boolean notifyForDescendents,   
  9.             IContentObserver observer) {   
  10.         ......   
  11.    
  12.         synchronized (mRootNode) {   
  13.             mRootNode.addObserverLocked(uri, observer, notifyForDescendents, mRootNode);   
  14.             ......   
  15.         }   
  16.     }   
  17.    
  18.     ......   
  19. }   

        它调用了ContentService类的成员变量mRootNode的addObserverLocked函数来注册这个ContentObserver对象observer。成员变量mRootNode的类型为ContentService在内部定义的一个类ObserverNode。

 
        Step 5. ObserverNode.addObserverLocked
        这个函数定义在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 String mName;   
  8.         private ArrayList<ObserverNode> mChildren = new ArrayList<ObserverNode>();   
  9.         private ArrayList<ObserverEntry> mObservers = new ArrayList<ObserverEntry>();   
  10.    
  11.         public ObserverNode(String name) {   
  12.             mName = name;   
  13.         }   
  14.    
  15.         private String getUriSegment(Uri uri, int index) {   
  16.             if (uri != null) {   
  17.                 if (index == 0) {   
  18.                     return uri.getAuthority();   
  19.                 } else {   
  20.                     return uri.getPathSegments().get(index - 1);   
  21.                 }   
  22.             } else {   
  23.                 return null;   
  24.             }   
  25.         }   
  26.    
  27.         private int countUriSegments(Uri uri) {   
  28.             if (uri == null) {   
  29.                 return 0;   
  30.             }   
  31.             return uri.getPathSegments().size() + 1;   
  32.         }   
  33.    
  34.         public void addObserverLocked(Uri uri, IContentObserver observer,   
  35.                 boolean notifyForDescendents, Object observersLock) {   
  36.             addObserverLocked(uri, 0, observer, notifyForDescendents, observersLock);   
  37.         }   
  38.    
  39.         private void addObserverLocked(Uri uri, int index, IContentObserver observer,   
  40.                 boolean notifyForDescendents, Object observersLock) {   
  41.             // If this is the leaf node add the observer   
  42.             if (index == countUriSegments(uri)) {   
  43.                 mObservers.add(new ObserverEntry(observer, notifyForDescendents, observersLock));   
  44.                 return;   
  45.             }   
  46.    
  47.             // Look to see if the proper child already exists   
  48.             String segment = getUriSegment(uri, index);   
  49.             if (segment == null) {   
  50.                 throw new IllegalArgumentException("Invalid Uri (" + uri + ") used for observer");   
  51.             }   
  52.             int N = mChildren.size();   
  53.             for (int i = 0; i < N; i++) {   
  54.                 ObserverNode node = mChildren.get(i);   
  55.                 if (node.mName.equals(segment)) {   
  56.                     node.addObserverLocked(uri, index + 1, observer, notifyForDescendents, observersLock);   
  57.                     return;   
  58.                 }   
  59.             }   
  60.    
  61.             // No child found, create one   
  62.             ObserverNode node = new ObserverNode(segment);   
  63.             mChildren.add(node);   
  64.             node.addObserverLocked(uri, index + 1, observer, notifyForDescendents, observersLock);   
  65.         }   
  66.    
  67.         ......   
  68.     }   
  69.    
  70.     ......   
  71. }   

        从这里我们就可以看出,注册到ContentService中的ContentObserver按照树形来组织,树的节点类型为ObserverNode,而树的根节点就为ContentService类的成员变量mRootNode。每一个ObserverNode节点都对应一个名字,它是从URI中解析出来的。

 
        在我们这个情景中,传进来的uri为"content://shy.luo.providers.articles/item",从Step 3调用mRootNode的addObserverLocked函数来往树上增加一个ObserverNode节点时,传进来的参数index的值为0,而调用countUriSegments("content://shy.luo.providers.articles/item")函数的返回值为2,不等于index的值,因此就会往下执行,而通过调用getUriSegment("content://shy.luo.providers.articles/item", 0)函数得到的返回值为"shy.luo.providers.articles"。假设这里是第一次调用树的根节点mRootNode来增加"content://shy.luo.providers.articles/item"这个URI,那么在接下来的for循环中,就不会在mRootNode的孩子节点列表mChildren中找到与名称"shy.luo.providers.articles"对应的ObserverNode,于是就会以"shy.luo.providers.articles"为名称来创建一个新的ObserverNode,并增加到mRootNode的孩子节点列表mChildren中去,并以这个新的ObserverNode来开始新一轮的addObserverLocked函数调用。
        第二次进入到addObserverLocked函数时,countUriSegments("content://shy.luo.providers.articles/item")的值仍为2,而index的值为1,因此就会往下执行,这时候通过调用getUriSegment("content://shy.luo.providers.articles/item", 1)函数得到的返回值为"item"。假设这时候在以"shy.luo.providers.articles/item"为名称的ObserverNode中不存在名称为"item"的孩子节点,于是又会以"item"为名称来创建一个新的ObserverNode,并以这个新的ObserverNode来开始新一轮的addObserverLocked函数调用。
        第三次进入到addObserverLocked函数时,countUriSegments("content://shy.luo.providers.articles/item")的值仍为2,而index的值也为2,因此就会新建一个ObserverEntry对象,并保存在这个以"item"为名称的ObserverNode的ContentObserver列表mObervers中。
        最终我们得到的树形结构如下所示:
        mRootNode("")
            -- ObserverNode("shy.luo.providers.articles")
                --ObserverNode("item") , which has a ContentObserver in mObservers  
       这样,ContentObserver的注册过程就完成了。




本文转自 Luoshengyang 51CTO博客,原文链接:http://blog.51cto.com/shyluo/967018,如需转载请自行联系原作者
目录
相关文章
|
1月前
|
开发框架 前端开发 Android开发
Flutter 与原生模块(Android 和 iOS)之间的通信机制,包括方法调用、事件传递等,分析了通信的必要性、主要方式、数据传递、性能优化及错误处理,并通过实际案例展示了其应用效果,展望了未来的发展趋势
本文深入探讨了 Flutter 与原生模块(Android 和 iOS)之间的通信机制,包括方法调用、事件传递等,分析了通信的必要性、主要方式、数据传递、性能优化及错误处理,并通过实际案例展示了其应用效果,展望了未来的发展趋势。这对于实现高效的跨平台移动应用开发具有重要指导意义。
158 4
|
20天前
|
JSON Java API
探索安卓开发:打造你的首个天气应用
在这篇技术指南中,我们将一起潜入安卓开发的海洋,学习如何从零开始构建一个简单的天气应用。通过这个实践项目,你将掌握安卓开发的核心概念、界面设计、网络编程以及数据解析等技能。无论你是初学者还是有一定基础的开发者,这篇文章都将为你提供一个清晰的路线图和实用的代码示例,帮助你在安卓开发的道路上迈出坚实的一步。让我们一起开始这段旅程,打造属于你自己的第一个安卓应用吧!
45 14
|
23天前
|
Java Linux 数据库
探索安卓开发:打造你的第一款应用
在数字时代的浪潮中,每个人都有机会成为创意的实现者。本文将带你走进安卓开发的奇妙世界,通过浅显易懂的语言和实际代码示例,引导你从零开始构建自己的第一款安卓应用。无论你是编程新手还是希望拓展技术的开发者,这篇文章都将为你打开一扇门,让你的创意和技术一起飞扬。
|
21天前
|
搜索推荐 前端开发 测试技术
打造个性化安卓应用:从设计到开发的全面指南
在这个数字时代,拥有一个定制的移动应用不仅是一种趋势,更是个人或企业品牌的重要延伸。本文将引导你通过一系列简单易懂的步骤,从构思你的应用理念开始,直至实现一个功能齐全的安卓应用。无论你是编程新手还是希望拓展技能的开发者,这篇文章都将为你提供必要的工具和知识,帮助你将创意转化为现实。
|
21天前
|
Java Android开发 开发者
探索安卓开发:构建你的第一个“Hello World”应用
在安卓开发的浩瀚海洋中,每个新手都渴望扬帆起航。本文将作为你的指南针,引领你通过创建一个简单的“Hello World”应用,迈出安卓开发的第一步。我们将一起搭建开发环境、了解基本概念,并编写第一行代码。就像印度圣雄甘地所说:“你必须成为你希望在世界上看到的改变。”让我们一起开始这段旅程,成为我们想要见到的开发者吧!
27 0
|
1月前
|
JSON Java Android开发
探索安卓开发之旅:打造你的第一个天气应用
【10月更文挑战第30天】在这个数字时代,掌握移动应用开发技能无疑是进入IT行业的敲门砖。本文将引导你开启安卓开发的奇妙之旅,通过构建一个简易的天气应用来实践你的编程技能。无论你是初学者还是有一定经验的开发者,这篇文章都将成为你宝贵的学习资源。我们将一步步地深入到安卓开发的世界中,从搭建开发环境到实现核心功能,每个环节都充满了发现和创造的乐趣。让我们开始吧,一起在代码的海洋中航行!
|
1月前
|
存储 搜索推荐 Java
打造个性化安卓应用:从设计到实现
【10月更文挑战第30天】在数字化时代,拥有一个个性化的安卓应用不仅能够提升用户体验,还能加强品牌识别度。本文将引导您了解如何从零开始设计和实现一个安卓应用,涵盖用户界面设计、功能开发和性能优化等关键环节。我们将以一个简单的记事本应用为例,展示如何通过Android Studio工具和Java语言实现基本功能,同时确保应用流畅运行。无论您是初学者还是希望提升现有技能的开发者,这篇文章都将为您提供宝贵的见解和实用的技巧。
|
1月前
|
搜索推荐 开发工具 Android开发
打造个性化Android应用:从设计到实现的旅程
【10月更文挑战第26天】在这个数字时代,拥有一个能够脱颖而出的移动应用是成功的关键。本文将引导您了解如何从概念化阶段出发,通过设计、开发直至发布,一步步构建一个既美观又实用的Android应用。我们将探讨用户体验(UX)设计的重要性,介绍Android开发的核心组件,并通过实际案例展示如何克服开发中的挑战。无论您是初学者还是有经验的开发者,这篇文章都将为您提供宝贵的见解和实用的技巧,帮助您在竞争激烈的应用市场中脱颖而出。
|
1月前
|
算法 Java 数据库
Android 应用的主线程在什么情况下会被阻塞?
【10月更文挑战第20天】为了避免主线程阻塞,我们需要合理地设计和优化应用的代码。将耗时操作移到后台线程执行,使用异步任务、线程池等技术来提高应用的并发处理能力。同时,要注意避免出现死循环、不合理的锁使用等问题。通过这些措施,可以确保主线程能够高效地运行,提供流畅的用户体验。
64 2
|
2月前
|
Java API Android开发
安卓应用程序开发的新手指南:从零开始构建你的第一个应用
【10月更文挑战第20天】在这个数字技术不断进步的时代,掌握移动应用开发技能无疑打开了一扇通往创新世界的大门。对于初学者来说,了解并学习如何从无到有构建一个安卓应用是至关重要的第一步。本文将为你提供一份详尽的入门指南,帮助你理解安卓开发的基础知识,并通过实际示例引导你完成第一个简单的应用项目。无论你是编程新手还是希望扩展你的技能集,这份指南都将是你宝贵的资源。
81 5