观察者(Observer)模式的定义:指多个对象间存在一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式,它是对象行为型模式。

观察者模式是一种对象行为型模式,其主要优点如下。

  1. 降低了目标与观察者之间的耦合关系,两者之间是抽象耦合关系。符合依赖倒置原则。
  2. 目标与观察者之间建立了一套触发机制。


它的主要缺点如下。

  1. 目标与观察者之间的依赖关系并没有完全解除,而且有可能出现循环引用。
  2. 当观察者对象很多时,通知的发布会花费很多时间,影响程序的效率。

    模式的结构与实现

    实现观察者模式时要注意具体目标对象和具体观察者对象之间不能直接调用,否则将使两者之间紧密耦合起来,这违反了面向对象的设计原则。

1. 模式的结构

观察者模式的主要角色如下。

  1. 抽象主题(Subject)角色:也叫抽象目标类,它提供了一个用于保存观察者对象的聚集类和增加、删除观察者对象的方法,以及通知所有观察者的抽象方法。
  2. 具体主题(Concrete Subject)角色:也叫具体目标类,它实现抽象目标中的通知方法,当具体主题的内部状态发生改变时,通知所有注册过的观察者对象。
  3. 抽象观察者(Observer)角色:它是一个抽象类或接口,它包含了一个更新自己的抽象方法,当接到具体主题的更改通知时被调用。
  4. 具体观察者(Concrete Observer)角色:实现抽象观察者中定义的抽象方法,以便在得到目标的更改通知时更新自身的状态。

1 定义一个监听器接口

  1. public interface EventListener {
  2. void handlerBell(RingEvent ringEvent);
  3. }

2 定义一个具体的监听器1

  1. public class StuEventListener implements EventListener{
  2. @Override
  3. public void handlerBell(RingEvent ringEvent) {
  4. if (ringEvent.isFlag()) {
  5. System.out.println("同学:老师要来上课了...");
  6. } else {
  7. System.out.println("同学:老师下课时间到了...");
  8. }
  9. }
  10. }

定义一个具体监听器2

  1. public class TeaEventListener implements EventListener {
  2. @Override
  3. public void handlerBell(RingEvent ringEvent) {
  4. if (ringEvent.isFlag()) {
  5. System.out.println("老师:同学们该上课了...");
  6. } else {
  7. System.out.println("老师:同学们下课时间到了...");
  8. }
  9. }
  10. }

3 定义一个handler

  1. public class Target {
  2. private List<EventListener> listeners = new ArrayList<>();
  3. public void add(EventListener listener) {
  4. listeners.add(listener);
  5. }
  6. public void ringBell(boolean flag) {
  7. String type = flag ? "上课铃" : "下课铃";
  8. System.out.println(type + "响了 ");
  9. notifyBell(new RingEvent(flag));
  10. }
  11. public void notifyBell(RingEvent ringEvent) {
  12. EventListener eventListener = null;
  13. Iterator<EventListener> t = listeners.iterator();
  14. while (t.hasNext()) {
  15. eventListener = t.next();
  16. eventListener.handlerBell(ringEvent);
  17. }
  18. }
  19. }

4 实体类

  1. public class RingEvent {
  2. private boolean flag;
  3. public RingEvent(boolean flag) {
  4. this.flag = flag;
  5. }
  6. public boolean isFlag() {
  7. return flag;
  8. }
  9. public void setFlag(boolean flag) {
  10. this.flag = flag;
  11. }
  12. }

5 测试

  1. public class Test {
  2. public static void main(String[] args) {
  3. Target target = new Target();
  4. target.add(new StuEventListener());
  5. target.add(new TeaEventListener());
  6. target.ringBell(false);
  7. System.out.println("==========");
  8. target.ringBell(false);
  9. }
  10. }

输出:

  1. 下课铃响了
  2. 同学:老师下课时间到了...
  3. 老师:同学们下课时间到了...
  4. ==========
  5. 下课铃响了
  6. 同学:老师下课时间到了...
  7. 老师:同学们下课时间到了...