Java ServerSocket OutputStream 不刷新

Question

我的 ServerSocket (java.net.ServerSocket) 仅在我关闭 OutputStream 时刷新数据，但如果我关闭 OutputStream，它会关闭连接。这是我的代码
服务器:

ServerSocket server = new ServerSocket(7788);
Socket client = server.accept();

OutputStream os = client.getOutputStream();

os.write("Hello World".getBytes());
os.flush();
// os.close();

客户:

Socket client = new Socket("localhost", 7788);

byte[] bytes = client.getInputStream().readAllBytes();
String message = new String(bytes);

System.out.println(message);

如果我关闭 OutputStream 一切正常，但我需要为我的项目多次发送数据。有解决方案吗？

Answer 1

问题不在于 flush()在 OutputStream (服务器)，而是 readAllBytes()在 InputStream (客户)。来自 docs (强调我的):

public byte[] readAllBytes() throws IOException

Reads all remaining bytes from the input stream. This method blocks until all remaining bytes have been read and end of stream is detected, or an exception is thrown.

end of stream仅在 close() 上“发送” ，这就是为什么您只能在 close() 之后才能阅读(打印)消息的原因.
交换单行文本数据的一个非常简单的解决方案是发送由 '\n' (换行)字符分隔的消息，并在客户端部分，逐行从套接字读取，例如:Server.java

import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server
{
        public static void main(String[] args) throws Exception
        {
                ServerSocket server = new ServerSocket(7788);
                Socket client = server.accept();

                OutputStream os = client.getOutputStream();
                for (int i = 0; i < 5; i++) {
                        os.write(String.format("message %d\n", i).getBytes());
                        os.flush();

                        Thread.sleep(2000);
                }

                os.close();
        }
}

Client.java

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;

public class Client
{
        public static void main(String[] args) throws Exception
        {
                Socket client = new Socket("localhost", 7788);

                BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
                String message = null;
                while ((message = reader.readLine()) != null)
                        System.out.println(message);

                reader.close();
        }
}

$ javac Server.java Client.java
$ java Server

$ java Client
message 0
message 1
message 2
message 3
message 4
$

如果您运行上面的代码，您将看到消息一个接一个地打印(接收)，延迟 2 秒，readLine()读取 \n 后立即返回(新行)字符。
如果这对您的用例不可行，我认为您将需要一个更加结构化的协议(protocol)。