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

Step 11. CursorWindow.writeToParcel 这个函数定义在frameworks/base/core/java/android/database/CursorWindow.java文件中：

publicclassCursorWindowextendsSQLiteClosableimplementsParcelable{
......
publicvoidwriteToParcel(Parceldest,intflags){
......
dest.writeStrongBinder(native_getBinder());
......
}
......
}

这个函数最主要的操作就是往数据流dest写入一个Binder对象，这个Binder对象是通过调用本地方法native_getBinder来得到的。 Step 12. CursorWindow.native_getBinder 这个函数定义在frameworks/base/core/jni/android_database_CursorWindow.cpp文件中：

staticjobjectnative_getBinder(JNIEnv*env,jobjectobject)
{
CursorWindow*window=GET_WINDOW(env,object);
if(window){
sp<IMemory>memory=window->getMemory();
if(memory!=NULL){
sp<IBinder>binder=memory->asBinder();
returnjavaObjectForIBinder(env,binder);
}
}
returnNULL;
}

在前面的Step 8中，我们在C++层创建了一个CursorWindow对象，这个对象保存在Java层创建的CursorWindow对象的成员变量nWindow中，这里通过GET_WINDOW宏来把这个在C++层创建的CurosrWindow对象返回来：

#defineGET_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文件中：

classCursorWindow
{
public:
......
sp<IMemory>getMemory(){returnmMemory;}
......
}

这个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文件中：

                               abstractpublicclassContentProviderNativeextendsBinderimplementsIContentProvider{     
                       ......     
                            
                       @Override     
                       publicbooleanonTransact(intcode,Parceldata,Parcelreply,intflags)     
                       throwsRemoteException{     
                       try{     
                       switch(code){     
                       caseQUERY_TRANSACTION:     
                       {     
                       data.enforceInterface(IContentProvider.descriptor);     
                            
                       Uriurl=Uri.CREATOR.createFromParcel(data);     
                            
                       //String[]projection     
                       intnum=data.readInt();     
                       String[]projection=null;     
                       if(num>0){     
                       projection=newString[num];     
                       for(inti=0;i<num;i++){     
                       projection[i]=data.readString();     
                       }     
                       }     
                            
                       //Stringselection,String[]selectionArgs...     
                       Stringselection=data.readString();     
                       num=data.readInt();     
                       String[]selectionArgs=null;     
                       if(num>0){     
                       selectionArgs=newString[num];     
                       for(inti=0;i<num;i++){     
                       selectionArgs[i]=data.readString();     
                       }     
                       }     
                            
                       StringsortOrder=data.readString();     
                       IContentObserverobserver=IContentObserver.Stub.     
                       asInterface(data.readStrongBinder());     
                       CursorWindowwindow=CursorWindow.CREATOR.createFromParcel(data);     
                            
                       //Flagforwhethercallerwantsthenumberof     
                       //rowsinthecursorandthepositionofthe     
                       //"_id"columnindex(or-1ifnon-existent)     
                       //Onlytobereturnedifbinder!=null.     
                       booleanwantsCursorMetadata=data.readInt()!=0;     
                            
                       IBulkCursorbulkCursor=bulkQuery(url,projection,selection,     
                       selectionArgs,sortOrder,observer,window);     
                       reply.writeNoException();     
                       if(bulkCursor!=null){     
                       reply.writeStrongBinder(bulkCursor.asBinder());     
                            
                       if(wantsCursorMetadata){     
                       reply.writeInt(bulkCursor.count());     
                       reply.writeInt(BulkCursorToCursorAdaptor.findRowIdColumnIndex(     
                       bulkCursor.getColumnNames()));     
                       }     
                       }else{     
                       reply.writeStrongBinder(null);     
                       }     
                            
                       returntrue;     
                       }     
                       ......     
                       }     
                       }catch(Exceptione){     
                       DatabaseUtils.writeExceptionToParcel(reply,e);     
                       returntrue;     
                       }     
                            
                       returnsuper.onTransact(code,data,reply,flags);     
                       }     
                            
                       ......     
                       }

这一步其实就是前面Step 10的逆操作，把请求参数从数据流data中读取出来。这里我们同样是重点关注下面这两个参数读取的步骤：

CursorWindowwindow=CursorWindow.CREATOR.createFromParcel(data);
//Flagforwhethercallerwantsthenumberof
//rowsinthecursorandthepositionofthe
//"_id"columnindex(or-1ifnon-existent)
//Onlytobereturnedifbinder!=null.
booleanwantsCursorMetadata=data.readInt()!=0;

通过调用CursorWindow.CREATOR.createFromParcel函数来从数据流data中重建一个本地的CursorWindow对象；接着又将数据流data的下一个整数值读取出来，如果这个整数值不为0，变量wantsCursorMetadata的值就为true，说明Content Provider在返回IBulkCursor接口给第三方应用程序之前，要先实际执行一把数据库查询操作，以便把结果数据的元信息返回给第三方应用程序。通过下面的代码我们可以看到，调用bulkQuery函数之后，就得到了一个IBulkCursor接口，这表示要返回的数据准备就绪了，但是这时候实际上还没有把结果数据从数据库中提取出来，而只是准备好了一个SQL查询计划，等到真正要使用这些结果数据时，系统才会真正执行查询数据库的操作:

if(wantsCursorMetadata){
reply.writeInt(bulkCursor.count());
......
}

在将这个IBulkCursor接口返回给第三方应用程序之前，如果发现wantsCursorMetadata的值就为true，就会调用它的count函数来获得结果数据的总行数，这样就会导致系统真正去执行数据库查询操作，并把结果数据保存到前面得到的CursorWindow对象中的匿名共享内存中去。下面我们就重点关注CursorWindow.CREATOR.createFromParcel函数是如何从数据流data中在本地构造一个CursorWindow对象的。 Step 15.CursorWindow.CREATOR.createFromParcel 这个函数定义在frameworks/base/core/java/android/database/CursorWindow.java文件中：

publicclassCursorWindowextendsSQLiteClosableimplementsParcelable{
......
privateCursorWindow(Parcelsource){
IBindernativeBinder=source.readStrongBinder();
......
native_init(nativeBinder);
}
......
publicstaticfinalParcelable.Creator<CursorWindow>CREATOR
=newParcelable.Creator<CursorWindow>(){
publicCursorWindowcreateFromParcel(Parcelsource){
returnnewCursorWindow(source);
}
......
};
......
}

在创建CursorWindow对象的过程中，首先是从数据流source中将在前面Step 10中写入的Binder接口读取出来，然后使用这个Binder接口来初始化这个CursorWindow对象，通过前面的Step 13，我们知道，这个Binder接口的实际类型为IMemory，它封装了对匿名共享内存的访问操作。初始化这个匿名共享内存对象的操作是由本地方法native_init函数来实现的，下面我们就看看它的实现。

更多相关文章

随机推荐