在回答上一节的问题之前,不知读者思考过下面的问题:实现文件描述符跨进程传递的目的是什么?
以上节所示读取音乐专辑的缩略图为例,问题的答案就是,让客户端能够读取专辑的缩略图文件。为什么客户端不先获得对应专辑缩略图的文件存储路径,然后直接打开这个文件,却要如此大费周章呢?原因有二:
- 出于安全的考虑,MediaProvider不希望客户端绕过它去直接读取存储设备上的文件。另外,客户端须额外声明相关的存储设备读写权限,然后才能直接读取其上面的文件。
- 虽然本例针对的是一个实际文件,但是从可扩展性角度看,我们希望客户端使用一个更通用的接口,通过这个接口可读取实际文件的数据,也可读取来自的网络的数据,而作为该接口的使用者无需关心数据到底从何而来。
* * * * *
**提示**:实际上还有更多的原因,读者不妨尝试在以上两点原因的基础上拓展思考。
* * * * *
1. 序列化ParcelFileDescriptor
好了,继续讨论本例的情况。现在服务端已经打开了某个缩略图文件,并且获得了一个文件描述符对象FileDescriptor。这个文件是服务端打开的。如何让客户端也打开这个文件呢?各据前文分析,客户端不会也不应该通过文件路径自己去打开这个文件。那该如何处理?
没关系,Binder驱动支持跨进程传递文件描述符。先来看ParcelFileDescriptor的序列化函数writeToParcel,代码如下:
**ParcelFileDescriptor.java::writeToParcel**
~~~
public void writeToParcel(Parcel out, int flags) {
//往Parcel包中直接写入mFileDescriptor指向的FileDescriptor对象
out.writeFileDescriptor(mFileDescriptor);
if((flags&PARCELABLE_WRITE_RETURN_VALUE) != 0 && !mClosed) {
try {
close();
}......
}
}
~~~
Parcel的writeFileDescriptor是一个native函数,代码如下:
**android_util_Binder.cpp::android_os_Parcel_writeFileDescriptor**
~~~
static voidandroid_os_Parcel_writeFileDescriptor(JNIEnv* env,
jobject clazz,jobject object)
{
Parcel*parcel = parcelForJavaObject(env, clazz);
if(parcel != NULL) {
//先调用jniGetFDFromFileDescriptor从Java层FileDescriptor对象中
//取出对应的文件描述符。在Native层,文件描述符是一个int整型
//然后调用Native parcel对象的writeDupFileDescriptor函数
const status_t err =
parcel->writeDupFileDescriptor(
jniGetFDFromFileDescriptor(env, object));
if(err != NO_ERROR) {
signalExceptionForError(env, clazz, err);
}
}
}
~~~
Native Parcel类的writeDupFileDescriptor代码如下:
**Parcel.cpp::writeDupFileDescriptor**
~~~
status_t Parcel::writeDupFileDescriptor(int fd)
{
returnwriteFileDescriptor(dup(fd), true);
}
//直接来看writeFileDescriptor函数
status_t Parcel::writeFileDescriptor(int fd, booltakeOwnership)
{
flat_binder_object obj;
obj.type= BINDER_TYPE_FD;
obj.flags = 0x7f | FLAT_BINDER_FLAG_ACCEPTS_FDS;
obj.handle = fd; //将MediaProvider打开的文件描述符传递给Binder协议
obj.cookie = (void*) (takeOwnership ? 1 : 0);
returnwriteObject(obj, true);
}
~~~
有上边代码可知,ParcelFileDescriptor的序列化过程就是将其内部对应文件的文件描述符取出,并存储到一个由Binder驱动的flat_binder_object对象中。该对象最终会发送给Binder驱动。
2. 反序列化ParcelFileDescriptor
假设客户端进程收到了来自服务端的回复,客户端要做的就是根据服务端的回复包构造一个新的ParcelFileDescriptor。我们重点关注文件描述符的反序列化,其中调用的函数是Parcel的readFileDescriptor,其代码如下:
**ParcelFileDescriptor.java::readFileDescriptor**
~~~
public final ParcelFileDescriptorreadFileDescriptor() {
//从internalReadFileDescriptor中返回一个FileDescriptor对象
FileDescriptor fd = internalReadFileDescriptor();
//构造一个ParcelFileDescriptor对象,该对象对应的文件就是服务端打开的那个缩略图文件
return fd!= null ? new ParcelFileDescriptor(fd) : null;
~~~
internalReadFileDescriptor是一个native函数,其实现代码如下:
**android_util_Binder.cpp::android_os_Parcel_readFileDescriptor**
~~~
static jobjectandroid_os_Parcel_readFileDescriptor(JNIEnv* env, jobject clazz)
{
Parcel*parcel = parcelForJavaObject(env, clazz);
if(parcel != NULL) {
//调用Parcel的readFileDescriptor得到一个文件描述符
intfd = parcel->readFileDescriptor();
if(fd < 0) return NULL;
fd =dup(fd);//调用dup复制该文件描述符
if(fd < 0) return NULL;
//调用jniCreateFileDescriptor以返回一个Java层的FileDescriptor对象
return jniCreateFileDescriptor(env, fd);
}
returnNULL;
}
~~~
来看Parcel的readFileDescriptor函数,代码如下:
**Parcel.cpp::readFileDescriptor**
~~~
int Parcel::readFileDescriptor() const
{
constflat_binder_object* flat = readObject(true);
if(flat) {
switch (flat->type) {
case BINDER_TYPE_FD:
//当服务端发送回复包的时候,handle变量指向fd。当客户端接收回复包的时候,
//又从handle中得到fd。此fd是彼fd吗?
return flat->handle;
}
}
returnBAD_TYPE;
}
~~~
笔者在以上代码中提到了一个较深刻的问题:此fd是彼fd吗?这个问题的真实含义是:
- 服务端打开了一个文件,得到了一个fd。注意,fd是一个整型。在服务端上,这个fd确实对应了一个已经打开的文件。
- 客户端得到的也是一个整型值,它对应的是一个文件吗?
如果说客户端得到一个整型值,就认为它得到了一个文件,这种说法未免有些草率。在以上代码中,我们发现客户端确实根据收到的那个整型值创建了一个FileDescriptor对象。那么,怎样才可知道这个整型值在客户端中一定代表一个文件呢?
这个问题的终极解答在Binder驱动的代码中。来看它的binder_transaction函数。
3. 文件描述符传递之Binder驱动的处理
**binder.c::binder_transaction**
~~~
static void binder_transaction(struct binder_proc*proc,
structbinder_thread *thread,
structbinder_transaction_data *tr, int reply)
......
switch(fp->type) {
caseBINDER_TYPE_FD: {
int target_fd;
struct file *file;
if (reply) {
......
//Binder驱动根据服务端返回的fd找到内核中文件的代表file,其数据类型是
//struct file
file = fget(fp->handle);
......
//target_proc为客户端进程,task_get_unused_fd_flags函数用于从客户端
//进程中找一个空闲的整型值,用做客户端进程的文件描述符
target_fd = task_get_unused_fd_flags(target_proc,
O_CLOEXEC);
......
//将客户端进程的文件描述符和代表文件的file对象绑定
task_fd_install(target_proc, target_fd, file);
fp->handle = target_fd;
}break;
......//其他处理
}
~~~
一切真相大白!原来,Binder驱动代替客户端打开了对应的文件,所以现在可以肯定,客户端收到的整型值确确实实代表一个文件。
4. 深入讨论
在研究这段代码时,笔者曾经向所在团队同仁问过这样一个问题:在Linux平台上,有什么办法能让两个进程共享同一文件的数据呢?曾得到下面这些回答:
- 两个进程打开同一文件。这种方式前面讨论过了,安全性和可扩展性都比较差,不是我们想要的方式。
- 通过父子进程的亲缘关系,使用文件重定向技术。由于这两个进程关系太亲近,这种实现方式拓展性较差,也不是我们想要的。
- 跳出两个进程打开同一个文件的限制。在两个进程间创建管道,然后由服务端读取文件数据并写入管道,再由客户端进程从管道中获取数据。这种方式和前面介绍的openAssetFileDescriptor有殊途同归之处。
在缺乏类似Binder驱动支持的情况下,要在Linux平台上做到文件描述符的跨进程传递是件比较困难的事。从上面三种回答来看,最具扩展性的是第三种方式,即进程间采用管道作为通信手段。但是对Android平台来说,这种方式的效率显然不如现有的openAssetFileDescriptor的实现。原因在于管道本身的特性。
服务端必须单独启动一个线程来不断地往管道中写数据,即整个数据的流动是由写端驱动的(虽然当管道无空间的时候,如果读端不读取数据,写端也没法再写入数据,但是如果写端不写数据,则读端一定读不到数据。基于这种认识,笔者认为管道中数据流动的驱动力应该在写端)。
Android 3.0以后为ContentProvider提供了管道支持,我们来看相关的函数。
**ContentProvider.java::openPipeHelper**
~~~
public <T> ParcelFileDescriptoropenPipeHelper(final Uri uri,
finalString mimeType, final Bundle opts,
final T args, final PipeDataWriter<T> func)
throws FileNotFoundException {
try {
//创建管道
final ParcelFileDescriptor[] fds = ParcelFileDescriptor.
createPipe();
//构造一个AsyncTask对象
AsyncTask<Object, Object, Object> task = new
AsyncTask<Object,Object, Object>() {
@Override
protected Object doInBackground(Object... params) {
//往管道写端写数据,如果没有这个后台线程的写操作,客户端无论如何
//也读不到数据的
func.writeDataToPipe(fds[1],uri, mimeType, opts, args);
try {
fds[1].close();
} ......
return null;
}
};
//AsyncTask.THREAD_POOL_EXECUTOR是一个线程池,task的doInBackground
//函数将在线程池中的一个线程中运行
task.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR,
(Object[])null);
return fds[0];//返回读端给客户端
} ......
}
~~~
由以上代码可知,采用管道这种方式的开销确实比客户端直接获取文件描述符的开销大。
- 前言
- 第1章 搭建Android源码工作环境
- 1.1 Android系统架构
- 1.2 搭建开发环境
- 1.2.1 下载源码
- 1.2.2 编译源码
- 1.2.3 利用Eclipse调试system_process
- 1.3 本章小结
- 第2章 深入理解Java Binder和MessageQueue
- 2.1 概述
- 2.2 Java层中的Binder架构分析
- 2.2.1 Binder架构总览
- 2.2.2 初始化Java层Binder框架
- 2.2.3 addService实例分析
- 2.2.4 Java层Binder架构总结
- 2.3 心系两界的MessageQueue
- 2.3.1 MessageQueue的创建
- 2.3.2 提取消息
- 2.3.3 nativePollOnce函数分析
- 2.3.4 MessageQueue总结
- 2.4 本章小结
- 第3章 深入理解SystemServer
- 3.1 概述
- 3.2 SystemServer分析
- 3.2.1 main函数分析
- 3.2.2 Service群英会
- 3.3 EntropyService分析
- 3.4 DropBoxManagerService分析
- 3.4.1 DBMS构造函数分析
- 3.4.2 dropbox日志文件的添加
- 3.4.3 DBMS和settings数据库
- 3.5 DiskStatsService和DeviceStorageMonitorService分析
- 3.5.1 DiskStatsService分析
- 3.5.2 DeviceStorageManagerService分析
- 3.6 SamplingProfilerService分析
- 3.6.1 SamplingProfilerService构造函数分析
- 3.6.2 SamplingProfilerIntegration分析
- 3.7 ClipboardService分析
- 3.7.1 复制数据到剪贴板
- 3.7.2 从剪切板粘贴数据
- 3.7.3 CBS中的权限管理
- 3.8 本章小结
- 第4章 深入理解PackageManagerService
- 4.1 概述
- 4.2 初识PackageManagerService
- 4.3 PKMS的main函数分析
- 4.3.1 构造函数分析之前期准备工作
- 4.3.2 构造函数分析之扫描Package
- 4.3.3 构造函数分析之扫尾工作
- 4.3.4 PKMS构造函数总结
- 4.4 APK Installation分析
- 4.4.1 adb install分析
- 4.4.2 pm分析
- 4.4.3 installPackageWithVerification函数分析
- 4.4.4 APK 安装流程总结
- 4.4.5 Verification介绍
- 4.5 queryIntentActivities分析
- 4.5.1 Intent及IntentFilter介绍
- 4.5.2 Activity信息的管理
- 4.5.3 Intent 匹配查询分析
- 4.5.4 queryIntentActivities总结
- 4.6 installd及UserManager介绍
- 4.6.1 installd介绍
- 4.6.2 UserManager介绍
- 4.7 本章学习指导
- 4.8 本章小结
- 第5章 深入理解PowerManagerService
- 5.1 概述
- 5.2 初识PowerManagerService
- 5.2.1 PMS构造函数分析
- 5.2.2 init分析
- 5.2.3 systemReady分析
- 5.2.4 BootComplete处理
- 5.2.5 初识PowerManagerService总结
- 5.3 PMS WakeLock分析
- 5.3.1 WakeLock客户端分析
- 5.3.2 PMS acquireWakeLock分析
- 5.3.3 Power类及LightService类介绍
- 5.3.4 WakeLock总结
- 5.4 userActivity及Power按键处理分析
- 5.4.1 userActivity分析
- 5.4.2 Power按键处理分析
- 5.5 BatteryService及BatteryStatsService分析
- 5.5.1 BatteryService分析
- 5.5.2 BatteryStatsService分析
- 5.5.3 BatteryService及BatteryStatsService总结
- 5.6 本章学习指导
- 5.7 本章小结
- 第6章 深入理解ActivityManagerService
- 6.1 概述
- 6.2 初识ActivityManagerService
- 6.2.1 ActivityManagerService的main函数分析
- 6.2.2 AMS的 setSystemProcess分析
- 6.2.3 AMS的 installSystemProviders函数分析
- 6.2.4 AMS的 systemReady分析
- 6.2.5 初识ActivityManagerService总结
- 6.3 startActivity分析
- 6.3.1 从am说起
- 6.3.2 AMS的startActivityAndWait函数分析
- 6.3.3 startActivityLocked分析
- 6.4 Broadcast和BroadcastReceiver分析
- 6.4.1 registerReceiver流程分析
- 6.4.2 sendBroadcast流程分析
- 6.4.3 BROADCAST_INTENT_MSG消息处理函数
- 6.4.4 应用进程处理广播分析
- 6.4.5 广播处理总结
- 6.5 startService之按图索骥
- 6.5.1 Service知识介绍
- 6.5.2 startService流程图
- 6.6 AMS中的进程管理
- 6.6.1 Linux进程管理介绍
- 6.6.2 关于Android中的进程管理的介绍
- 6.6.3 AMS进程管理函数分析
- 6.6.4 AMS进程管理总结
- 6.7 App的 Crash处理
- 6.7.1 应用进程的Crash处理
- 6.7.2 AMS的handleApplicationCrash分析
- 6.7.3 AppDeathRecipient binderDied分析
- 6.7.4 App的Crash处理总结
- 6.8 本章学习指导
- 6.9 本章小结
- 第7章 深入理解ContentProvider
- 7.1 概述
- 7.2 MediaProvider的启动及创建
- 7.2.1 Context的getContentResolver函数分析
- 7.2.2 MediaStore.Image.Media的query函数分析
- 7.2.3 MediaProvider的启动及创建总结
- 7.3 SQLite创建数据库分析
- 7.3.1 SQLite及SQLiteDatabase家族
- 7.3.2 MediaProvider创建数据库分析
- 7.3.3 SQLiteDatabase创建数据库的分析总结
- 7.4 Cursor 的query函数的实现分析
- 7.4.1 提取query关键点
- 7.4.2 MediaProvider 的query分析
- 7.4.3 query关键点分析
- 7.4.4 Cursor query实现分析总结
- 7.5 Cursor close函数实现分析
- 7.5.1 客户端close的分析
- 7.5.2 服务端close的分析
- 7.5.3 finalize函数分析
- 7.5.4 Cursor close函数总结
- 7.6 ContentResolver openAssetFileDescriptor函数分析
- 7.6.1 openAssetFileDescriptor之客户端调用分析
- 7.6.2 ContentProvider的 openTypedAssetFile函数分析
- 7.6.3 跨进程传递文件描述符的探讨
- 7.6.4 openAssetFileDescriptor函数分析总结
- 7.7 本章学习指导
- 7.8 本章小结
- 第8章 深入理解ContentService和AccountManagerService
- 8.1 概述
- 8.2 数据更新通知机制分析
- 8.2.1 初识ContentService
- 8.2.2 ContentResovler 的registerContentObserver分析
- 8.2.3 ContentResolver的 notifyChange分析
- 8.2.4 数据更新通知机制总结和深入探讨
- 8.3 AccountManagerService分析
- 8.3.1 初识AccountManagerService
- 8.3.2 AccountManager addAccount分析
- 8.3.3 AccountManagerService的分析总结
- 8.4 数据同步管理SyncManager分析
- 8.4.1 初识SyncManager
- 8.4.2 ContentResolver 的requestSync分析
- 8.4.3 数据同步管理SyncManager分析总结
- 8.5 本章学习指导
- 8.6 本章小结