写一个输入流到一个HttpServlet响应

Question

我有一个输入流，我想将其写入HttpServletResponse。有一种方法，由于使用字节[]，需要花费的时间太长

InputStream is = getInputStream();
int contentLength = getContentLength();

byte[] data = new byte[contentLength];
is.read(data);

//response here is the HttpServletResponse object
response.setContentLength(contentLength);
response.write(data);

我想知道在速度和效率方面，什么可能是最好的方法。

Answer 1

我认为这是非常接近最佳的方式，但我建议进行以下更改。使用固定大小的缓冲区（比如20K），然后在循环中执行读/写操作。

对于循环，请执行以下操作

byte[] buffer=new byte[20*1024];
outputStream=response.getOutputStream();
while(true) {
  int readSize=is.read(buffer);
  if(readSize==-1)
    break;
  outputStream.write(buffer,0,readSize);
}

ps：你的程序不会一直按原样工作，因为read并不总是填满你给它的整个数组。

Answer 2

BufferedInputStream in = null;
BufferedOutputStream out = null;
OutputStream os;
os = new BufferedOutputStream(response.getOutputStream());
in = new BufferedInputStream(new FileInputStream(file));
out = new BufferedOutputStream(os);
byte[] buffer = new byte[1024 * 8];
int j = -1;
while ((j = in.read(buffer)) != -1) {
    out.write(buffer, 0, j);
}

Answer 3

只需在块中写入，而不是首先将其完全复制到Java内存中。下面的基本示例以10KB的块编写。这样一来，最终的一致内存使用量只有10KB，而不是完整的内容长度。最终用户也将更快地获得部分内容。

response.setContentLength(getContentLength());
byte[] buffer = new byte[10240];

try (
    InputStream input = getInputStream();
    OutputStream output = response.getOutputStream();
) {
    for (int length = 0; (length = input.read(buffer)) > 0;) {
        output.write(buffer, 0, length);
    }
}

就性能而言，您可以使用NIO通道和直接分配的ByteBuffer。在一些自定义实用程序类中创建以下实用程序/助手方法，例如：

public static long stream(InputStream input, OutputStream output) throws IOException {
    try (
        ReadableByteChannel inputChannel = Channels.newChannel(input);
        WritableByteChannel outputChannel = Channels.newChannel(output);
    ) {
        ByteBuffer buffer = ByteBuffer.allocateDirect(10240);
        long size = 0;

        while (inputChannel.read(buffer) != -1) {
            buffer.flip();
            size += outputChannel.write(buffer);
            buffer.clear();
        }

        return size;
    }
}

然后按如下方式使用：

response.setContentLength(getContentLength());
Utils.stream(getInputStream(), response.getOutputStream());