套接字的多线程问题

Question

我目前正在制作一个允许两个玩家通过插座的棋盘游戏。我也在尝试添加游戏聊天，但我需要一种方法让 Frame 类正常运行（Jbuttons、在 jscroll 区域中输入文本等），但也需要发送和查找传入的对象。我认为实现 runnable 将是最好的选择。 这是我的运行方法：

public void run() {
    while(running){
        Object obj = null;
        try {
            obj = connection.receiveObjects();
        } catch (ClassNotFoundException) {
            e.printStackTrace();
        } catch (IOException e){
            e.printStackTrace();
            running = false;
        if(obj != null){
            if(obj instanceof String){
                showMessage((String)obj);
            }
        }
    }

}

我的连接类只是一个服务器或客户端，并使用这些方法：

public void sendObjects(Object obj) throws IOException{
        output.writeObject(obj);
        output.flush();

}   
public Object receiveObjects() throws IOException, ClassNotFoundException{
        return input.readObject();
}

在我调用的 Frame 类的构造函数中

Thread thread = new Thread(this);  
thread.start();

希望run方法不会干扰actionPerformed方法。但令我沮丧的是，当我单击一个 jbutton（它所做的只是调用 send() 方法）时，程序冻结了，没有发送任何内容。

这是其他必要的代码：

private JTextArea textBox;
private JScrollPane pane;
private JTextArea userText;
private JScrollPane userPane;



private void send(){
    String message = "YOU- " + userText.getText();
    userText.setText("");
    String totalMessage = textBox.getText();
    textBox.setText(totalMessage + "/n" + message);
    try {
        connection.sendObjects(message);
    } catch (IOException e) {
        e.printStackTrace();
    }
}

public void showMessage(String s){
    String totalMessage = "Opponent- " + textBox.getText();
    textBox.setText(totalMessage + "/n" + s);
}

我的希望是，一旦我开始聊天，我还可以添加发送片段并调用其他方法来完成我需要的所有其他事情（通过 instanceof）。我可能可以创建一个单独的类来实现 runnable 来处理数据传输，但我希望我可以在一个类中完成所有这些，并且不明白为什么我不能。我确实花了至少一个半小时来查找多线程，但我无法弄清楚我的问题。如果我正在查看任何明显的东西，我深表歉意，但多线程和套接字远远超出了我的舒适区和 AP Comp sci 课程教育。

Answer 1

除了 UI 线程，您还需要：

1. 一个线程持续监听传入数据
2. 一个线程发送数据

你有#1但没有#2，所以修改send()方法如下：

private void send() {
    // Do the UI tasks on the UI thread
    final String message = "YOU- " + userText.getText();
    userText.setText("");
    String totalMessage = textBox.getText();
    textBox.setText(totalMessage + "\n" + message);
    // Start new thread to do the networking (send data)
    new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                connection.sendObjects(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }).start();
}