Java中Socket读取到EOF后仍发送响应的解决方案

问题场景 #

用Java Socket持续监听POST请求，计划读取完整请求数据后返回响应，但运行时出现以下问题：

• 用reader.readLine()循环读取到EOF时，Java会自动关闭Socket的读写流及连接，导致后续代码执行但响应无法正常返回，页面持续加载。
• 仅读取请求首行时能正常返回响应，但无法获取完整请求数据，不符合需求。

核心问题原因 #

HTTP POST请求由请求头和请求体两部分组成：

1. 请求头以空行（\r\n\r\n）结束，这是请求头与请求体的分界。
2. 请求体的长度由请求头中的Content-Length字段指定（分块编码场景为Transfer-Encoding: chunked）。
3. 原代码中while ((line = reader.readLine()) != null)会一直读取直到客户端关闭连接（触发EOF），此时Socket连接已不可用，自然无法发送响应。

可行解决方案 #

正确处理流程：

1. 先读取请求头，直到遇到空行，解析出Content-Length的值。
2. 根据Content-Length的数值，读取对应长度的字节作为请求体，而非一直读到EOF。
3. 读取完完整请求后，再发送响应，此时Socket连接仍处于可用状态。

修改后的核心代码 #

import java.io.*;
import java.net.Socket;

public class SocketHandler {
    private static int count = 0;

    public static void handleClient(Socket clientSocket) {
        try (InputStream inputStream = clientSocket.getInputStream();
             OutputStream outputStream = clientSocket.getOutputStream();
             BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {

            String requestData = "";
            String line;
            int contentLength = 0;

            // 1. 读取请求头，直到空行
            while ((line = reader.readLine()) != null) {
                requestData += line + "\n";
                // 解析Content-Length字段
                if (line.startsWith("Content-Length:")) {
                    contentLength = Integer.parseInt(line.split(":")[1].trim());
                }
                // 遇到空行，请求头读取完毕
                if (line.isEmpty()) {
                    break;
                }
            }

            // 2. 根据Content-Length读取请求体
            if (contentLength > 0) {
                char[] bodyBuffer = new char[contentLength];
                int readBytes = reader.read(bodyBuffer, 0, contentLength);
                if (readBytes > 0) {
                    requestData += new String(bodyBuffer, 0, readBytes);
                }
            }

            // 3. 发送响应
            String responseHeader = "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\n\r\n";
            String responseBody = "{\"reply\":\"" + count + "\"}";
            outputStream.write((responseHeader + responseBody).getBytes());
            outputStream.flush();
            count++;

        } catch (IOException e) {
            System.out.println("ERROR");
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

补充说明 #

• 如果需要支持分块编码（Transfer-Encoding: chunked），需额外处理分块格式：每个块以十六进制长度开头，后跟\r\n，然后是块内容，最后以长度为0的块结束。
• 代码改用InputStream和OutputStream替代PrintWriter，是为了更直接控制字节流，避免字符编码或缓冲带来的问题。
• 生产环境建议使用现成HTTP服务器框架（如Tomcat、Jetty），避免手动处理Socket和HTTP协议细节。

内容的提问来源于stack exchange，提问作者The Photon