传递读取的 FD parcelable：何时关闭？

Question

为了通过 binder 传递大量数据，我们创建了一个管道，然后将管道的读取端作为 ParcelFileDescriptor 传递到 binder，并启动一个线程将数据写入管道的写入端。基本上是这样的：

  public void writeToParcel(Parcel out, int flags) {
    ParcelFileDescriptor[] fds;
    try {
      fds = ParcelFileDescriptor.createPipe();
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
    out.writeParcelable(fds[0], 0);
    byte[] bytes = ...; // Marshall object data to bytes
    write(bytes, fds[1]); // Starts a thread to write the data
  }

接收端从管道的读取端读取数据。它看起来像这样：

ParcelFileDescriptor readFd = in.readFileDescriptor();

FileInputStream fis = new ParcelFileDescriptor.AutoCloseInputStream(readFd);
ByteArrayOutputStream out = new ByteArrayOutputStream();

byte[] b = new byte[16 * 1024];
int n;

try {
  while ((n = fis.read(b)) != -1) {
    out.write(b, 0, n);
  }
} catch (IOException e) {
  throw new RuntimeException(e);
} finally {
  try {
    Log.i(TAG, "Closing read file descriptor..."); // I see this
    fis.close();
    Log.i(TAG, "Closed read file descriptor"); // And I see this
  } catch (IOException e) {
    e.printStackTrace();
  }
}

这可行，但是当启用严格模式时，我们会崩溃：

 01-03 14:26:48.099 E/StrictMode(25346): A resource was acquired at attached stack trace but never released. See java.io.Closeable for information on avoiding resource leaks. 
 01-03 14:26:48.099 E/StrictMode(25346): java.lang.Throwable: Explicit termination method 'close' not called 
 01-03 14:26:48.099 E/StrictMode(25346):    at dalvik.system.CloseGuard.open(CloseGuard.java:223) 
 01-03 14:26:48.099 E/StrictMode(25346):    at android.os.ParcelFileDescriptor.<init>(ParcelFileDescriptor.java:192) 
 01-03 14:26:48.099 E/StrictMode(25346):    at android.os.ParcelFileDescriptor.<init>(ParcelFileDescriptor.java:181) 
 01-03 14:26:48.099 E/StrictMode(25346):    at android.os.ParcelFileDescriptor.createPipe(ParcelFileDescriptor.java:425) 
 01-03 14:26:48.099 E/StrictMode(25346):    at com.clover.sdk.FdParcelable.writeToParcel(FdParcelable.java:118) 

第 118 行是管道的创建 (ParcelFileDescriptor.createPipe())。

所以看来发送者需要关闭读端和写端。我的问题是我不知道什么时候可以关闭阅读端，因为我不知道阅读器什么时候会读完。

我错过了什么？

Answer 1

1. 写完后立即关闭输出流。

2. 消费者始终负责在完成读取后立即关闭其输入流。这不是您的责任（除非您也是消费者）。

您所描述的类似于我打开 FileOutputStream（我正在使用 API）并期望运行时为我关闭它，只是因为我在使用完它时没有明确关闭它。

因此，将 FD 发送到 Parcel，使用它的人负责关闭它。他们可以使用这样的东西：

val fd = parcel.readFileDescriptor()
val input = ParcelFileDescriptor.AutoCloseInputStream(fd)
// Use input. When #close() is called it will also close the FD.

见：https://developer.android.com/reference/android/os/ParcelFileDescriptor.AutoCloseInputStream

您可以在客户端 SDK 库中隐藏此实现。无论如何，为消费者做好记录。