Android应用程序组件Content Provider在应用程序之间共享数据的原理分析(3)-阿里云开发者社区

开发者社区> 开发与运维> 正文
登录阅读全文

Android应用程序组件Content Provider在应用程序之间共享数据的原理分析(3)

简介:
  Step 11. CursorWindow.writeToParcel
      这个函数定义在frameworks/base/core/java/android/database/CursorWindow.java文件中:
  1. public class CursorWindow extends SQLiteClosable implements Parcelable {  
  2.     ......  
  3.   
  4.     public void writeToParcel(Parcel dest, int flags) {  
  5.         ......  
  6.         dest.writeStrongBinder(native_getBinder());  
  7.         ......  
  8.     }  
  9.   
  10.     ......  
  11. }  
      这个函数最主要的操作就是往数据流dest写入一个Binder对象,这个Binder对象是通过调用本地方法native_getBinder来得到的。
 
      Step 12. CursorWindow.native_getBinder
      这个函数定义在frameworks/base/core/jni/android_database_CursorWindow.cpp文件中:
  1. static jobject native_getBinder(JNIEnv * env, jobject object)  
  2. {  
  3.     CursorWindow * window = GET_WINDOW(env, object);  
  4.     if (window) {  
  5.         sp<IMemory> memory = window->getMemory();  
  6.         if (memory != NULL) {  
  7.             sp<IBinder> binder = memory->asBinder();  
  8.             return javaObjectForIBinder(env, binder);  
  9.         }  
  10.     }  
  11.     return NULL;  
  12. }  
      在前面的Step 8中,我们在C++层创建了一个CursorWindow对象,这个对象保存在Java层创建的CursorWindow对象的成员变量nWindow中,这里通过GET_WINDOW宏来把这个在C++层创建的CurosrWindow对象返回来:
 
  1. #define GET_WINDOW(env, object) ((CursorWindow *)env->GetIntField(object, gWindowField))  
      获得了这个CursorWindow对象以后,就调用它的getMemory函数来获得一个IMemory接口,这是一个Binder接口,具体可以参考前面一篇文章Android系统匿名共享内存(Anonymous Shared Memory)C++调用接口分析
 
      Step 13. CursorWindow.getMemory
      这个函数定义在frameworks/base/core/jni/CursorWindow.h文件中:
  1. class CursorWindow  
  2. {  
  3. public:  
  4.     ......  
  5.   
  6.     sp<IMemory>         getMemory() {return mMemory;}  
  7.   
  8.     ......  
  9. }  
      这个CursorWindow对象的成员变量mMemory就是在前面Step 9中创建的了。
 
      这样,在第三方应用程序这一侧创建的匿名共享存对象就可以传递给Content Provider来使用了。回到前面的Step 10中,所有的参数都就准备就绪以后,就通过Binder进程间通信机制把数据查询请求发送给相应的Content Proivder了。这个请求是在ContentProviderNative类的onTransact函数中响应的。
      Step 14. ContentProviderNative.onTransact
      这个函数定义在frameworks/base/core/java/android/content/ContentProviderNative.java文件中:

  1. abstract public class ContentProviderNative extends Binder implements IContentProvider {   
  2.     ......   
  3.    
  4.     @Override   
  5.     public boolean onTransact(int code, Parcel data, Parcel reply, int flags)   
  6.     throws RemoteException {   
  7.         try {   
  8.             switch (code) {   
  9.             case QUERY_TRANSACTION:   
  10.                 {   
  11.                     data.enforceInterface(IContentProvider.descriptor);   
  12.    
  13.                     Uri url = Uri.CREATOR.createFromParcel(data);   
  14.    
  15.                     // String[] projection   
  16.                     int num = data.readInt();   
  17.                     String[] projection = null;   
  18.                     if (num > 0) {   
  19.                         projection = new String[num];   
  20.                         for (int i = 0; i < num; i++) {   
  21.                             projection[i] = data.readString();   
  22.                         }   
  23.                     }   
  24.    
  25.                     // String selection, String[] selectionArgs...   
  26.                     String selection = data.readString();   
  27.                     num = data.readInt();   
  28.                     String[] selectionArgs = null;   
  29.                     if (num > 0) {   
  30.                         selectionArgs = new String[num];   
  31.                         for (int i = 0; i < num; i++) {   
  32.                             selectionArgs[i] = data.readString();   
  33.                         }   
  34.                     }   
  35.    
  36.                     String sortOrder = data.readString();   
  37.                     IContentObserver observer = IContentObserver.Stub.   
  38.                         asInterface(data.readStrongBinder());   
  39.                     CursorWindow window = CursorWindow.CREATOR.createFromParcel(data);   
  40.    
  41.                     // Flag for whether caller wants the number of   
  42.                     // rows in the cursor and the position of the   
  43.                     // "_id" column index (or -1 if non-existent)   
  44.                     // Only to be returned if binder != null.   
  45.                     boolean wantsCursorMetadata = data.readInt() != 0;   
  46.    
  47.                     IBulkCursor bulkCursor = bulkQuery(url, projection, selection,   
  48.                         selectionArgs, sortOrder, observer, window);   
  49.                     reply.writeNoException();   
  50.                     if (bulkCursor != null) {   
  51.                         reply.writeStrongBinder(bulkCursor.asBinder());   
  52.    
  53.                         if (wantsCursorMetadata) {   
  54.                             reply.writeInt(bulkCursor.count());   
  55.                             reply.writeInt(BulkCursorToCursorAdaptor.findRowIdColumnIndex(   
  56.                                 bulkCursor.getColumnNames()));   
  57.                         }   
  58.                     } else {   
  59.                         reply.writeStrongBinder(null);   
  60.                     }   
  61.    
  62.                     return true;   
  63.                 }   
  64.             ......   
  65.             }   
  66.         } catch (Exception e) {   
  67.             DatabaseUtils.writeExceptionToParcel(reply, e);   
  68.             return true;   
  69.         }   
  70.    
  71.         return super.onTransact(code, data, reply, flags);   
  72.     }   
  73.    
  74.     ......   
  75. }   
     这一步其实就是前面Step 10的逆操作,把请求参数从数据流data中读取出来。这里我们同样是重点关注下面这两个参数读取的步骤: 
  1. CursorWindow window = CursorWindow.CREATOR.createFromParcel(data);  
  2.   
  3. // Flag for whether caller wants the number of  
  4. // rows in the cursor and the position of the  
  5. // "_id" column index (or -1 if non-existent)  
  6. // Only to be returned if binder != null.  
  7. boolean wantsCursorMetadata = data.readInt() != 0;  
      通过调用CursorWindow.CREATOR.createFromParcel函数来从数据流data中重建一个本地的CursorWindow对象;接着又将数据流data的下一个整数值读取出来,如果这个整数值不为0,变量wantsCursorMetadata的值就为true,说明Content Provider在返回IBulkCursor接口给第三方应用程序之前,要先实际执行一把数据库查询操作,以便把结果数据的元信息返回给第三方应用程序。
 
      通过下面的代码我们可以看到,调用bulkQuery函数之后,就得到了一个IBulkCursor接口,这表示要返回的数据准备就绪了,但是这时候实际上还没有把结果数据从数据库中提取出来,而只是准备好了一个SQL查询计划,等到真正要使用这些结果数据时,系统才会真正执行查询数据库的操作:
  1. if (wantsCursorMetadata) {  
  2.     reply.writeInt(bulkCursor.count());  
  3.     ......  
  4. }  
      在将这个IBulkCursor接口返回给第三方应用程序之前,如果发现wantsCursorMetadata的值就为true,就会调用它的count函数来获得结果数据的总行数,这样就会导致系统真正去执行数据库查询操作,并把结果数据保存到前面得到的CursorWindow对象中的匿名共享内存中去。
 
      下面我们就重点关注CursorWindow.CREATOR.createFromParcel函数是如何从数据流data中在本地构造一个CursorWindow对象的。
      Step 15. CursorWindow.CREATOR.createFromParcel
      这个函数定义在frameworks/base/core/java/android/database/CursorWindow.java文件中:
  1. public class CursorWindow extends SQLiteClosable implements Parcelable {  
  2.     ......  
  3.   
  4.     private CursorWindow(Parcel source) {  
  5.         IBinder nativeBinder = source.readStrongBinder();  
  6.         ......  
  7.   
  8.         native_init(nativeBinder);  
  9.     }  
  10.   
  11.     ......  
  12.   
  13.     public static final Parcelable.Creator<CursorWindow> CREATOR  
  14.             = new Parcelable.Creator<CursorWindow>() {  
  15.         public CursorWindow createFromParcel(Parcel source) {  
  16.             return new CursorWindow(source);  
  17.         }  
  18.   
  19.         ......  
  20.     };  
  21.   
  22.     ......  
  23. }  
      在创建CursorWindow对象的过程中,首先是从数据流source中将在前面Step 10中写入的Binder接口读取出来,然后使用这个Binder接口来初始化这个CursorWindow对象,通过前面的Step 13,我们知道,这个Binder接口的实际类型为IMemory,它封装了对匿名共享内存的访问操作。初始化这个匿名共享内存对象的操作是由本地方法native_init函数来实现的,下面我们就看看它的实现。 




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

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章