大字节缓冲区的BufferedReader吗？

Question

有没有一种方法可以使用BufferedReader读取ByteBuffer而不必先将其转换为String？我想读取相当大的ByteBuffer作为文本行，并且出于性能方面的考虑，我想避免将其写入磁盘。在ByteBuffer上调用toString不起作用，因为生成的String太大（它抛出java.lang.OutOfMemoryError：Java堆空间）。我本来以为API中会有一些东西可以将ByteBuffer包装在合适的读取器中，但是我似乎找不到合适的东西。

这是一个简短的代码示例，说明了我在做什么）：

// input stream is from Process getInputStream()
public String read(InputStream istream)
{
  ReadableByteChannel source = Channels.newChannel(istream);
  ByteArrayOutputStream ostream = new ByteArrayOutputStream(bufferSize);
  WritableByteChannel destination = Channels.newChannel(ostream);
  ByteBuffer buffer = ByteBuffer.allocateDirect(writeBufferSize);

  while (source.read(buffer) != -1)
  {
    buffer.flip();
    while (buffer.hasRemaining())
    {
      destination.write(buffer);
    }
    buffer.clear();
  }

  // this data can be up to 150 MB.. won't fit in a String.
  result = ostream.toString();
  source.close();
  destination.close();
  return result;
}

// after the process is run, we call this method with the String
public void readLines(String text)
{
  BufferedReader reader = new BufferedReader(new StringReader(text));
  String line;

  while ((line = reader.readLine()) != null)
  {
    // do stuff with line
  }
}

Answer 1

目前尚不清楚为什么要使用字节缓冲区作为开始。如果您有一个InputStream并且想要阅读它的行，那么为什么不只使用一个InputStreamReader包装在其中的包裹BufferedReader呢？参与NIO有什么好处？

调用toString()上ByteArrayOutputStream像一个坏主意的声音对我来说，即使你必须为它的空间：更好地得到它作为一个字节数组，敷在ByteArrayInputStream后的InputStreamReader，如果你真的必须有一个ByteArrayOutputStream。如果您
确实 要调用toString()，请至少使用重载，该重载使用要使用的字符编码的名称-否则它将使用系统默认值，这可能不是您想要的。

编辑：好的，所以您真的想使用NIO。您ByteArrayOutputStream最终仍在写信，因此最终将得到其中包含数据的BAOS。如果您想避免复制这些数据，则需要从派生ByteArrayOutputStream，例如：

public class ReadableByteArrayOutputStream extends ByteArrayOutputStream
{
    /**
     * Converts the data in the current stream into a ByteArrayInputStream.
     * The resulting stream wraps the existing byte array directly;
     * further writes to this output stream will result in unpredictable
     * behavior.
     */
    public InputStream toInputStream()
    {
        return new ByteArrayInputStream(array, 0, count);
    }
}

然后，您可以创建输入流，将其包装为，将其InputStreamReader包装为BufferedReader，然后就可以离开了。