android 中通过AIDL传输流文件

需求：

客户端通过AIDL传一段文件流给服务端，服务端根据流还原生成文件并打开

前置条件：

不赘述AIDL的使用方法
示例代码不做详细的容错处理

想法：

如果要通过AIDL把一个文件流传输到另一端，临时可以想得到的一个方法是：
client端的线程通过FileInputStream每次read一个缓冲，通过AIDL相应的去调用server端的方法，把这个缓冲区的byte数组传递到server端，然后server端通过FileOutputStream把这些byte数组write到新生成的临时文件即可。
但这种方法的弊端就是在文件传输期间会阻塞server端。众所周知，service是运行在应用的主线程中的，如果service中出现了很多不在其子线程中运行的阻塞或耗时操作，肯定会影响整个应用的流畅性的，所以这种方法不可行。

解决方法：

问题的关键是如何把接收的过程放到server端的线程中？解决方法是使用管道！但是Android进程间通信用Binder来传递数据，有一个最基本的要求就是要实现Parcelable接口。所以这里就需要用到：

ParcelFileDescriptor[] pfd = ParcelFileDescriptor.createPipe();

• pfd[0]是管道的read端
• pfd[1]是管道的write端

简单流程说明：

客户端：
先把pfd[0]通过AIDL调用传输给服务端，然后

ParcelFileDescriptor.AutoCloseOutputStream aos = new ParcelFileDescriptor.AutoCloseOutputStream(pfd[1]);

发送线程把本地文件FileInputStream读取的数据写到aos

服务端：

ParcelFileDescriptor.AutoCloseInputStream ais = new ParcelFileDescriptor.AutoCloseInputStream(input); //input是传过来的pfd[0]

接收线程把ais中读取的数据写到临时文件的FileOutputStream中

概要流程说明

---

简单代码片段

AIDL文件：

package com.test.aidlservice;

interface ITestInterface
{
    void openFile(String fileName, in ParcelFileDescriptor input);
}

服务端：

package com.test.aidlservice;


public class TestService extends Service
{
    @Nullable
    @Override
    public IBinder onBind(Intent intent)
    {
        return new TestBinder();
    }

    class TestBinder extends ITestInterface.Stub
    {
        @Override
        public void openFile(String fileName, ParcelFileDescriptor input) throws
                RemoteException
        {
            // 通过管道的read端包装输入流
            ParcelFileDescriptor.AutoCloseInputStream autoCloseInputStream =
                    new ParcelFileDescriptor.AutoCloseInputStream(input);

            // 生成临时文件路径
            String path = Environment.getExternalStorageDirectory().toString();
            path = path + "/temp_" + fileName;

            // 把流存到临时文件中
            try
            {
                new OpenFileTask(path, autoCloseInputStream).execute();
            }
            catch (FileNotFoundException e)
            {
                e.printStackTrace();
            }
        }
    }
}

OpenFileTask的任务就是通过传入的临时文件path生成对应的FileOutputStream，然后把autoCloseInputStream读出的数据写入到FileOutputStream中。整个文件写完后，调用startActivity打开对应格式的文件，在此不再赘述。

客户端：

private ITestInterface mTestService = null;
private ServiceConnection mConnection = new ServiceConnection()
{
    @Override
    public void onServiceConnected(ComponentName name, IBinder service)
    {
        mTestService = ITestInterface.Stub.asInterface(service);
    }

    @Override
    public void onServiceDisconnected(ComponentName name)
    {
        mTestService = null;
    }
};

bind部分：

Intent intent = new Intent();
intent.setAction("com.test.aidl.ITestInterface");
intent.setPackage("com.test.aidlservice");
bindService(intent, mConnection, BIND_AUTO_CREATE);

传输部分：

//获取一个需要被服务端打开的测试文件
String filePath = Environment.getExternalStorageDirectory().toString() + "/test.docx";

try
{
    ParcelFileDescriptor[] pfd = ParcelFileDescriptor.createPipe();
    ParcelFileDescriptor.AutoCloseOutputStream autoCloseOutputStream = new ParcelFileDescriptor.AutoCloseOutputStream(pfd[1]);
            
    new WriteFileTask(filePath, autoCloseOutputStream).execute();
    
    mTestService.openFile("test.docx", pfd[0]);
}
catch (IOException e)
{
    e.printStackTrace();
}
catch (RemoteException e)
{
    e.printStackTrace();
}

WriteFileTask的任务就是通过传入的文件path生成对应的FileInputStream，然后读取FileInputStream中的数据写入到autoCloseOutputStream中即可。