Java 事件系统/观察者模式

Question

我查看了 Java 中观察者模式的许多实现，但似乎没有一个能完全按照我的意愿运行。

在我熟悉的编程语言中，可以创建一个事件对象，该对象可以由侦听器“连接”到，并由可观察对象“触发”。示例见下面的伪代码。

class MyObservable {
  
  public Event myEvent1
  public Event myEvent2


  public fireEvent1() {
    myEvent1:Fire()
  }

  public fireEvent2() {
    myEvent2:Fire()
  }
}

class MainClass {

  private onMyEvent1() {
    print("my event 1 fired")
  }

  private onMyEvent2() {
    print("my event 2 fired")
  }

  public MainClass() {
      myObservable = new MyObservable()

      // Pass in the function that i want to be called
      // when myEvent1 is fired.
      myObservable.myEvent1.Connect(onMyEvent1)

      // Pass in the function that i want to be called
      // when myEvent2 is fired.
      myObservable.myEvent1.Connect(onMyEvent2)
  } 

}

我在 Java 中看到的所有实现都需要我为每个事件创建一个单独的接口。这似乎非常费力。我也有监听许多事件的类，这意味着我的监听器实现了多达 10 个接口，这对我来说似乎不正确。在 Java 中真的没有更好/更快的方法来实现观察者模式吗？

非常感谢上述伪代码中 Java 中的最小等效代码，或者只是指向 Java 中观察者模式的良好实现的链接！

编辑：我忘了提到可以将可变数量的参数传递给 fire() 方法（抱歉，不是在伪代码实现中！）。

例如在myEvent1.fire(5,3)中，数字5和3可以用在fireEvent1(int num1, int num2)中

Answer 1

以下是您的伪代码的直接翻译（请注意，该代码不是线程安全的），并且可以合理地完成您似乎想要的工作。需要明确的是，这不一定是最好的解决方案，各种 Java 框架都提供了不同的方法来定义和处理事件。

public class Event {
  private final List<Runnable> handlers = new ArrayList<>();

  public void connect(Runnable handler) {
    handlers.add(handler);
  }

  public void fire() {
    for (Runnable handler : new ArrayList<>(handlers)) {
      handler.run();
    }
  }
}

Event 使用基本的Runnable 接口在事件触发时执行操作。

class MyObservable {
  
  public Event myEvent1
  public Event myEvent2

  public fireEvent1() {
    myEvent1.fire()
  }

  public fireEvent2() {
    myEvent2.fire()
  }
}

class MainClass {

  private onMyEvent1() {
    print("my event 1 fired")
  }

  private onMyEvent2() {
    print("my event 2 fired")
  }

  public MainClass() {
      myObservable = new MyObservable()

      myObservable.myEvent1.connect(this::onMyEvent1)

      myObservable.myEvent1.connect(this::onMyEvent2)
  } 
}

Main 使用方法引用创建Runnable 实现，以便其方法注册到Event。

Answer 2

PropertyChangeSupport 将是一个选项。已经存在多个事件系统，以及添加此类功能的库（例如，通过注释，因此您不必自己编写锅炉代码）。 EventListenerList 将是另一个现有系统 - 请查看 AbstractTableModel 以获取使用示例。

import java.beans.PropertyChangeListener;
import java.beans.PropertyChangeSupport;

public class Model {
  private PropertyChangeSupport support = new PropertyChangeSupport(this);
  private String                field1  = "";

  public void setField1(String newValue) {
    String oldValue = this.field1;
    this.field1 = newValue;
    support.firePropertyChange("field1", oldValue, newValue);
  }

  public void addField1Listener(PropertyChangeListener listener) {
    support.addPropertyChangeListener("field1", listener);
  }

  public void removeField1Listener(PropertyChangeListener listener) {
    support.removePropertyChangeListener("field1", listener);
  }

  public static void main(String[] args) {
    Model model = new Model();
    model.addField1Listener(e -> System.out.println("field1 changed to: " + model.field1));
    model.setField1("new");
  }
}