被动侦听聊天应用程序的套接字

Question

我目前正在开发一个聊天应用程序，总体来说很简单，但是我在从客户端和服务器端接收字符串时遇到了问题。我使用一个线程被动地在套接字上监听传入的消息，这是我怀疑问题所在的地方。我这样做对吗？

来源:发送字符串的代码:

send.addActionListener(new ActionListener(){
        public void actionPerformed(ActionEvent e){
            messageBuffer = message.getText();
            out.println(messageBuffer);
            chat.append(username + ": " + messageBuffer + "\n");
            message.setText("");
        }
    });

然后我有这个被动地听（问题可能在这里）：

public void run(){
    while(true){
        try {
               messageBufferIn = in.readLine();
               System.out.println(in.readLine());
               chat.append(recipient + ": " + messageBufferIn + "\n");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

我还用这个调用线程：

public static void startChatting(){
    try {
        Thread.sleep(10);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

谢谢你能提供的任何帮助，我对线程总体来说还是新手，所以我的错误可能相当平庸。

编辑：问题是当我尝试向接收者发送消息时，没有任何通过，我可以确认它们已连接。事实上，System.out.println（in.readLine（））;根本不通过，甚至没有“空”输出。

Answer 1

我怀疑您的主要问题是您没有刷新OutputStream。您需要添加＜code＞。flush（）在您完成写入并想要发送消息之后。例如，您的ActionListener如下所示：

send.addActionListener(new ActionListener(){
    public void actionPerformed(ActionEvent e){
        messageBuffer = message.getText();
        out.println(messageBuffer);
        out.flush();
        chat.append(username + ": " + messageBuffer + "\n");
        message.setText("");
    }
});

如果您不这样做，您的< code>OutputStream将一直保持在那里，直到它的缓冲区满了(这将会有很多消息)。

Answer 2

>

您在 Swing 中遇到并发问题，Swing GUI 不知道您在后台任务上运行/打开套接字，

Swing GUI的所有更新都必须在EDT上完成，否则什么也没发生，或者你有一些例外

必须将所有更新从后台任务（在您的情况下为Runnable#Thread）包装到Swing GUI的的调用稍后

而（true）{是无尽循环放在那里布尔变量而不是true，那么你可以在你的情况下停止、启动或重新启动任何东西Socket

如果send.addActionListener（new ActionListener（）{只运行一次（如果用户通过JButton单击调用）然后使用SwingWoker打开Socket，SwingWorker很好地保证所有输出都应该在EDT上完成

Runnable#Thread和SwingWorker之间的区别在于 >被指定只运行一次