BufferedReader 在 read() 处阻塞

我试图创建一个简单的聊天程序，带有“服务器”和客户端，现在我的问题是程序在从服务器读取消息到客户端时阻塞，反之亦然。此示例解决了从客户端到服务器的消息问题。

我在服务器端的示例：

private Reader input;
private Writer output;

try {

        server = new ServerSocket(this.port);

        while (true) {

            Socket connection = server.accept();

            serverDisplay("We have a connection");

            input = new BufferedReader(new InputStreamReader(
                    connection.getInputStream()));
            output = new BufferedWriter(new OutputStreamWriter(
                    connection.getOutputStream()));

            int c;
            StringBuffer sb = new StringBuffer();

            // This is where it blocks, the input stream should return -1 at the end of the
            // stream and break the loop, but it doesnt
            while ((c = input.read()) != -1) {
                sb.append((char) c);
            }
            serverDisplay(sb.toString());
        }

    } catch (IOException e) {
        System.out.println("IO ex in the server");
    }

为了在客户端发送消息，我有以下代码：

output = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream()));

and

private void sendMessage(String message) {
    displayMessage(message);

    try {
        output.write(message);
        output.flush();
    } catch (IOException e) {
        System.out.println("IO ex at sendMessage client");
    }

}

它读取我发送的所有字符（从客户端到服务器；通过 Sys out 确认）但是当它应该读取流的末尾（-1）时，它挂在那里.

我试图在 while 循环内打印“c”以查看它返回的值，它根本不进入循环，也不会破坏它，它只是挂在那里。

我知道已经有一些与该主题相关的问题，但我还没有在其中任何一个中找到解决我的问题的方法。

奇怪的是（至少对我来说）if I use:

output = new ObjectOutputStream(connection.getOutputStream());
input = new ObjectInputStream(connection.getInputStream());

and:

while ((message = (String) input.readObject()) != null)

代替：

input = new BufferedReader(new InputStreamReader(connection.getInputStream()));
output = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream()));

And:

while ((c = input.read()) != -1) 

洞的东西有效。然而，这不是我想要的方式，通过阅读 BufferedReader/Writer、Input/OutputStreamWriter 的 API，我认为我的代码应该可以工作。

先感谢您。

在发送流（或整个套接字）关闭之前，不会到达接收端的流末尾。

output.close()发送端将导致接收端看到流结束。

如果您需要将流用于多个消息，则需要在应用程序协议中引入帧结构，以便接收者可以确定消息边界。这可以很简单，只需在每条消息中添加消息长度（以字节为单位）即可。

因为您使用字符串作为整个消息。您可以使用DataInputStream http://docs.oracle.com/javase/7/docs/api/java/io/DataInputStream.html and DataOutputStream http://docs.oracle.com/javase/7/docs/api/java/io/DataOutputStream.html流装饰器为您构建消息readUTF() and writeUTF(String). writeUTF(String)基本上通过在写入字符串之前将其长度写入流来构建字符串。readUTF()然后读取这个长度，然后知道在返回之前需要从流中读取多少数据。

Example:

Output:

DataOutputStream output = new DataOutputStream(connection.getOutputStream());

private void sendMessage(String message) {
    displayMessage(message);

    try {
        output.writeUTF(message);
        output.flush();
    } catch (IOException e) {
        System.out.println("IO ex at sendMessage client");
    }

}

Input:

DataInputStream input = new DataInputStream(connection.getInputStream());

String message = input.readUTF();

serverDispaly(message);