二十、观察者模式

1，基本介绍

// 抽象主题
interface Subject {
  // 注册观察者
  void registerObserver(Observer o);
  // 删除观察者
  void removeObserver(Observer o);
  // 通知观察者
  void notifyObservers();
}

（2）接着定义一个具体主题 ConcreteSubject 类，改类实现了 Subject 接口，并保存了观察者列表和状态。当状态发生改变时，它会调用 notifyObservers 方法来通知所有观察者。

// 具体主题
class ConcreteSubject implements Subject {
  // 观察者集合
  private List<Observer> observers = new ArrayList<>();

  // 当前状态
  private String state;

  // 获取当前状态
  public String getState() {
    return state;
  }

  // 修改状态
  public void changeState(String state) {
    this.state = state;
    // 通知观察者
    notifyObservers();
  }

  // 注册观察者
  @Override
  public void registerObserver(Observer o) {
    observers.add(o);
  }

  // 删除观察者
  @Override
  public void removeObserver(Observer o) {
    observers.remove(o);
  }

  // 通知观察者
  @Override
  public void notifyObservers() {
    for (Observer o : observers) {
      o.update(this.state);
    }
  }
}

（3）然后定义一个抽象观察者 Observer 接口，该接口定义了一个更新自身的方法。

// 抽象观察者
interface Observer {
  // 更新自身方法
  void update(String state);
}

（4）接着定义具体观察者 ConcreteObserver 类，该类实现了 Observer 接口，并在 update 方法中实现了对主题状态的处理逻辑。

// 具体观察者
public class ConcreteObserver implements Observer {
  // 观察者名字
  private String name;

  public ConcreteObserver(String name){
    this.name = name;
  }

  // 更新自身方法
  @Override
  public void update(String state) {
    System.out.println(this.name + "收到消息：" + state);
  }
}

（5）最后我们创建 1 个主题，2 个观察者对象测试一下：

public class Test {
  public static void main(String[] args) {
    // 定义1个主题
    ConcreteSubject subject = new ConcreteSubject();
    // 定义2个观察者
    Observer observer1 = new ConcreteObserver("用户1");
    Observer observer2 = new ConcreteObserver("用户2");
    // 注册2个观察者
    subject.registerObserver(observer1);
    subject.registerObserver(observer2);
    // 更新主题状态
    subject.changeState("Welcome to hangge.com");
    // 删除1个观察者
    subject.removeObserver(observer1);
    // 再次更新主题状态
    subject.changeState("欢迎访问 hangge.com");
  }
}

附一：JDK 中的观察者模式

1，使用 Observable 类和 Observer 接口实现观察者模式

2，使用 EventListener 接口实现观察者模式

3，javax.swing 中的观察者模式

public class Test {
  public static void main(String[] args) {
    // 创建一个窗口
    JFrame frame = new JFrame("My Window");
    frame.setLayout(new BorderLayout());
    frame.setSize(400, 300);
    frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

    // 创建一个文本字段
    JTextField textField = new JTextField();
    frame.add(textField, BorderLayout.CENTER);

    // 创建一个按钮（被观察者）
    JButton button = new JButton("点击按钮");
    frame.add(button,BorderLayout.NORTH);

    // 创建按钮监听器（观察者）
    ActionListener buttonListener = new ActionListener() {
      @Override
      public void actionPerformed(ActionEvent e) {
        textField.setText("按钮被点击!");
      }
    };

    // 将观察者 (按钮监听器) 注册到被观察者 (按钮) 上
    button.addActionListener(buttonListener);

    // 显示窗口
    frame.setVisible(true);
  }
}

附二：Spring 中的观察者模式

1，Spring 事件机制

2，Spring Web MVC