Java ServerSocket OutputStream not flushing

Question

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

服务器：

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

问题不在于OutputStream(服务器(上的flush()，而在于InputStream(客户端(上的readAllBytes()。来自文档(强调矿(：

publicbyte[]readAllBytes((抛出IOException

从输入流中读取所有剩余字节此方法阻止直到所有剩余的字节都被读取并且流的末尾检测到，或者引发异常。

CCD_；发送"；仅在close()上，这就是为什么您只能在close()之后阅读(打印(消息。

交换单行文本数据的一个非常简单的解决方案是发送由"(新行(字符分隔的消息，在客户端部分，逐行从套接字读取，例如：

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 %dn", 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(新行(字符后立即返回。

如果这对您的用例不可行，我认为您将需要一个更结构化的协议。