使用多个 UI 线程运行 java 应用程序

Question

我正在尝试用 java 编写一个非常简单的客户端-服务器电子邮件项目。 我已经使用套接字编写了客户端和服务器之间的通信代码，现在我正在尝试编写一些测试代码，其中还包括一个非常简单的 UI。 我的想法是创建与我拥有的客户端一样多的线程，并且我希望每个单独的线程都开始打开一个使用 Java FX 创建的简单 UI 窗口，但我遇到了一些问题。

这是主类：

import java.io.*;

public class ClientController{
    public static void main(String args[]) throws IOException {
        ParallelClient c1=new ParallelClient("aaaa@gmail.com");
        ParallelClient c2=new ParallelClient("bbbb@gmail.com");
        c1.start();
        c2.start();
    }
}

这是 ParallelClient 类：

import ...

public class ParallelClient extends Thread{
    private String user;

    public ParallelClient(String user){
        this.user=user;
    }

    public void run(){
        ClientApp app=new ClientApp();
        try {
            app.start(new Stage());
        } catch (Exception e) {
            e.printStackTrace();
        }
        ...
    }
    ...
}

这是设置新窗口的 ClientApp 类：

import ...

public class ClientApp extends Application {

    @Override
    public void start(Stage stage) throws Exception {
        try {
            Parent root = FXMLLoader.load(getClass().getResource("ui/client-management.fxml"));
            stage.setTitle("ClientMail");
            stage.setScene(new Scene(root, 1080, 720));
            stage.show();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

当我尝试运行代码时，我遇到了以下问题，我无法理解如何解决它：

Exception in thread "Thread-0" Exception in thread "Thread-1" java.lang.NoClassDefFoundError: Could not initialize class javafx.stage.Screen
    at javafx.stage.Window.<init>(Window.java:1439)
    at javafx.stage.Stage.<init>(Stage.java:252)
    at javafx.stage.Stage.<init>(Stage.java:240)
    at model.ParallelClient.run(ParallelClient.java:25)
java.lang.ExceptionInInitializerError
    at javafx.stage.Window.<init>(Window.java:1439)
    at javafx.stage.Stage.<init>(Stage.java:252)
    at javafx.stage.Stage.<init>(Stage.java:240)
    at model.ParallelClient.run(ParallelClient.java:25)
Caused by: java.lang.IllegalStateException: This operation is permitted on the event thread only; currentThread = Thread-1
    at com.sun.glass.ui.Application.checkEventThread(Application.java:441)
    at com.sun.glass.ui.Screen.setEventHandler(Screen.java:369)
    at com.sun.javafx.tk.quantum.QuantumToolkit.setScreenConfigurationListener(QuantumToolkit.java:728)
    at javafx.stage.Screen.<clinit>(Screen.java:74)
    ... 4 more

Answer 1

正如您在问题中发布的那样，应用程序的结构存在几个问题。

Application 类代表整个应用程序的生命周期，通过调用其init()、start() 和stop() 方法进行管理。整个应用程序中应该只有一个Application 实例，并且通常这个实例是由JavaFX 启动机制创建的，因此您不应自己实例化Application 子类。

JavaFX 应用程序需要启动 JavaFX 运行时，其中包括启动 JavaFX 应用程序线程。这是通过调用静态Application.launch() 方法完成的，该方法只能调用一次。 launch() 方法启动 JavaFX 运行时，创建 Application 类的实例，调用 init()，然后在 FX 应用程序线程上调用 start()。 （在 JavaFX 9 及更高版本中，您还可以通过调用 Platform.startup() 来启动运行时，但这种用例很少见。

请注意，在您的应用程序中，没有调用 Application.launch()（或 Platform.startup()），因此 JavaFX 运行时永远不会启动。

某些操作只能在 FX 应用程序线程上执行。其中包括创建Stages 和Scenes，以及对已显示的 UI 元素属性的任何修改。因此，您不能在单独的线程中“运行每个客户端”。这是您的异常的原因：您试图在不是 FX 应用程序线程的线程上创建一个新的 Stage。

每个客户端都不需要新线程来显示 UI（如上所述，不能这样做）。您可能确实需要在单独的线程上执行每个客户端与服务器的通信（因为这些操作需要很长时间，并且您不应该阻塞 FX 应用程序线程）。您可以通过为每个客户端的服务器通信创建一个新线程或使用共享的执行器服务来实现这一点，以便每个客户端都可以从池中获取一个线程（这可能是首选方法）。

所以你的结构应该是这样的：

public class Client {

    private Parent ui ;
    private ExecutorService exec ; // for handling server communication

    private final String user ;

    public Client(String user, ExecutorService exec) {
        this.user = user ;
        this.exec = exec ;
        try {
            ui = FXMLLoader.load(getClass().getResource("ui/client-management.fxml"));
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public Client(String user) {
        this(user, Executors.newSingleThreadExecutor());
    }

    public Parent getUI() {
        return ui ;
    }

    public void showInNewWindow() {
        Scene scene = new Scene(ui);
        Stage stage = new Stage();
        stage.setScene(scene);
        stage.show();
    }

    public void checkForNewEmail() {
        Task<List<Email>> newEmailTask = new Task<>() {
            @Override
            protected List<Email> call() throws Exception {
                List<Email> newEmails = new ArrayList<>();
                // contact server and retrieve any new emails
                return newEmails ;
            }
        };
        newEmailTask.setOnSucceeded(e -> {
            List<Email> newEmails = newEmailTask.getValue();
            // update UI with new emails...
        });
        exec.submit(newEmailTask);
    }

    // etc ...
}

那么你的ClientController 类可以做这样的事情：

public class ClientController {

    private ExecutorService exec = Executors.newCachedThreadPool();

    public void startClients() {
        Client clientA = new Client("aaaa@gmail.com", exec);
        Client clientB = new Client("bbbb@gmail.com", exec);
        clientA.showInNewWindow();
        clientB.showInNewWindow();
    }
}

你的应用类可以做到

public class ClientApp extends Application {

    @Override
    public void start(Stage primaryStage) {
        ClientController controller = new ClientController();
        controller.startClients();
    }

    public static void main(String[] args) {
        Application.launch(args);
    }
}