0

我正在编写一个 Java 客户端/服务器应用程序。它应该允许客户端向服务器发送文本数据。这种通信应该可以使用同一个连接重复多次。

我这样写：

// On a server:
ServerSocket serverSocket = new ServerSocket(port);
Socket socket = serverSocket.accept();
socket.setKeepAlive(true);
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
if (reader.ready()) {
    for (String line = reader.readLine(); line != null; line = reader.readLine()) {
        // do something with line
    }
}

// On a client:
Socket socket = new Socket(host, port);
socket.setKeepAlive(true);
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
writer.write("Some data from client to server");
writer.flush();

问题是：在客户端关闭 OutputStream 之前，我无法在服务器上读取。或者，如果它已经关闭，我无法再次在客户端上打开 OutputStream。如何连续发送和读取数据？

4

3 回答 3

2

两端需要两个线程，一个用于读取数据，另一个用于写入数据。

于 2013-07-27T10:07:34.050 回答
1

如果您的目标是通过同一个套接字连接发送许多消息，则这些消息必须由应用程序级协议分隔。换句话说，您将无法依赖任何系统调用reader.ready()或reader.readLine() == null检测服务器上消息的结尾。

实现此目的的一种方法是以字符长度开始每条消息。然后，服务器将准确读取该数量的字符，然后停止并等待新消息。另一种是定义一个特殊的字符序列来结束每条消息。服务器将通过结束当前消息的读取并返回“等待新消息”状态来响应读取该特定序列。您必须确保此序列永远不会出现在消息本身中。

于 2013-07-27T14:12:13.437 回答
1

问题是：在客户端关闭 OutputStream 之前，我无法在服务器上读取。

是的你可以。您只是无法解决 readLine() 返回 null 的情况。这不是一回事。

或者，如果它已经关闭，我无法再次在客户端上打开 OutputStream。

当然不是。您必须创建一个新的套接字。

如何连续发送和接收数据？

我不明白这个问题。您发布的代码不会尝试这样做。

于 2013-07-27T10:32:53.480 回答