java - Socket OutputStream(BufferedWriter) 不刷新消息

Question

使用一个简单的客户端，我尝试通过 Socket 的 OutputStream 发送控制台输入:

try (Socket socket = new Socket(host, port);
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in))) {

    Thread input = new Thread(() -> {
        String msg;
        try {
            while ((msg = in.readLine()) != null) {
                System.out.println(msg);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    });
    input.start();

    String msg;
    try {
        while ((msg = stdIn.readLine()) != null) {
            out.write(msg);
            out.flush(); // not flushing?
        }
    } catch (Exception e) {
        e.printStackTrace();
    }

} catch (IOException e) {
    e.printStackTrace();
}

在我发送END OF INPUT之后，我似乎在服务器端收到所有先前的尝试作为一个长String，但是流不会刷新，但是也会终止客户端。

使用 PrintWriter 而不是 BufferedWriter 会产生相同的结果。

为什么在从 std in 读取END OF INPUT(^Z) 之前数据不会消失？

Answer 1

你正在读台词，但你没有写台词。编写消息时添加行终止符。