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. }   

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. }   

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. }   

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. }   

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. }   

本文转自 Luoshengyang 51CTO博客，原文链接：http://blog.51cto.com/shyluo/967018，如需转载请自行联系原作者