Java Socket读取消息后发送消息失败的问题排查

问题根源分析 #

你的代码存在几个关键问题，直接导致Socket停止工作：

1. readLine()的阻塞逻辑缺陷
   BufferedReader.readLine()会一直阻塞，直到读取到换行符（\n）或者输入流被关闭。如果客户端发送消息时未携带结尾换行符，或发送后未等待响应就直接关闭输出流，服务器会卡在这个读取循环里，根本执行不到后续的发送代码。即便客户端发送了换行符，当readLine()返回null时，说明客户端已关闭输出流（通常意味着连接即将断开），此时服务器再发送消息必然失败。

2. PrintWriter.close()的连锁影响
   调用printWriter.close()时，会自动关闭底层的OutputStream，进而直接关闭整个clientSocket。结合前面的读取逻辑导致的连接状态异常，会直接引发Socket停止工作的现象。

3. 单线程处理连接的局限
   当前代码是单线程架构，一次只能处理一个客户端连接。如果第一个客户端的读取逻辑阻塞，服务器就无法接受新连接，表现为Socket“停止工作”。

修复方案 #

1. 调整读取逻辑，避免无限阻塞 #

不要依赖readLine()循环到null，而是约定消息结束标记（比如固定字符串"END"），或者采用“先读长度再读内容”的协议。如果必须用readLine()，要确保客户端每条消息都以换行符结尾，且发送后等待服务器响应再关闭连接。

修改读取逻辑示例：

String line;
while ((line = reader.readLine()) != null) {
    if ("END".equals(line)) {
        break; // 收到结束标记，停止读取
    }
    messageBuilder.append(line);
    messageBuilder.append("\n");
}

2. 优化PrintWriter的创建时机 #

将PrintWriter的创建移到需要发送响应的环节，避免提前占用输出流：

// 仅在需要发送响应时创建PrintWriter
PrintWriter printWriter = new PrintWriter(clientSocket.getOutputStream(), true);
if (aux) {
    printWriter.println(xml);
} else {
    printWriter.println("THERES NO ERRORS YET");
}
printWriter.close();

注意：println()方法会自动添加换行符，无需手动拼接"\n"。

3. 改用多线程处理客户端连接 #

为每个客户端连接启动独立线程，避免单线程阻塞导致服务器无法接受新连接：

while (true) {
    Socket clientSocket = serverSocket.accept();
    // 启动新线程处理当前连接
    new Thread(() -> {
        BufferedReader reader = null;
        PrintWriter printWriter = null;
        try {
            reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            StringBuilder messageBuilder = new StringBuilder();
            String line;
            // 改进的读取逻辑
            while ((line = reader.readLine()) != null && !"END".equals(line)) {
                messageBuilder.append(line).append("\n");
            }
            String message = messageBuilder.toString();
            
            // 后续的文件写入、消息分析逻辑...
            sjf.agregarLog("Se mando nuevo mensaje");
            aux = false;
            lista = new Lista();
            analizarMensaje();
            
            // 发送响应
            printWriter = new PrintWriter(clientSocket.getOutputStream(), true);
            if (aux) {
                printWriter.println(xml);
            } else {
                printWriter.println("THERES NO ERRORS YET");
            }
        } catch (IOException e) {
            logger.error("处理客户端连接出错: {}", e.getMessage());
            sjf.agregarLog("处理连接出错: " + e.getMessage());
        } finally {
            // 确保资源正常关闭
            try {
                if (reader != null) reader.close();
                if (printWriter != null) printWriter.close();
                if (clientSocket != null) clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }).start();
}

4. 增加异常捕获与资源管理 #

添加异常捕获逻辑，避免单个连接的异常导致整个服务器崩溃，同时确保所有IO资源都能正常关闭。

额外注意事项 #

• 客户端发送消息后，必须等待服务器响应再关闭Socket，否则服务器发送响应时会抛出连接已关闭的异常。
• PrintWriter的autoFlush=true参数会在调用println()、printf()等方法时自动刷新缓冲区，无需额外调用flush()（使用print()方法时除外）。

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