写入HttpServletResponse时超10MB大文件报stream is closed异常求助

问题描述 #

向HttpServletResponse写入文件时，仅当文件大小超过10MB时会抛出stream is closed异常；已尝试将写入超时设置为600000，但问题仍未解决。小文件或记录数较少的文件可正常下载，替换为IOUtils.copyLarge(fis,os)后问题依旧，异常出现在写入流的操作处。

可能的原因及解决方法 #

1. 容器/反向代理的超时或大小限制 #

很多Web容器（如Tomcat）或前端反向代理（如Nginx）会对请求响应的超时时间、响应大小做限制，当文件超过阈值时会主动断开连接，导致流被关闭。

• Tomcat配置调整：检查server.xml中的Connector配置，确认connectionTimeout是否生效，同时设置maxPostSize="-1"（不限制请求体大小），另外设置maxSwallowSize="-1"禁用Tomcat对请求体的 swallow 限制，避免连接断开时提前关闭流。
• 反向代理配置：如果使用Nginx等代理，调整proxy_connect_timeout、proxy_send_timeout、proxy_read_timeout为足够大的值，同时设置client_max_body_size 100M;（根据实际需求调整大小）。

2. Content-Length的整数溢出问题 #

代码中使用response.setContentLength(fileLength.intValue())，虽然10MB远小于Integer的最大值（约2GB），但部分容器可能会对Content-Length的准确性做校验，若实际写入字节数与设置值存在偏差，可能提前关闭流。

• 解决方案：改用Servlet 3.1+支持的response.setContentLengthLong(fileLength)，直接传入Long类型的文件大小，避免类型转换带来的问题。

3. 流操作顺序错误 #

代码在finally块中先关闭输出流os，再调用response.flushBuffer()，此时流已关闭，flush操作无效，甚至可能引发异常，也可能导致容器提前终止响应。

• 调整finally块的代码顺序：

try {
    if (fis != null) {
        fis.close();
    }
    if (os != null) {
        os.flush();
    }
    response.flushBuffer(); // 先刷新缓冲区，再关闭流
    if (os != null) {
        os.close();
    }
} catch (IOException e) {
    Logger.error(e.getMessage(), e);
}

4. 报告生成耗时过长导致连接超时 #

generatereport()方法从数据库获取数据并写入文件，大文件场景下该方法耗时较长，可能在文件生成过程中客户端或代理已超时断开连接，后续写入流时触发异常。

• 优化generatereport()的性能：比如优化数据库查询语句、批量读取数据、优化文件写入逻辑，减少生成时间。
• 提前发送响应头：在调用generatereport()前先设置好所有响应头，并调用response.flushBuffer()，告知客户端连接已建立，避免连接因长时间无响应被断开。

5. 客户端主动断开连接 #

大文件下载时，客户端可能因网络问题主动断开连接，导致服务端写入流时抛出异常。可以针对性处理这类异常，避免误报业务错误。

• 异常处理优化：在catch块中判断异常类型，若为ClientAbortException（Tomcat）或类似的客户端断开异常，可忽略该错误，无需抛出业务异常：

catch (Exception e) {
    if (e instanceof ClientAbortException) {
        Logger.info("客户端主动断开下载连接", e);
    } else {
        Logger.error(e.getMessage(), e);
        throw new CommandException(e);
    }
}

原问题代码 #

InputStream fis = null;
OutputStream os = null;
try {
    // 设置响应类型、响应头等操作
    file = generatereport();// 从数据库取数据并写入文件
    Long fileLength = Long.valueOf(file.length());
    fis = new FileInputStream(file);

    response.setContentLength(fileLength.intValue());
    os = response.getOutputStream();
    byte[] b = new byte[1024];
    int count = fis.read(b);
    while (count > -1) {
        os.write(b, 0, count);  // 此处抛出异常
        count = fis.read(b);
    }
} catch (Exception e) {
    Logger.error(e.getMessage(), e);
    throw new CommandException(e);
} finally {
    try {
        if (fis != null) {
            fis.close();
        }
        if (os != null) {
            os.flush();
            os.close();
        }
        response.flushBuffer();
    } catch (IOException e) {
        Logger.error(e.getMessage(), e);
    }
    if (StringUtils.isNotEmpty(dataSource)) {
        DataSourceSwitcher.restoreDataSource(dataSource);
    }
}

内容的提问来源于stack exchange，提问作者deepthi kolapineni