0

大家下午好!

我正在尝试创建一个简单的消息传递应用程序,但我找不到一个大问题的解决方案。确切地说,有两个大问题。

这里的代码:

@Override
public void run() {
    String incoming;
    try {
        while (true) {
            if (!connected)
                break;
            // READING
            if (reader.ready() && (incoming = reader.readLine()) != null) {
                notifier.putCommand(incoming, this);
                incoming = null;
            }

            // WRITING
            synchronized (messagges) {
                for (String message : messagges) {
                    System.out.println("SENDING MESSAGE TO CLIENT: " + message);
                    writer.println(message);
                }
                messagges.clear();
            }
            writer.println("b");
        }
    } catch (IOException e) {
        MyLogger.log(e);
    }
}

问题:

  1. 如果我不是每次都向客户端写入垃圾文本,(writer.println("b"))我将无法读取从它发送的 BufferedReader 上的任何消息。这怎么可能?!

  2. 在客户端,我只看到很多“b”,但在声明中发送的任何内容(writer.println(message))。这真的很奇怪,因为当我在服务器上打印 SENDING MESSAGE TO CLIENT: [...] 我在控制台中看到它,但是没有发送消息。

可能是什么问题?

4

1 回答 1

1

您需要了解缓冲的工作原理,尤其是学习使用该flush()方法来指示缓冲写入器实际发送数据。

于 2011-10-23T12:21:42.373 回答