Java TCP/IP服务器无法向客户端传递输出的问题求助

核心问题定位 #

1. 重复创建输出流：send方法每次调用都会重新实例化BufferedOutputStream，覆盖全局的out对象，导致输出流状态混乱，甚至可能丢失缓冲数据。
2. 缺少数据终止标识：发送的字符串没有换行符（\n）或其他终止标记，若客户端使用readLine()这类基于行的读取方法，会因无法识别结束位置而持续阻塞。
3. 循环未响应终止信号：run方法内部的while(true)循环不监听cancel标志，导致调用cancel()后线程无法正常终止，资源无法释放。
4. 连接状态判断错误：isConnected()直接返回socket.isConnected()，但该方法仅表示曾经建立过连接，不能反映当前连接的有效性。

代码修改方案 #

1. 修复send方法（复用输出流+添加终止符）

import java.nio.charset.StandardCharsets;

// ... 其他代码不变
public void send(String[] arg) {
    StringBuilder builder = new StringBuilder();
    for (int i = 0; i < arg.length; i++) {
        builder.append(arg[i]);
    }
    // 添加换行符，适配客户端行读取逻辑
    builder.append("\n");
    try {
        // 复用全局已初始化的out对象，不再重复创建
        out.write(builder.toString().getBytes(StandardCharsets.UTF_8)); // 指定编码避免乱码
        out.flush();
        System.out.println(builder.toString());
    } catch (Exception e) {
        e.printStackTrace();
        logger.error(e.getLocalizedMessage(), e);
    }
}

2. 修复run方法（响应终止标志+调整KeepAlive设置）

@Override 
public void run() {
    logger.info("Opening Serversocket at port {}", port);
    try {
        while (!cancel) {
            socket = serverSocket.accept();
            logger.info("Client connected to Serversocket! at {}", port);
            // 连接建立后再设置KeepAlive，避免空指针
            socket.setKeepAlive(true);
            out = new BufferedOutputStream(socket.getOutputStream());
            String[] a = new String[1];
            a[0] = "AAAAAAAA";
            // 内部循环监听cancel标志，支持正常终止
            while (!cancel) {
                send(a);
                Thread.sleep(100);
            }
        }
    } catch (Exception e) {
        logger.error(e.getLocalizedMessage(), e);
        e.printStackTrace();
    }
}

3. 修复连接状态判断方法

public boolean isConnected() {
    // 综合判断：socket不为空、未关闭、且曾经建立过连接
    return socket != null && !socket.isClosed() && socket.isConnected();
}

客户端适配建议 #

如果客户端使用BufferedReader读取，需确保读取逻辑匹配服务器的输出格式：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
import java.nio.charset.StandardCharsets;

public class Client {
    public static void main(String[] args) throws Exception {
        Socket socket = new Socket("localhost", 你的端口号);
        BufferedReader in = new BufferedReader(
            new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8)
        );
        String line;
        // readLine()会读取到换行符为止，正好匹配服务器输出
        while ((line = in.readLine()) != null) {
            System.out.println("收到服务器数据：" + line);
        }
    }
}

额外注意事项 #

• 始终指定字符编码（如StandardCharsets.UTF_8），避免不同系统下的编码不一致导致乱码。
• cancel()方法中需确保流和Socket的关闭顺序：先关闭输出流，再关闭Socket，避免资源泄漏。

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