怎么实现javascript的观察者模式_它与发布订阅模式有何不同?

发布时间 - 2026-01-06 00:00:00    点击率:
观察者模式需Subject持有Observer引用并同步通知,发布-订阅通过事件中心解耦;前者适用于强绑定场景,后者适合松耦合跨模块通信。

JavaScript 中的观察者模式可以直接用对象和数组手动实现,不需要第三方库;它和发布-订阅模式的关键区别在于:观察者模式中 Subject(被观察者)必须持有 Observer(观察者)的引用,而发布-订阅模式通过事件中心解耦两者。

怎么手写一个基础的观察者模式

核心是三个角色:Subject(被观察者)、Observer(观察者)、以及它们之间的注册/通知逻辑。重点不是“多酷”,而是“谁持有谁的引用”——Subject 必须保存 Observer 实例列表,并在状态变化时主动遍历调用其 update 方法。

常见错误是把回调函数当 Observer 对象,导致无法退订;或者在 notify 里直接执行异步操作,破坏同步通知语义。

  • Observer 应是一个有 update 方法的对象,而非裸函数
  • Subjectobservers 是数组,add/remove 操作要确保引用一致(不能靠值比较)
  • notify 应同步执行,避免时序错乱;如需异步,应由调用方控制(例如包装成 setTimeout(() => subject.notify(), 0)
class Subject {
  constructor() {
    this.observers = [];
  }
  add(observer) {
    if (typeof observer.update === 'function') {
      this.observers.push(observer);
    }
  }
  remove(observer) {
    const index = this.observers.indexOf(observer);
    if (index > -1) this.observers.splice(index, 1);
  }
  notify(data) {
    this.observers.forEach(obs => obs.update(data));
  }
}

class Observer {
  constructor(name) {
    this.name = name;
  }
  update(data) {
    console.log(`${this.name} received:`, data);
  }
}

const subject = new Subject();
const obs1 = new Observer('Alice');
const obs2 = new Observer('Bob');
subject.add(obs1);
subject.add(obs2);
subject.notify({ msg: 'hello' }); // Alice 和 Bob 都会收到

发布-订阅模式用 Event Emitter 实现更自然

发布-订阅不依赖对象引用关系,而是靠字符串类型的事件名作中介。所有订阅者都向一个中央 EventEmitter 注册,发布者只管 emit,不关心谁在听。这意味着模块可以完全独立加载、销毁,不会因残留引用导致内存泄漏。

典型陷阱是忘记 off 或使用匿名函数订阅,造成重复监听或无法退订;另一个是事件名拼写不一致(比如 'data-updated''dataUpdated'),导致静默失败。

  • 事件名建议统一用小写加连字符(kebab-case),避免大小写歧义
  • 订阅时尽量传具名函数,或在闭包外保留对 handler 的引用以便退订
  • once 方法比手动 off 更安全,适合一次性响应
class EventEmitter {
  constructor() {
    this.events = {};
  }
  on(event, handler) {
    if (!this.events[event]) this.events[event] = [];
    this.events[event].push(handler);
  }
  off(event, handler) {
    if (!this.events[event]) return;
    const i = this.events[event].indexOf(handler);
    if (i > -1) this.events[event].splice(i, 1);
  }
  emit(event, ...args) {
    if (this.events[event]) {
      this.events[event].forEach(h => h(...args));
    }
  }
}

const ee = new EventEmitter();
const handler = (msg) => console.log('got:', msg);
ee.on('user-login', handler);
ee.emit('user-login', { id: 123 });
ee.off('user-login', handler); // 必须传同一个引用

什么时候该选观察者,什么时候该用发布-订阅

选观察者模式的场景非常具体:两个对象生命周期强绑定,且需要细粒度控制通知时机(例如一个 UI 组件精确响应某个 Model 字段变化)。Vue 2 的响应式系统底层就大量使用了观察者模式变体(Dep + Watcher)。

发布-订阅更适合跨模块通信,尤其是松耦合系统(如微前端、插件架构)。但要注意:过度依赖全局事件中心会让数据流难以追踪,调试成本上升。

  • 如果两个类在同一个模块内紧密协作(如 Form 和它的 ValidationRule),观察者更直白
  • 如果通知方和响应方来自不同包、甚至不同团队维护(如支付 SDK 发出 'payment-success'),发布-订阅是唯一可行选择
  • React 中的 Context + useReducer 是观察者模式的思想体现;而自定义 Hooks 封装 useEvent 则偏向发布-订阅

真正容易被忽略的是退订时机——观察者模式中忘记 remove 会导致内存泄漏;发布-订阅中忘记 off 会引发重复执行。这两者都不能靠 GC 自动清理,必须显式处理。


# vue  # react  # javascript  # java  # 前端  # go  # 回调函数  # 区别  # red 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: 原生JS实现图片轮播切换效果  Laravel 419 page expired怎么解决_Laravel CSRF令牌过期处理  ,交易猫的商品怎么发布到网站上去?  Laravel如何使用Service Provider注册服务_Laravel服务提供者配置与加载  laravel怎么用DB facade执行原生SQL查询_laravel DB facade原生SQL执行方法  Laravel如何生成API文档?(Swagger/OpenAPI教程)  怎么用AI帮你设计一套个性化的手机App图标?  制作电商网页,电商供应链怎么做?  常州企业网站制作公司,全国继续教育网怎么登录?  Laravel如何实现API资源集合?(Resource Collection教程)  活动邀请函制作网站有哪些,活动邀请函文案?  如何在云主机上快速搭建多站点网站?  QQ浏览器网页版登录入口 个人中心在线进入  Laravel如何与Inertia.js和Vue/React构建现代单页应用  python中快速进行多个字符替换的方法小结  Windows11怎样设置电源计划_Windows11电源计划调整攻略【指南】  Laravel如何使用集合(Collections)进行数据处理_Laravel Collection常用方法与技巧  Gemini怎么用新功能实时问答_Gemini实时问答使用【步骤】  如何在万网开始建站?分步指南解析  如何注册花生壳免费域名并搭建个人网站?  成都品牌网站制作公司,成都营业执照年报网上怎么办理?  Laravel如何为API生成Swagger或OpenAPI文档  如何在IIS7中新建站点?详细步骤解析  PHP 500报错的快速解决方法  大学网站设计制作软件有哪些,如何将网站制作成自己app?  如何用低价快速搭建高质量网站?  Laravel如何使用Socialite实现第三方登录?(微信/GitHub示例)  如何在宝塔面板中创建新站点?  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设?  网站制作大概多少钱一个,做一个平台网站大概多少钱?  详解vue.js组件化开发实践  黑客如何通过漏洞一步步攻陷网站服务器?  Laravel API资源(Resource)怎么用_格式化Laravel API响应的最佳实践  javascript读取文本节点方法小结  Laravel如何构建RESTful API_Laravel标准化API接口开发指南  Laravel事件和监听器如何实现_Laravel Events & Listeners解耦应用的实战教程  laravel怎么在请求结束后执行任务(Terminable Middleware)_laravel Terminable Middleware请求结束任务执行方法  免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程?  原生JS获取元素集合的子元素宽度实例  Laravel的辅助函数有哪些_Laravel常用Helpers函数提高开发效率  Thinkphp 中 distinct 的用法解析  如何快速辨别茅台真假?关键步骤解析  JS碰撞运动实现方法详解  标题:Vue + Vuex 项目中正确使用 JWT 进行身份认证的实践指南  如何续费美橙建站之星域名及服务?  laravel服务容器和依赖注入怎么理解_laravel服务容器与依赖注入解析  如何在万网自助建站平台快速创建网站?  如何在云主机快速搭建网站站点?  如何快速搭建高效服务器建站系统?  Laravel怎么为数据库表字段添加索引以优化查询