我希望使用ParcelFileDescriptor.createPipe()
方法创建一个管道,通过流到流的拷贝线程和表示管道读取端的ParcelFileDescriptor将一个Android Service中的InputStream传送给另一个运行在不同进程中的Service,并通过Binder IPC机制实现传输。
发送代码(进程A)
我想把一个给定的InputStream发送到接收服务中:
public sendInputStream() {
InputStream is = ...; // that's the stream for process/service B
ParcelFileDescriptor pdf = ParcelFileDescriptorUtil.pipeFrom(is);
inputStreamService.inputStream(pdf);
}
ParcelFileDescriptorUtil是一个帮助类,其中包含一个经典的java.io.
流到流复制Thread:
public class ParcelFileDescriptorUtil {
public static ParcelFileDescriptor pipeFrom(InputStream inputStream) throws IOException {
ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe();
ParcelFileDescriptor readSide = pipe[0];
ParcelFileDescriptor writeSide = pipe[1];
// start the transfer thread
new TransferThread(inputStream, new ParcelFileDescriptor.AutoCloseOutputStream(writeSide)).start();
return readSide;
}
static class TransferThread extends Thread {
final InputStream mIn;
final OutputStream mOut;
TransferThread(InputStream in, OutputStream out) {
super("ParcelFileDescriptor Transfer Thread");
mIn = in;
mOut = out;
setDaemon(true);
}
@Override
public void run() {
byte[] buf = new byte[1024];
int len;
try {
while ((len = mIn.read(buf)) > 0) {
mOut.write(buf, 0, len);
}
mOut.flush(); // just to be safe
} catch (IOException e) {
LOG.e("TransferThread", e);
}
finally {
try {
mIn.close();
} catch (IOException e) {
}
try {
mOut.close();
} catch (IOException e) {
}
}
}
}
}
接收服务代码(进程B)
接收服务的.aidl
文件:
package org.exmaple;
interface IInputStreamService {
void inputStream(in ParcelFileDescriptor pfd);
}
接收服务,由进程A调用:
public class InputStreamService extends Service {
@Override
public IBinder onBind(Intent intent) {
return mBinder;
}
private final IInputStreamService.Stub mBinder = new IInputStreamService.Stub() {
@Override
public void inputStream(ParcelFileDescriptor pfd) throws RemoteException {
InputStream is = new ParcelFileDescriptor.AutoCloseInputStream(pfd);
OutputStream os = ...;
int len;
byte[] buf = new byte[1024];
try {
while ((len = is.read(buf)) > 0) {
os.write(buf, 0, len);
}
} catch (IOException e) {
// this catches the exception shown below
}
}
};
但是在 inputStream()
中调用 in.read()
总是会抛出一个 IOException
异常
java.io.IOException: read failed: EBADF (Bad file number)
at libcore.io.IoBridge.read(IoBridge.java:442)
at java.io.FileInputStream.read(FileInputStream.java:179)
at java.io.InputStream.read(InputStream.java:163)
看起来当文件描述符关闭时,read()
会设置EBADF errno。但我不知道是什么导致了它,也不知道如何解决。
是的,我知道 ContentProvider 也是一个可能的选择。但我的方法不应该也能起作用吗?在 Android 中,有没有其他将 InputStream 流传递给不同服务的方法?
顺便说一下:CommonsWare 创建了一个类似的项目,使用 ContentProvider(相关的 SO 问题 1,2)。这就是我从中得到大部分想法的地方。