Java实现同时处理客户端/服务端并保持GUI响应的方法

我正在开发一款带有GUI的Java程序，期望同时具备客户端和服务端功能，但当前程序只能处理单一任务。例如作为服务端等待客户端连接时，程序会出现界面冻结的情况。

服务端代码 #

public void server(int port) {
    try {
        try (ServerSocket server = new ServerSocket(port)) {
            serverStatus = ("Server telah dimulai di port " + port);

            while (true) {
                // Menunggu koneksi dari client
                serverStatus = ("Menunggu koneksi dari client...");
                Socket robot = server.accept();
                serverStatus = ("Terhubung");

                // Menambahkan koneksi client ke daftar koneksi
                robotSockets.add(robot);

                // Membuat thread untuk menangani setiap koneksi client
                Thread robotThread = new Thread(new ClientHandler(robot));
                robotThread.start();
            }
        }
    } catch (IOException e) {
        e.printStackTrace();
        serverStatus = "Server启动失败: " + e.getMessage();
    }
}

客户端代码 #

public void client(Consumer<String> onMessageReceived) {
    Thread clientSideThread = new Thread(() -> {
        try {
            InputStream inputStream = socket.getInputStream();
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                String message = new String(buffer, 0, bytesRead, StandardCharsets.UTF_8);
                onMessageReceived.accept(message);
            }

        } catch (IOException e) {
            e.printStackTrace();
            if (!socket.isClosed()) {
                this.statusKoneksi = "Terputus";
            }
        }
    });
    clientSideThread.start();
}

请问如何实现程序同时处理服务端监听客户端连接、客户端连接服务端的功能，且保持GUI界面响应？

核心问题是GUI操作必须在事件调度线程（EDT）执行，而阻塞IO操作（如server.accept()、inputStream.read()）绝对不能放在EDT，否则会导致界面冻结。以下是具体修复步骤：

1. 将服务端监听逻辑移出EDT #

当前server()方法如果直接从GUI按钮点击事件调用，会在EDT中执行，server.accept()是阻塞方法，会卡住整个GUI。必须把服务端的启动和监听逻辑放到单独的后台线程：

修改后的服务端代码 #

public void startServer(int port) {
    // 启动后台线程执行服务端监听
    new Thread(() -> {
        try (ServerSocket server = new ServerSocket(port)) {
            // 更新GUI状态必须切换回EDT
            SwingUtilities.invokeLater(() -> 
                serverStatus = "Server已启动在端口 " + port
            );

            while (!Thread.currentThread().isInterrupted()) {
                SwingUtilities.invokeLater(() -> 
                    serverStatus = "等待客户端连接..."
                );
                Socket robot = server.accept(); // 阻塞操作在后台线程执行，不影响GUI

                SwingUtilities.invokeLater(() -> {
                    serverStatus = "已连接";
                    robotSockets.add(robot); // 若该集合被多线程访问，需改用线程安全集合如CopyOnWriteArrayList
                });

                // 继续用单独线程处理每个客户端连接，避免阻塞监听线程
                Thread robotThread = new Thread(new ClientHandler(robot));
                robotThread.start();
            }
        } catch (IOException e) {
            SwingUtilities.invokeLater(() -> 
                serverStatus = "Server异常: " + e.getMessage()
            );
            e.printStackTrace();
        }
    }, "ServerListenerThread").start();
}

2. 确保客户端回调更新GUI时回到EDT #

客户端代码中onMessageReceived.accept(message)如果直接用来更新GUI组件（如文本框内容），会因为在后台线程执行导致线程安全问题，需在回调中切换到EDT：

修改后的客户端调用示例 #

// 启动客户端时，将GUI更新逻辑切换到EDT执行
client(message -> {
    SwingUtilities.invokeLater(() -> {
        // 此处放置GUI更新代码，比如显示收到的消息
        messageTextArea.append(message + "\n");
    });
});

3. 线程安全与资源管理 #

• 线程安全集合：如果robotSockets被多线程（监听线程、客户端处理线程、GUI线程）访问，改用CopyOnWriteArrayList或在访问时加同步锁，避免并发修改异常。
• 线程中断与资源释放：添加停止服务端/客户端功能时，需正确中断后台线程并关闭套接字资源，避免线程泄漏：

  // 停止服务端的示例方法
  public void stopServer() {
      if (server != null && !server.isClosed()) {
          try {
              server.close(); // 关闭ServerSocket会触发accept()抛出异常，终止监听线程
          } catch (IOException e) {
              e.printStackTrace();
          }
      }
      // 中断所有客户端处理线程
      for (Thread thread : clientThreads) {
          thread.interrupt();
      }
  }
  

4. JavaFX适配说明 #

如果使用JavaFX而非Swing，将SwingUtilities.invokeLater()替换为Platform.runLater()，原理一致——所有GUI操作必须在JavaFX应用线程执行。

内容的提问来源于stack exchange，提问作者Mr. x