java - 使用 JavaFX 的观察者模式和条形图的问题

Question

我有一个问题，我想要一个带有观察者模式自动更新系列的条形图。问题是:当调用更新函数时，图表上没有任何附加内容。这是我使用的代码:第一类是为我提供数据的类。

import java.util.Observable;

public class ChartModel extends Observable {
    private  String[] dataName;
    private static double[] data;

    public ChartModel(){
        dataName=new String[4];
        data=new double[4];
    }

    public String[] getDataName(){
        return dataName;
    } 

    public double[] getData(){
        return data;
    }

    public void setChartData(String[] d, double[] dd){
        for(int i=0; i<dataName.length; i++){
            dataName[i]=d[i];
            data[i]=dd[i];
        }
        setChanged();
        notifyObservers();
    }

    public void updateCharData(String dataName, double newData){
        int i;
        for(i=0; i<dataName.length() && !this.dataName[i].equals(dataName); i++);
        if(i<dataName.length())
            data[i]=newData;
        setChanged();
        notifyObservers();
    }
}

现在这是我的图表类:

import javafx.application.Application;
import javafx.scene.Scene;
import javafx.scene.chart.BarChart;
import javafx.scene.chart.CategoryAxis;
import javafx.scene.chart.NumberAxis;
import javafx.scene.chart.XYChart;
import javafx.stage.Stage;

import java.util.Observable;
import java.util.Observer;

public class MyBarChart extends Application implements Observer {

private String[] dataName;
private double[] data;
BarChart<String, Number> bc;

public void start(Stage stage) {
    stage.setTitle("Graphique");
    final CategoryAxis xAxis = new CategoryAxis();
    final NumberAxis yAxis = new NumberAxis();
    bc=new BarChart<String, Number>(xAxis,yAxis);
    bc.setTitle("Etudiants");
    xAxis.setLabel("Sections");
    //xAxis.setTickLabelRotation(90);
    yAxis.setLabel("Nombre d'élèves");

    Scene scene  = new Scene(bc,800,600);
    stage.setScene(scene);
    stage.show();
}

@Override
public void update(Observable o, Object arg) {
    if(o instanceof ChartModel){
        ChartModel cm=(ChartModel) o;
        dataName=cm.getDataName();
        data=cm.getData();
        for(int i=0; i<dataName.length; i++){
            System.out.println(dataName[i]+ " " +data[i]);
        }
        bc.getData().clear();
        for(int i=0; i<dataName.length; i++){
            XYChart.Series series1 = new XYChart.Series();
            series1.setName(dataName[i]);
            series1.getData().add(new XYChart.Data(data[i], dataName[i]));
            bc.getData().addAll(series1);
        }
    }
}

public static void main(String[] args){
    String[] dataName=new String[]{"Informatique","Infirmier","Kine", "Compta"};
    double[] data=new double[]{10,20,30,40};
    ChartModel cm=new ChartModel();
    launch(args);
    cm.setChartData(dataName, data);
    MyBarChart bc=new MyBarChart();
    cm.addObserver(bc);
    //cm.updateCharData("Informatique", 50);
/*        try{
        Thread.sleep(5000);
    }
    catch (InterruptedException e){//trt
        }
        cm.updateCharData("Informatique", 10);
    try{ Thread.sleep(5000); }
    catch (InterruptedException e){//trt
         }*/
  }
}

你知道我能做什么来解决这个问题吗？

非常感谢。

Answer 1

JavaFX 应用程序的(简化的)生命周期如下:

1. Application.launch被调用，这将启动工具包等。
   1. Application 的一个实例创建所使用的类。
   2. 重复的事件处理/渲染/布局等。
2. 当 JavaFX 确定它应该关闭时，它会进行一些清理并 Application.launch返回。

因此main方法中的代码在

之后

launch(args);

在GUI关闭后执行。
此外，自 Application.launch创建它自己的应用程序类实例，GUI 不会有任何更新。 (您将添加一个不同的实例作为观察者)。

另请注意，只要 JavaFX 应用程序线程上的长时间运行操作正在运行，您的应用程序就会卡住。因此，您需要确保模型的更新是在单独的线程上完成的。这还要求您确保在 JavaFX 应用程序线程上完成对 GUI 的更新(出于性能原因，JavaFX 假定仅从该线程完成对 GUI 的访问。)。

<小时/>

您的 ChartModel 的某些部分类看起来很奇怪:

• data是 static但是dataName不是
• 您似乎重新发明了轮子:您可以简单地使用 LinkedHashMap<String, Double>而不是使用 2 个数组来存储数据
• 对数据的访问不同步，导致潜在的并发问题
• Observable在 Java 9 中已弃用
• 在 updateCharData字符串参数的长度用于循环条件和 if条件

以下代码演示了从 start 开始更新方法并从单独的线程进行更新。它还改变了数据存储到 LinkedHashMap 的方式。以避免实现类似 map 的功能。

public class MyBarChart extends Application implements Observer {
    BarChart<String, Number> bc;

    public void start(Stage stage) {
        stage.setTitle("Graphique");
        final CategoryAxis xAxis = new CategoryAxis();
        final NumberAxis yAxis = new NumberAxis();
        bc = new BarChart<String, Number>(xAxis, yAxis);
        bc.setTitle("Etudiants");
        xAxis.setLabel("Sections");
        //xAxis.setTickLabelRotation(90);
        yAxis.setLabel("Nombre d'élèves");

        Scene scene = new Scene(bc, 800, 600);
        stage.setScene(scene);
        stage.show();

        initModel();
    }

    private void initModel() {
        String[] dataName = new String[]{"Informatique", "Infirmier", "Kine", "Compta"};
        double[] data = new double[]{10, 20, 30, 40};
        ChartModel cm = new ChartModel();
        cm.setChartData(dataName, data);
        cm.addObserver(this);
        new Thread(() -> {
            cm.updateCharData("Informatique", 50);
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {//trt
            }
            cm.updateCharData("Informatique", 10);
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {//trt
            }
        }).start();
    }

    @Override
    public void update(Observable o, Object arg) {
        if (o instanceof ChartModel) {
            ChartModel cm = (ChartModel) o;
            Map<String, Double> data = cm.getData();

            // make sure to read the data from the thread that does the updates
            // or make sure the data is synchronized

            final XYChart.Series<String, Number>[] series = new XYChart.Series[data.size()];

            int index = 0;
            for (Map.Entry<String, Double> entry : cm.getData().entrySet()) {
                XYChart.Series<String, Number> series1 = new XYChart.Series<>();
                series1.setName(entry.getKey());
                series1.getData().add(new XYChart.Data<>(entry.getKey(), entry.getValue()));
                series[index] = series1;
                index++;
            }

            // updates to the gui on the javafx application thread
            Platform.runLater(() -> bc.getData().setAll(series));
        }
    }

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

public class ChartModel extends Observable {

    private final Map<String, Double> data = new LinkedHashMap<>();

    public Map<String, Double> getData() {
        return data;
    }

    public void setChartData(String[] d, double[] dd) {
        if (d.length != dd.length) {
            throw new IllegalArgumentException();
        }
        for (int i = 0; i < d.length; i++) {
            data.put(d[i], dd[i]);
        }
        setChanged();
        notifyObservers();
    }

    public void updateCharData(String dataName, double newData) {
        data.put(dataName, newData);
        setChanged();
        notifyObservers();
    }
}