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

如何解决使用多个UI线程运行Java应用程序

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

这是主要课程：

import java.io.*;

public class ClientController{
    public static void main(String args[]) throws IOException {
        ParallelClient c1=new ParallelClient("[e-mail]");
        ParallelClient c2=new ParallelClient("[e-mail]");
        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

解决方法

在问题中发布应用程序时，该应用程序的结构存在一些问题。

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

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

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

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

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

因此您的结构应如下所示：

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("[e-mail]",exec);
        Client clientB = new Client("[e-mail]",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);
    }
}