为何try代码块导致线程阻塞？请求体检测问题求助

为什么你的代码会阻塞？ #

你遇到的阻塞核心在于**BufferedReader.readLine()是阻塞式方法**：当没有请求体时，客户端发送完请求头的空行后就不会再传输任何数据，此时调用readLine()会一直等待新输入，直到客户端主动断开连接（也就是你取消浏览器请求时）才返回null，直接导致线程卡住、服务器无法响应。

另外你原循环存在空指针风险：while (!(line = br.readLine()).isBlank()) 若readLine()返回null（比如连接意外中断），调用isBlank()会直接抛出NullPointerException，正确写法应先判断line不为null，再检查是否为空行：

String line;
while ((line = br.readLine()) != null && !line.isBlank()) {
    // 处理请求头逻辑
}

正确检测并读取请求体的方法 #

HTTP协议中请求体的存在与否有明确规则，不能直接用readLine()判断，正确步骤如下：

1. 按请求方法初步筛选

   • GET、HEAD这类方法规范上不会携带请求体，直接跳过处理即可；
   • POST、PUT、PATCH等方法可能携带请求体，但需结合请求头进一步确认。

2. 通过请求头判断是否存在请求体
   请求体的存在与格式由两个请求头决定：

   • Content-Length：明确指定请求体字节数，存在该头则说明有请求体；
   • Transfer-Encoding: chunked：表示请求体采用分块编码传输，此时无固定Content-Length，需按分块规则读取。

3. 对应读取请求体的逻辑
   注意：不要用BufferedReader读取请求体（除非确定是带换行的纯文本），建议直接用底层InputStream按字节读取，避免编码或格式问题导致错误。

示例代码片段

// 假设已解析得到请求方法和请求头（用Map存储）
String requestMethod = ...; // 比如"POST"
Map<String, String> requestHeaders = ...;

boolean hasRequestBody = false;
// 判断是否存在请求体
if (("POST".equals(requestMethod) || "PUT".equals(requestMethod) || "PATCH".equals(requestMethod))) {
    String contentLength = requestHeaders.get("Content-Length");
    String transferEncoding = requestHeaders.get("Transfer-Encoding");
    hasRequestBody = (contentLength != null && !contentLength.trim().equals("0")) 
                     || ("chunked".equalsIgnoreCase(transferEncoding));
}

if (hasRequestBody) {
    InputStream inputStream = socket.getInputStream();
    String contentLengthStr = requestHeaders.get("Content-Length");
    if (contentLengthStr != null) {
        // 处理固定长度的请求体
        int contentLength = Integer.parseInt(contentLengthStr.trim());
        byte[] bodyBytes = new byte[contentLength];
        int totalRead = 0;
        int readBytes;
        while (totalRead < contentLength && (readBytes = inputStream.read(bodyBytes, totalRead, contentLength - totalRead)) != -1) {
            totalRead += readBytes;
        }
        // 字节转字符串（根据实际编码调整，比如UTF-8）
        String requestBody = new String(bodyBytes, StandardCharsets.UTF_8);
        // 处理请求体逻辑
    } else {
        // 处理分块编码的请求体
        BufferedReader chunkReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));
        StringBuilder chunkBody = new StringBuilder();
        String chunkLine;
        while ((chunkLine = chunkReader.readLine()) != null) {
            // 解析块长度（十六进制转十进制）
            int chunkLength = Integer.parseInt(chunkLine.trim(), 16);
            if (chunkLength == 0) {
                // 分块结束，读取末尾空行
                chunkReader.readLine();
                break;
            }
            // 读取当前块内容
            char[] chunkContent = new char[chunkLength];
            chunkReader.read(chunkContent, 0, chunkLength);
            chunkBody.append(chunkContent);
            // 读取块后的换行符
            chunkReader.readLine();
        }
        String requestBody = chunkBody.toString();
        // 处理请求体逻辑
    }
}

额外注意点 #

• 即使是POST方法，也可能存在无请求体的情况（比如空表单提交），必须结合请求头判断，不能默认读取；
• 分块编码需严格遵循HTTP规范：每个块以十六进制长度开头，后跟换行、块内容、换行，最后以长度为0的块结束；
• 处理完请求头后，不要随意调用readLine()或read()，除非确定有数据可读，否则会触发阻塞。

内容的提问来源于stack exchange，提问作者T-Stone