概念

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

主要角色

  • Subject: 目标
  • ConcreteSubject: 具体目标
  • Observer: 观察者
  • ConcreteObserver: 具体观察者
  1. /**
  2.  * Subject: 目标
  3.  */
  4. public abstract class AbstractTikToker {
  6.     //添加粉丝
  7.     abstract void addFans(AbstractFans fans);
  9.     //通知粉丝
  10.     abstract void notifyFans(String msg);
  11. }
  1. /**
  2.  * ConcreteSubject: 具体目标
  3.  */
  4. public class MMTikToker  extends AbstractTikToker{
  6.     //1、观察者的核心1
  7.     List<AbstractFans> fansList = new ArrayList<>();
  9.     void startSell() {
  10.         System.out.println("雷丰阳... 开始卖货...源码设计课");
  11.         notifyFans("我开始卖东西了，是源码设计课，只要666");
  12.     }
  13.     void endSell() {
  14.         System.out.println("雷丰阳... 结束卖货...源码设计课");
  15.         notifyFans("课已经卖完了，记得五星好评...");
  16.     }
  19.     @Override
  20.     void addFans(AbstractFans fans) {
  21.         fansList.add(fans);
  22.     }
  24.     //通知所有观察者
  25.     @Override
  26.     void notifyFans(String msg) {
  27.         //1、所有粉丝拿来通知
  28.         for (AbstractFans fans : fansList) {
  29.             fans.acceptMsg(msg);
  30.         }
  31.     }
  32. }
  1. /**
  2.  * Observer: 观察者
  3.  */
  4. public abstract class AbstractFans {
  6.     List<AbstractTikToker> tikTokers;//双向观察
  8.     abstract void acceptMsg(String msg);
  10.     void follow(AbstractTikToker tikToker){
  11.         //主播增粉了
  12.         tikToker.addFans(this);
  13. //        for (AbstractTikToker toker : tikTokers) {
  14. //
  15. //        }
  16.     };
  19. }
  1. /**
  2.  * ConcreteObserver: 具体观察者
  3.  */
  4. public class HumanFans extends AbstractFans {
  5.     @Override
  6.     void acceptMsg(String msg) {
  7.         System.out.println("主播说："+msg);
  8.     }
  9. }
  1. /**
  2.  *  ConcreteObserver: 具体观察者
  3.  */
  4. public class RobotFans extends AbstractFans {
  5.     @Override
  6.     void acceptMsg(String msg) {
  7.         System.out.println("呸....");
  8.     }
  9. }

应用场景

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