Java HTTP 1.1客户端Socket流结束问题技术咨询

嘿，我来帮你搞定这个困扰你的Socket流结束问题！从你贴的代码来看，核心问题出在**HTTP/1.1默认启用持久连接（Keep-Alive）**上——服务器在返回响应后不会主动关闭Socket连接，你的BufferedReader.readLine()会一直阻塞等待，直到服务器超时断开连接，这时候就会触发"end of stream"的异常或者返回null。

下面我给你几个实用的解决方案，按复杂度和推荐程度排序：

方案1：添加Connection: close请求头（最简单快速） #

直接在请求头里告诉服务器，响应完成后关闭连接，这样客户端读完响应后就能检测到流结束，不会一直阻塞。修改你的请求代码：

OutputStream output = socket.getOutputStream();
PrintWriter writer = new PrintWriter(output, true);
writer.println("GET / HTTP/1.1");
writer.println("Host: " + uri.getHost());
writer.println("Accept: text/html");
writer.println("Connection: close"); // 新增这一行，告诉服务器关闭连接
writer.println();

这样服务器返回响应后会主动关闭Socket，你的readLine()在读完所有响应内容后会返回null，你就可以正常结束读取流程了。

方案2：解析Content-Length头部读取响应体（标准做法） #

HTTP响应头里的Content-Length字段会告诉你响应体的字节数，你可以先读取所有响应头，找到这个值，然后精确读取对应数量的字节，不用依赖流关闭。示例代码：

InputStream input = socket.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(input));
String line;
StringBuilder headerBuilder = new StringBuilder();
int contentLength = -1;

// 读取响应头，直到空行
while ((line = reader.readLine()) != null && !line.isEmpty()) {
    headerBuilder.append(line).append("\n");
    // 解析Content-Length
    if (line.startsWith("Content-Length:")) {
        contentLength = Integer.parseInt(line.substring("Content-Length:".trim().length()).trim());
    }
}

// 读取响应体
StringBuilder bodyBuilder = new StringBuilder();
if (contentLength != -1) {
    char[] buffer = new char[contentLength];
    int read = 0;
    while (read < contentLength) {
        int charsRead = reader.read(buffer, read, contentLength - read);
        if (charsRead == -1) break; // 处理异常情况
        read += charsRead;
    }
    bodyBuilder.append(buffer, 0, read);
}

// 现在headerBuilder和bodyBuilder分别存了响应头和响应体

这种方法更符合HTTP/1.1的规范，也能兼容持久连接场景，推荐在正式项目中使用。

方案3：处理分块编码（Transfer-Encoding: chunked） #

如果服务器返回的响应是分块编码（没有Content-Length，而是Transfer-Encoding: chunked），你需要按照分块的格式解析：每个块开头是十六进制的长度，然后是块内容，最后以0\r\n\r\n结束。简单示例：

// 读取响应头后，开始处理分块
StringBuilder bodyBuilder = new StringBuilder();
while ((line = reader.readLine()) != null) {
    // 解析块长度（十六进制转十进制）
    int chunkLength = Integer.parseInt(line.trim(), 16);
    if (chunkLength == 0) break; // 块长度为0表示结束
    
    // 读取块内容
    char[] chunkBuffer = new char[chunkLength];
    int read = 0;
    while (read < chunkLength) {
        int charsRead = reader.read(chunkBuffer, read, chunkLength - read);
        if (charsRead == -1) break;
        read += charsRead;
    }
    bodyBuilder.append(chunkBuffer, 0, read);
    
    // 跳过块末尾的换行符
    reader.readLine();
}
// 跳过最后的空行
reader.readLine();

这种情况比较常见于动态生成内容的响应，比如服务器不知道最终响应长度的时候会用分块编码。

总结一下 #

• 快速测试用方案1，简单直接；
• 正式开发优先用方案2，兼容大多数场景；
• 如果遇到分块编码的响应，就需要用方案3处理。

内容的提问来源于stack exchange，提问作者Wouter Vandenputte