关闭浏览器未触发IO异常问题求助（Spring Boot场景）

问题场景 #

编写了一个向HttpServletResponse逐行写入数据并休眠的接口，代码如下：

@GetMapping("/")
public void getdata(HttpServletRequest request, HttpServletResponse response) {
    
    ArrayList<String> nameList = new ArrayList<String>();
    nameList.add("John");
    nameList.add("Mary");
    nameList.add("Sean");
    nameList.add("Peter");

    try {
        for (String s : nameList)
        {
            PrintWriter writer = response.getWriter();
            writer.write(s + "\r\n");
            writer.flush();
            System.out.println("Writen " + s);
            TimeUnit.SECONDS.sleep(5);
        }
    } catch (IOException | InterruptedException e) {
        e.printStackTrace();
    }
}

执行时，写入第一个名称后休眠5秒，此时关闭浏览器，程序却仍继续写入所有数据，未抛出预期的IO异常（如连接已关闭）。改用OutputStream或设置HttpSession也无法解决该问题。

使用的Spring Boot依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-thymeleaf</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

程序输出始终为：

Writen John
Writen Mary
Writen Sean
Writen Peter

原因分析 #

1. TCP连接特性：浏览器关闭时会向服务器发送FIN包，但TCP连接不会立刻中断，服务器处于CLOSE_WAIT状态，此时写入操作在输出缓冲区未耗尽时不会立刻触发错误，直到后续操作才可能检测到连接断开。
2. Servlet容器输出缓冲：Spring Boot默认使用Tomcat，Tomcat会维护自己的输出缓冲区，writer.flush()只是将数据刷入Tomcat缓冲区，而非直接发送到客户端。Tomcat会异步处理数据发送，不会立刻将客户端断开的状态反馈给应用层。
3. 重复获取Writer实例：每次循环调用response.getWriter()会返回同一个实例，但这不是核心问题，只是代码冗余。

解决方案 #

核心思路是主动检测客户端连接状态，通过PrintWriter.checkError()方法触发底层IO错误检查。该方法会刷新缓冲区并验证连接是否有效，若客户端已断开则会抛出IOException或返回true。

修改后的代码如下：

@GetMapping("/")
public void getdata(HttpServletRequest request, HttpServletResponse response) {
    ArrayList<String> nameList = new ArrayList<>();
    nameList.add("John");
    nameList.add("Mary");
    nameList.add("Sean");
    nameList.add("Peter");

    // 使用try-with-resources自动管理PrintWriter资源
    try (PrintWriter writer = response.getWriter()) {
        // 设置Connection头，告知服务器在响应完成后关闭连接
        response.setHeader("Connection", "close");
        
        for (String s : nameList) {
            writer.write(s + "\r\n");
            writer.flush();
            
            // 主动检查IO错误，若客户端断开则终止循环
            if (writer.checkError()) {
                System.err.println("客户端已断开连接，停止写入");
                break;
            }
            
            System.out.println("Writen " + s);
            TimeUnit.SECONDS.sleep(5);
        }
    } catch (IOException | InterruptedException e) {
        e.printStackTrace();
    }
}

关键优化点 #

• checkError()方法：主动触发底层连接状态检查，替代依赖自动抛出异常的机制，能及时发现客户端断开的情况。
• try-with-resources：自动关闭PrintWriter，避免资源泄漏。
• Connection: close头：让服务器在响应过程中更快检测到连接断开，配合checkError()能提升检测灵敏度。

内容的提问来源于stack exchange，提问作者Jay Joshi