描述

观察者模式(Observer Pattern)：定义对象间的一种一对多依赖关系，使得每当一个对象状态发生改变时，其相关依赖对象皆得到通知并被自动更新。观察者模式又叫做发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。对象行为型模式
image.png

主要角色

  • Subject: 目标
  • ConcreteSubject: 具体目标
  • Observer: 观察者
  • ConcreteObserver: 具体观察者

代码实现

  1. 观察者
  2. public abstract class AbstractAnchor {
  4.     abstract void addFan(AbstractFan fan);
  5. }
  1. public class LshadAnchor extends AbstractAnchor {
  3.     private List<AbstractFan> fans = new ArrayList<>();
  5.     public void startBroadcast() {
  6.         System.out.println("开播了 通知粉丝");
  7.         for (AbstractFan fan : fans) {
  8.             fan.notificationCallback();
  9.         }
  10.     }
  12.     public void downcast() {
  13.         System.out.println("下播了 通知粉丝");
  14.         for (AbstractFan fan : fans) {
  15.             fan.notificationCallback();
  16.         }
  17.     }
  19.     @Override
  20.     void addFan(AbstractFan fan) {
  21.         fans.add(fan);
  22.     }
  23. }
  1. public abstract class AbstractFan {
  3.     abstract void subscribeToTheHost(AbstractAnchor abstractAnchor);
  5.     abstract void notificationCallback();
  6. }
  1. public class HumanFans extends AbstractFan{
  3.     @Override
  4.     void subscribeToTheHost(AbstractAnchor abstractAnchor) {
  5.         abstractAnchor.addFan(this);
  6.     }
  8.     @Override
  9.     void notificationCallback() {
  10.         System.out.println("呸...");
  11.     }
  12. }
  1. public class RobotFans extends AbstractFan{
  2.     @Override
  3.     void subscribeToTheHost(AbstractAnchor abstractAnchor) {
  4.         abstractAnchor.addFan(this);
  5.     }
  7.     @Override
  8.     void notificationCallback() {
  9.         System.out.println("来了臭弟弟");
  10.     }
  11. }
  1. public class ObserverTest {
  2.     public static void main(String[] args) {
  3.         LshadAnchor lshadAnchor = new LshadAnchor();
  5.         HumanFans humanFans = new HumanFans();
  6.         RobotFans robotFans = new RobotFans();
  7.         humanFans.subscribeToTheHost(lshadAnchor);
  8.         robotFans.subscribeToTheHost(lshadAnchor);
  10.         lshadAnchor.startBroadcast();
  12.         lshadAnchor.downcast();
  14.     }
  15. }
  16. //测试结果
  17. 开播了 通知粉丝
  18. 呸...
  19. 来了臭弟弟
  20. 下播了 通知粉丝
  21. 呸...
  22. 来了臭弟弟

使用场景

什么场景用到？

  • Spring事件机制如何实现？
  • Vue的双向绑定核心响应式编程核心思想
  • ……