Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
JS如何实现观察者模式_创想鸟

JS如何实现观察者模式

观察者模式的核心在于主题直接管理并通知观察者,而发布订阅模式通过事件中心解耦发布者与订阅者;在javascript中,该模式广泛应用于dom事件、状态管理、实时数据更新等场景,其实现需注意内存泄漏、通知性能、错误处理及数据传递方式,确保系统解耦性与健壮性。

JS如何实现观察者模式

JavaScript中实现观察者模式,核心在于构建一个“主题”(Subject)对象,它负责维护一个订阅者(Observer)列表,并在自身状态发生变化时,遍历这个列表并通知所有已注册的订阅者。说白了,就是让感兴趣的对象(观察者)去“监听”另一个对象(主题)的变化,一旦有变动,主题就会告诉它们。

class Subject {    constructor() {        this.observers = []; // 存储所有观察者    }    /**     * 添加一个观察者     * @param {Function} observer - 观察者函数或对象,通常是一个回调函数     */    addObserver(observer) {        if (typeof observer === 'function' && !this.observers.includes(observer)) {            this.observers.push(observer);        } else {            // 我个人觉得,这里加个简单的错误提示或者日志会更好,            // 毕竟有时候传入的可能不是函数,或者重复添加了            console.warn('Observer must be a unique function.');        }    }    /**     * 移除一个观察者     * @param {Function} observer - 要移除的观察者     */    removeObserver(observer) {        this.observers = this.observers.filter(obs => obs !== observer);    }    /**     * 通知所有观察者状态已更新     * @param {*} data - 传递给观察者的数据     */    notify(data) {        // 有时候我会考虑是否要异步通知,避免一个耗时观察者阻塞其他,        // 但对于多数前端场景,同步通知也挺常见。        this.observers.forEach(observer => {            try {                observer(data);            } catch (error) {                // 这里捕获一下观察者执行时的错误,避免一个观察者出错导致整个通知链中断                console.error('Error notifying observer:', error);            }        });    }}// 示例用法:const mySubject = new Subject();// 定义一些观察者const observerA = (data) => {    console.log('观察者A收到通知:', data);};const observerB = (data) => {    console.log('观察者B收到通知,数据是:', data);};const observerC = (data) => {    console.log('观察者C处理数据:', JSON.stringify(data));};// 注册观察者mySubject.addObserver(observerA);mySubject.addObserver(observerB);mySubject.addObserver(observerC);console.log('--- 第一次状态变化 ---');mySubject.notify({ message: 'Hello from Subject!', timestamp: Date.now() });// 移除一个观察者mySubject.removeObserver(observerB);console.log('--- 第二次状态变化(B已移除)---');mySubject.notify('新的消息');// 尝试添加一个非函数或重复的mySubject.addObserver({}); // 会有警告mySubject.addObserver(observerA); // 不会重复添加

观察者模式与发布订阅模式有何不同?

这真的是一个老生常谈的问题,但它确实很重要,因为两者概念上很接近,但在实现和职责划分上有所区别。在我看来,最核心的区别在于它们之间是否存在一个“中间人”。观察者模式中,主题(Subject)是直接知道并管理着所有观察者(Observer)的。它维护一个观察者列表,并在状态改变时直接调用这些观察者的方法。这是一种“一对多”的直接依赖关系。就像一个明星(主题)直接管理着他的粉丝俱乐部(观察者),有新动态就直接发给所有粉丝。

而发布订阅模式(Pub/Sub)则引入了一个“事件中心”或“消息代理”(Broker/Event Bus)。发布者(Publisher)不直接知道订阅者(Subscriber),它只负责向事件中心发布消息;订阅者也不直接知道发布者,它只向事件中心订阅感兴趣的消息。所有的通信都通过这个中间人来完成。这就像出版社(发布者)把书交给书店(事件中心),读者(订阅者)去书店买书,出版社和读者之间并不直接打交道。

从解耦程度上看,发布订阅模式的解耦更彻底,因为它消除了发布者和订阅者之间的直接依赖。主题(发布者)和观察者(订阅者)之间完全互不干涉。这在大型应用中特别有用,可以避免组件之间形成复杂的网状依赖。观察者模式虽然也实现了观察者和主题的解耦(观察者不需要知道主题的具体实现,只需要知道它有

notify

方法),但主题本身还是需要管理观察者的列表,这种耦合是存在的。所以,选择哪种模式,往往取决于你对系统解耦程度的需求以及复杂性考量。

在哪些实际场景中,观察者模式能发挥作用?

观察者模式在前端开发中简直是无处不在,只是我们可能不总用“观察者模式”这个词来称呼它。最直观的例子就是DOM事件处理。当你在一个按钮上添加

addEventListener

监听点击事件时,这个按钮就是主题,你的回调函数就是观察者。按钮被点击时,它会通知所有注册的监听器。这不就是典型的观察者模式吗?

再比如,单页应用中的状态管理。虽然像Redux这样的库更多地被认为是发布订阅模式(因为它有一个中央的store作为事件中心),但其内部某些机制,比如组件订阅store的变化,然后根据变化重新渲染,这本质上也是一种观察行为。如果你自己实现一个简单的全局状态管理器,让组件注册监听某个状态的变化,那这就是观察者模式的典型应用。

还有一些场景,比如:

实时数据更新: 假设你有一个图表组件,需要实时展示后端推送的数据。后端数据一更新,主题(数据服务)就通知图表组件(观察者)去刷新。UI组件间的通信: 当一个表单输入框的值改变时,可能需要另一个显示区域同步更新。输入框作为主题,显示区域作为观察者。游戏开发: 玩家角色的生命值、分数等属性变化时,可以通知UI显示、音效播放等观察者。

我觉得,只要是涉及到“当A发生变化时,B、C、D需要做出响应”这种需求,观察者模式就值得考虑。它提供了一种清晰、可维护的方式来处理这种一对多的依赖关系。

实现观察者模式时,有哪些常见的陷阱或优化考量?

实现观察者模式,虽然概念上简单,但在实际应用中还是有些细节需要注意,不然可能会引入一些问题。

一个比较常见的陷阱是内存泄漏。如果观察者没有被正确地从主题中移除,即使观察者本身已经不再被使用了(比如对应的DOM元素被移除了),主题仍然会持有对它的引用。这意味着垃圾回收器无法回收这个观察者,导致内存占用持续增加。这在单页应用中尤其常见,页面切换或者组件销毁时,忘记取消订阅是很要命的。所以,我的经验是,在组件生命周期结束时(比如React的

componentWillUnmount

useEffect

的返回函数中),一定要记得调用

removeObserver

另一个是通知的顺序和性能。如果有很多观察者,或者某个观察者的回调函数执行时间很长,同步通知可能会阻塞主线程,导致UI卡顿。这时可以考虑异步通知,比如使用

setTimeout

requestAnimationFrame

或者微任务(

Promise.resolve().then(...)

)来调度观察者的执行。这样可以把耗时操作放到事件循环的下一轮,避免阻塞。但异步通知也会带来额外的复杂性,比如如何确保通知的顺序,以及如何处理通知失败的情况。

再来就是错误处理。在我的示例代码里,我加了一个

try-catch

块来包裹观察者的执行。这是很重要的,因为如果一个观察者在执行时抛出了未捕获的错误,它可能会中断整个通知链,导致后续的观察者无法收到通知。捕获错误并记录下来,可以确保系统的健壮性。

最后,还有参数传递的考量。

notify

方法通常会传递一些数据给观察者。这些数据应该包含观察者所需的所有信息,但也要避免传递过大的对象,否则会增加内存开销和数据序列化的负担。有时候,一个简单的ID或者一个表示变化类型的枚举值就足够了,观察者可以根据这个ID再去主题那里拉取更详细的数据。这种“拉取”模式(Pull Model)与“推送”模式(Push Model)是观察者模式的两种变体,各有优缺点。推送模式简单直接,但可能传递冗余数据;拉取模式更灵活,但观察者需要主动获取数据。具体用哪种,得看实际需求。

以上就是JS如何实现观察者模式的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1514816.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
javascript怎么过滤数组中的元素
上一篇 2025年12月20日 08:42:23
js怎么操作localStorage
下一篇 2025年12月20日 08:42:37

相关推荐

  • 构建Spring自定义Kafka配置的注解式解决方案

    本文探讨了在Spring Boot应用中通过自定义注解实现Kafka配置自动化时遇到的挑战,特别是由于Bean注册时机不当导致的依赖注入失败。我们将深入分析问题根源,并提供两种核心解决方案:利用META-INF/spring.factories实现标准化的自动配置发现,以及通过ImportBeanD…

    2026年9月21日
    1100
  • SpringBoot的定时任务

    SpringBoot的定时任务SpringBoot的定时任务SpringBoot的定时任务SpringBoot的定时任务

    大家好,我是你们的老朋友全栈君。我们又见面了。 一、基于注解(@Scheduled)的定时任务 使用SpringBoot的@Scheduled注解来创建定时任务非常简单,只需几行代码就能实现。然而,@Scheduled默认是单线程运行,这意味着当启动多个任务时,一个任务的执行时间可能会影响到下一个任…

    2026年9月21日 用户投稿
    400
  • MySQL全文搜索引擎集成方案_提升文本数据搜索能力的实用指南

    MySQL全文搜索引擎集成方案_提升文本数据搜索能力的实用指南MySQL全文搜索引擎集成方案_提升文本数据搜索能力的实用指南MySQL全文搜索引擎集成方案_提升文本数据搜索能力的实用指南MySQL全文搜索引擎集成方案_提升文本数据搜索能力的实用指南

    mysql原生全文搜索功能存在明显局限,需结合外部搜索引擎才能满足复杂需求。1. mysql全文搜索适用于小数据量、简单查询场景,但分词能力弱,尤其对中文支持差,查询功能有限,无法实现模糊查询、纠错等高级功能,且性能随数据量增长显著下降。2. 外部搜索引擎如elasticsearch(es)和sph…

    2026年9月21日 用户投稿
    000
  • Android应用中实现游戏循环与UI更新的正确姿势

    本文旨在解决Android应用开发中,开发者尝试使用传统游戏循环(如while(running))导致应用无响应或崩溃的问题。核心内容是阐明Android事件驱动的UI模型,指导开发者如何正确初始化UI组件、设置事件监听器,并通过事件回调机制实现逻辑更新和UI刷新,避免阻塞主线程,确保应用的流畅运行…

    2026年9月21日
    700
  • HuggingFace的AI混合工具如何使用?开发AI模型的实用操作教程

    HuggingFace的AI混合工具核心在于其生态系统设计,通过Transformers库的统一接口、Pipelines的抽象封装、Datasets与Accelerate等工具,实现多模型组合与微调。它允许开发者将复杂任务拆解,利用预训练模型如BERT、T5等,通过Python逻辑串联不同Pipel…

    2026年9月21日
    1000
  • MySQL如何处理长时间运行的查询_避免数据库阻塞?

    MySQL如何处理长时间运行的查询_避免数据库阻塞?MySQL如何处理长时间运行的查询_避免数据库阻塞?MySQL如何处理长时间运行的查询_避免数据库阻塞?MySQL如何处理长时间运行的查询_避免数据库阻塞?

    诊断mysql慢查询需1.开启慢查询日志并设置long_query_time;2.使用explain分析sql执行情况;3.借助工具如pt-query-digest分析日志。优化涉及1.确保join字段有索引;2.优化join顺序及减少join表数;3.使用临时表、批量处理和数据分区。防止阻塞应1.…

    2026年9月21日 用户投稿
    000
  • 使用EventBus实现Android实时速度显示与后台保存教程

    本教程详细介绍了如何在Android应用中实现实时速度的显示与后台保存功能。通过利用前台服务(Foreground Service)获取位置数据,并结合EventBus库实现服务与UI界面(MainActivity)之间的实时数据通信,确保即使应用处于后台或屏幕关闭时,速度数据也能持续更新并显示在用…

    2026年9月21日
    000
  • laravel如何进行安全的SQL查询以防止注入_Laravel安全SQL查询防注入方法

    使用Eloquent和Query Builder并配合参数绑定可有效防止SQL注入。Laravel通过PDO预处理机制自动转义参数,确保安全;应避免拼接用户输入,尤其在whereRaw等原生语句中需使用?占位符绑定变量;所有用户输入均需验证,对ID类字段强制类型转换,并禁止将用户输入直接用于表名、字…

    2026年9月21日
    000
  • PHP/MySQL:高效合并订单商品并按日期分组显示

    本教程将指导如何在PHP/MySQL应用中,将同一日期的订单商品合并显示在同一行,以提高数据展示的清晰度。核心解决方案是利用MySQL的GROUP_CONCAT函数在数据库层面进行高效聚合,避免复杂的PHP逻辑处理,从而简化代码并优化性能。 订单数据展示的常见挑战 在开发在线购物平台时,通常需要向用…

    2026年9月21日
    100
  • 如何在MindSpore中训练AI大模型?华为AI框架的训练教程

    如何在MindSpore中训练AI大模型?华为AI框架的训练教程如何在MindSpore中训练AI大模型?华为AI框架的训练教程如何在MindSpore中训练AI大模型?华为AI框架的训练教程如何在MindSpore中训练AI大模型?华为AI框架的训练教程

    答案:MindSpore通过自动并行、混合精度、优化器状态分片等技术,结合Profiler工具调试性能瓶颈,实现大模型高效分布式训练。 ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无限量使用 DeepSeek R1 模型☜☜☜ 在MindSpore中训练AI大模型,核心在于巧妙地利用其…

    2026年9月21日 用户投稿
    300
  • Java ConcurrentSkipListMap在并发场景下应用

    ConcurrentSkipListMap是基于跳跃表实现的线程安全有序映射,支持高并发读写与高效范围查询,适用于需排序的并发场景,如排行榜系统;相比ConcurrentHashMap,它提供有序性与导航操作,但插入查找为O(log n),内存开销较大,适合读多写少或需区间扫描的业务。 在高并发场景…

    2026年9月21日
    100
  • MySQL数据库如何支持多租户业务_设计策略与实现?

    MySQL数据库如何支持多租户业务_设计策略与实现?MySQL数据库如何支持多租户业务_设计策略与实现?MySQL数据库如何支持多租户业务_设计策略与实现?MySQL数据库如何支持多租户业务_设计策略与实现?

    mysql 支持多租户架构的关键在于选择合适的数据隔离策略,并兼顾性能与运维管理。1. 常见方式包括共享数据库共享表(资源利用率高但隔离性差)、共享数据库独立表(平衡隔离性与维护成本)和独立数据库(隔离性强但管理复杂)。2. 租户识别需在请求前确定租户id,并自动附加到sql查询中,可通过视图或中间…

    2026年9月21日 用户投稿
    000
  • 如何使用Ribbet的AI功能裁剪图片?快速实现精准图像裁剪

    答案:Ribbet的AI裁剪功能可快速智能识别主体并推荐裁剪方案,支持手动微调与多种比例选择,结合亮度、色彩等编辑工具优化效果,适用于制作符合社交媒体尺寸要求的封面图,操作简便且大部分功能免费,适合追求效率的普通用户。 ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无限量使用 DeepS…

    2026年9月21日
    400
  • MySQL重复数据检测与清理逻辑_Sublime脚本批量处理历史冗余记录

    MySQL重复数据检测与清理逻辑_Sublime脚本批量处理历史冗余记录MySQL重复数据检测与清理逻辑_Sublime脚本批量处理历史冗余记录MySQL重复数据检测与清理逻辑_Sublime脚本批量处理历史冗余记录MySQL重复数据检测与清理逻辑_Sublime脚本批量处理历史冗余记录

    处理mysql重复数据的核心步骤是识别并清理,可使用group by或窗口函数定位重复项,再通过分批删除或倒腾法安全清理;sublime text可用于高效生成和编辑sql语句。1. 识别重复数据常用group by+having或row_number()窗口函数;2. 清理策略包括分批删除、使用临…

    2026年9月21日 用户投稿
    100
  • 怎么全选VSCode多个光标_VSCode多光标操作与批量选择文本教程

    VSCode中高效创建多光标的方法包括:Alt+Click手动添加光标,适用于不规则位置;Ctrl+Alt+方向键垂直添加光标,适合连续多行操作;Ctrl+D逐个选择匹配项,精准控制选择范围;Ctrl+Shift+L一次性选择所有匹配项,实现全局批量修改。结合查找替换和列选择模式可进一步提升编辑效率…

    2026年9月21日
    100
  • mac怎么查看具体的内存型号_mac内存型号查询方法

    首先通过“关于本机”查看内存容量与类型,再进入“系统报告”的内存页面获取各插槽的制造商、型号、部件编号和速度等详细信息,最后使用“活动监视器”分析内存使用情况以判断是否需要升级。 如果您想了解Mac设备中安装的内存具体型号和规格,但系统概览仅显示总容量,则需要通过特定工具深入查看硬件信息。以下是查询…

    2026年9月21日
    000
  • windows10如何查看S.M.A.R.T.硬盘状态_windows10硬盘S.M.A.R.T.状态查看方法

    电脑运行慢、蓝屏或文件损坏可能是硬盘故障前兆,可通过S.M.A.R.T.技术检测健康状况。1、使用WMIC命令行工具输入“wmic diskdrive get model,status”查看状态,显示Pred Fail需立即备份数据;2、CrystalDiskInfo可深度分析S.M.A.R.T.参…

    2026年9月21日
    200
  • 燕云十六声装备回收转流派技巧分享

    燕云十六声装备回收转流派技巧分享燕云十六声装备回收转流派技巧分享燕云十六声装备回收转流派技巧分享燕云十六声装备回收转流派技巧分享

    燕云十六声中,装备是角色变强的关键所在!武器、防具、饰品各具特色,品质更是分为绿、蓝、紫、金四个等级。想要高效提升战力、不浪费培养资源?那就必须掌握装备回收技巧与流派转换策略。具体怎么操作?继续往下看,实用攻略全解析助你轻松上手! 燕云十六声装备回收与转流派技巧指南 一、装备和武学的区别要分清 新手…

    2026年9月21日 用户投稿
    200
  • 分布式锁(Redis)解决数据竞争

    使用redis实现分布式锁来解决数据竞争可以通过setnx和expire命令。1)使用setnx尝试获取锁,并通过expire设置锁的过期时间防止死锁。2)释放锁时使用watch命令确保锁未被其他客户端获取。需要注意redis的单点故障、高并发性能瓶颈和锁的过期时间设置。 在处理高并发的应用场景中,…

    2026年9月21日
    000
  • 如何在Weka中处理向量属性:ARFF格式的限制与解决方案

    本文探讨了weka中arff格式对直接向量属性表示的限制,并提供了两种主要解决方案。对于时间序列数据,建议利用weka的内置时间序列分析功能。对于非时间序列数据,核心在于通过特征工程(如使用addexpression、multifilter等)将向量拆解并转换为可被weka有效处理的独立特征,以揭示…

    2026年9月21日
    000

发表回复

登录后才能评论
关注微信