Vue源码分析4 ---- depend和watcher数据监听

2024-05-13 06:38

本文主要是介绍Vue源码分析4 ---- depend和watcher数据监听,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前面Array数据帧检测说完,下面接着说Vue数据侦测具体实现过程。下面我们说depend和watcher数据监听。
注意,本教程源码接着下面这个链接数据侦测变化继续写

Watcher和 Dep 定义

Watcher类是用来实时检测数据变化,并且通知dom变化。Watcher是一个中介,数据变化时通过Watcher中转,通知组件
Dep用来管理所有依赖

设计思路
在这里插入图片描述

看到这里,估计大都数小伙伴雾里看花。下面我们用代码手把手实现上面步骤。

1.实现 Dep 和Watcher类

把依赖手机的代码封装成一个Dep类,它专门用于管理依赖,每个Observer的实例,成员中都有一个Dep的实例
先创建 dep.js 文件

class Dep{constructor(arg) {console.log("I am Dep");}
}

然后在创建 Watcher.js 文件

class Watcher{constructor(arg) {console.log("I am watcher");}
}

修改index.html文件

<!DOCTYPE html>
<html><head><meta charset="utf-8"><title></title><script src="./index.js" type="text/javascript" charset="utf-8"></script><script src="arry.js" type="text/javascript" charset="utf-8"></script><script src="dep.js" type="text/javascript" charset="utf-8"></script><script src="watcher.js" type="text/javascript" charset="utf-8"></script></head><body></body><script type="text/javascript">var Student ={name:"Tony",year:20,grade:{math:100,chinese:45},number:[12,23,23,[123,4324,423423]]}// defineReactive(Student,"name");observe(Student);console.log(Student);// console.log(Student.number[0]);// console.log(Student.number.splice(1,0,"213"));// console.log("Student.number.pop",Student.number.push([1,2,3]));// Student.name ="Janny";// console.log(Student.name);// Student.grade.math =20;// console.log(arrayMethods)</script>
</html>
在这里插入代码片

接着修改index.js 里面 defineReactive 函数, 源码下载地址

function defineReactive(obj, key, val) {console.log("我是defineReactive", obj, key);const dep = new Dep();if (arguments.length == 2) {val = obj[key];}var childOb = observe(val);Object.defineProperty(obj, key, {enumerable: true,configurable: true,get(){console.log('%s 属性被读取了', key);return val;},set(newVal) {console.log('%s 属性被写入', key, newVal);if (val === newVal) {return;}val = newVal;childOb = observe(val);//发布订阅模式dep.notify();}})
};

Observerconstructor 函数里面我们添加一行

this.dep=new Dep();

然后执行以上代码在浏览器console可以看到,每一层 Object.__ob__ 都包含dep属性
在这里插入图片描述
我们再看流程图,我们当数据更新时,需要通知依赖,因此我们这里添加Dep.notify方法,并且在setter里面调用通知

先修改 dep.js文件夹,添加notify属性

class Dep{constructor(arg) {console.log("I am Dep");}notify(){console.log("I am Dep notify");}
}

然后修改index.js文件,修改defineReactive 方法,在set添加调用notify方法

function defineReactive(obj, key, val) {console.log("我是defineReactive", obj, key);const dep = new Dep();if (arguments.length == 2) {val = obj[key];}var childOb = observe(val);Object.defineProperty(obj, key, {enumerable: true,configurable: true,get(){console.log('%s 属性被读取了', key);return val;},set(newVal) {console.log('%s 属性被写入', key, newVal);if (val === newVal) {return;}val = newVal;childOb = observe(val);//发布订阅模式dep.notify();}})
};

然后在浏览器console输入 Student.name="GoGo",发现成功调用notify。说明object类通知依赖成功。
在这里插入图片描述
同样,我们在数组 array.js文件 Object.defineProperty 方法添加 ob.dep.notify(); 实现数组通知

methodToPatch.forEach(function(method) {console.log("forEach", method);const original = arrayProto[method];Object.defineProperty(arrayMethods, method, {emumerable: false,configurable: true,writable: true,value: function mutor(...args) {console.log("...args", ...args);const ob = this.__ob__;let inserted = [];switch (method) {case "push":case "unshift":inserted = args;break;case "splice":inserted =args.slice(2);//取splice第二个参数console.log("args:",args)console.log("inserted:",inserted)break;}if(inserted){ob.obserArray(inserted);}const result = original.apply(this, args);ob.dep.notify();return result;}})
})

到此为止我们大概写了Dep和Watcher核心框架,下面我们开始实现这两个类的核心代码。

然后我们继续写在Watcher 在Dep中读取数据,所以在原来 dep.js文件中添加以下代码

var uid = 0;
class Dep{constructor(arg) {console.log("I am Dep");this.id=uid++;this.subs = [];//这个数组里面放watcher实例}addSub(sub){this.subs.push(sub);}depend(){console.log("depend被调用了")if(Dep.target){console.log("Dep.target");this.addSub(Dep.target);}}notify(){console.log("I am Dep notify");}
}

在上面代码钟,我们在Dep内放一个subs属性,用于存watcher属性。
然后depend函数,用于watcher读取数据。
执行以上代码,我们发现每次getter读取数据,都会depend一次

在这里插入图片描述

接着我们在 Watcher 类继续添加源码。

首先我们先了解 parsePath 函数,改函数源码是,目的是获取相对于object对象的值。

function parsePath(str){var segments=str.split('.');console.log(segments,segments.length);return (obj)=>{for(let i=0;i<segments.length;i++){if(!obj) return;obj = obj[segments[i]]console.log("obj",obj);}return obj;};}

例如,想看以下代码,创建一个parsePath.html文件,输入以下代码

<!DOCTYPE html>
<html><head><meta charset="utf-8"><title></title></head><body></body><script type="text/javascript">var str='grade.math';var student={name:"fyy",age:14,grade:{Chinese:100,math:90},sanwei:{heigh:30,weigh:40}}var fn =parsePath(str);console.log(fn)fn(student)function parsePath(str){var segments=str.split('.');console.log(segments,segments.length);return (obj)=>{for(let i=0;i<segments.length;i++){if(!obj) return;obj = obj[segments[i]]console.log("obj",obj);}return obj;};}</script>
</html>

执行以上程序,可以看到运行结果是
在这里插入图片描述
说明可以得到strudent.grade.math的参数为90,填入parsePath位字符串。

下面我们具体写Watcher 类,

var uid = 0;
class Watcher{constructor(target,expression,callback) {console.log("I am watcher");this.id= uid++;this.target = target;this.getter = parsePath(expression);this.callback=callback;this.value = this.get();//触发上面this.getter}get(){console.log("I am Watcher get");//进入依赖收集阶段,让全局Dep.target 设置为Watcher本身,那么就是进入依赖收集阶段Dep.target=this;console.log("开始传递参数 Dep.target");const obj =this.target;console.log("this.target",obj);var value;try{value =this.getter(obj);console.log("get value",value);}catch(e){//TODO handle the exceptionconsole.log("can not find",obj,e)}finally{Dep.target=null;}}return value
}function parsePath(str){var segements =str.split('.');return (obj)=>{for(let i =0 ; i < segements.length; i++){if(!obj)return;obj = obj[segements[i]]}console.log("parsePath",obj)return obj;}}

然后我们在index.html代码改成

<!DOCTYPE html>
<html><head><meta charset="utf-8"><title></title><script src="./index.js" type="text/javascript" charset="utf-8"></script><script src="arry.js" type="text/javascript" charset="utf-8"></script><script src="dep.js" type="text/javascript" charset="utf-8"></script><script src="watcher.js" type="text/javascript" charset="utf-8"></script></head><body></body><script type="text/javascript">var Student ={name:"Tony",year:20,grade:{math:100,chinese:45},number:[12,23,23,[123,4324,423423]]}// defineReactive(Student,"name");observe(Student);console.log(Student);new Watcher(Student,'grade.math',(val,oldValue)=>{console.log("五星好评")console.log("watching",val,oldValue);});</script>
</html>

执行以上代码,可以得到

在这里插入图片描述
可以看到,当我们创建Watcher类的时候,参数输入需要监听的对象,参数和方法。实际上会调用Watcher.get()方法,该方法会触发对应属性 Object.defineProperty 的get方法,从而收集依赖,下面这张图可以说明Watcher如何读取数据。
这里Dep.target就是图中Window.target。
在这里插入图片描述
另外我们可以看到Dep.targe 是一个全局变量,存储Watcher.constructor属性。
在这里插入图片描述
到此为止,我们把依赖收集,依赖通知,还有Watcher读取数据已经实现了,剩下是依赖通知Watcher更新数据(notify)。

然后我们在 Wathcer类添加 update,run和getAndInvoke方法。其中getAndInvoke是核心,用于或者object对象的值并且调用callback回调函数

	update(){console.log("I am watcher update ");this.run();}run(){this.getAndInvoke(this.callback);}getAndInvoke(cb){console.log("getAndInvoke");const value =this.get();if(value!==this.value || typeof value == 'object'){const oldValue = this.value;this.value=value;cb.callback(this.target,value,oldValue)}console.log(value);}

然后我们完善Dep类notify函数。

	notify(){console.log("I am Dep notify");const subs= this.subs.slice();//浅克隆一份;for(let i=0,l=subs.length;i<l;i++){subs[i].update();console.log("subs[i]",i,subs[i]);}

该函数是通过Dep.notify通知Wathcer更新。
最后我们开始执行以下html代码

<!DOCTYPE html>
<html><head><meta charset="utf-8"><title></title><script src="./index.js" type="text/javascript" charset="utf-8"></script><script src="arry.js" type="text/javascript" charset="utf-8"></script><script src="dep.js" type="text/javascript" charset="utf-8"></script><script src="watcher.js" type="text/javascript" charset="utf-8"></script></head><body></body><script type="text/javascript">var Student ={name:"Tony",year:20,grade:{math:100,chinese:45},number:[12,23,23,[123,4324,423423]]}// defineReactive(Student,"name");observe(Student);console.log(Student);new Watcher(Student,'grade.math',(val,oldValue)=>{console.log("五星好评")console.log("watching",val,oldValue);});Student.grade.math=300;</script>
</html>

最后查看执行结果:
在这里插入图片描述

以上就是Dep和watcher实现方法,估计看到这里读者依然不懂,在这里我只是提供思路还有重写步骤方法,建议您自己重写一次,再次看这篇教程才会深有体会。

结论

依赖就是Wather。只有Watcher触发的getter才会收集依赖,哪个Watcher触发了getter,就把哪个watcher收集到Dep中。
Dep使用发布订阅模式,当数据发生变化时,会循环依赖列表,把所有的Watcher都通知一遍。
Watcher 把自己设置到全局的一个指定文职,然后读取数据,因为读取了数据,所以会触发这个数据的getter。在getter中就能得到当前正在读取数据watcher,并把这个Watcher收集到Dep 中

以下链接是本教程所有源码 dep和watcher源码地址

这篇关于Vue源码分析4 ---- depend和watcher数据监听的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/984957

相关文章

Vue3 的 shallowRef 和 shallowReactive:优化性能

大家对 Vue3 的 ref 和 reactive 都很熟悉,那么对 shallowRef 和 shallowReactive 是否了解呢? 在编程和数据结构中,“shallow”(浅层)通常指对数据结构的最外层进行操作,而不递归地处理其内部或嵌套的数据。这种处理方式关注的是数据结构的第一层属性或元素,而忽略更深层次的嵌套内容。 1. 浅层与深层的对比 1.1 浅层(Shallow) 定义

大模型研发全揭秘:客服工单数据标注的完整攻略

在人工智能(AI)领域,数据标注是模型训练过程中至关重要的一步。无论你是新手还是有经验的从业者,掌握数据标注的技术细节和常见问题的解决方案都能为你的AI项目增添不少价值。在电信运营商的客服系统中,工单数据是客户问题和解决方案的重要记录。通过对这些工单数据进行有效标注,不仅能够帮助提升客服自动化系统的智能化水平,还能优化客户服务流程,提高客户满意度。本文将详细介绍如何在电信运营商客服工单的背景下进行

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后,随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步,我们目前的解决方案是建立数据中间表。把需要检索的业务数据,统一放到一张M

这15个Vue指令,让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件,按住 Control 和回车键再显示它吗?小菜一碟: <template

关于数据埋点,你需要了解这些基本知识

产品汪每天都在和数据打交道,你知道数据来自哪里吗? 移动app端内的用户行为数据大多来自埋点,了解一些埋点知识,能和数据分析师、技术侃大山,参与到前期的数据采集,更重要是让最终的埋点数据能为我所用,否则可怜巴巴等上几个月是常有的事。   埋点类型 根据埋点方式,可以区分为: 手动埋点半自动埋点全自动埋点 秉承“任何事物都有两面性”的道理:自动程度高的,能解决通用统计,便于统一化管理,但个性化定

【 html+css 绚丽Loading 】000046 三才归元阵

前言:哈喽,大家好,今天给大家分享html+css 绚丽Loading!并提供具体代码帮助大家深入理解,彻底掌握!创作不易,如果能帮助到大家或者给大家一些灵感和启发,欢迎收藏+关注哦 💕 目录 📚一、效果📚二、信息💡1.简介:💡2.外观描述:💡3.使用方式:💡4.战斗方式:💡5.提升:💡6.传说: 📚三、源代码,上代码,可以直接复制使用🎥效果🗂️目录✍️

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

异构存储(冷热数据分离)

异构存储主要解决不同的数据,存储在不同类型的硬盘中,达到最佳性能的问题。 异构存储Shell操作 (1)查看当前有哪些存储策略可以用 [lytfly@hadoop102 hadoop-3.1.4]$ hdfs storagepolicies -listPolicies (2)为指定路径(数据存储目录)设置指定的存储策略 hdfs storagepolicies -setStoragePo

Hadoop集群数据均衡之磁盘间数据均衡

生产环境,由于硬盘空间不足,往往需要增加一块硬盘。刚加载的硬盘没有数据时,可以执行磁盘数据均衡命令。(Hadoop3.x新特性) plan后面带的节点的名字必须是已经存在的,并且是需要均衡的节点。 如果节点不存在,会报如下错误: 如果节点只有一个硬盘的话,不会创建均衡计划: (1)生成均衡计划 hdfs diskbalancer -plan hadoop102 (2)执行均衡计划 hd

【前端学习】AntV G6-08 深入图形与图形分组、自定义节点、节点动画(下)

【课程链接】 AntV G6:深入图形与图形分组、自定义节点、节点动画(下)_哔哩哔哩_bilibili 本章十吾老师讲解了一个复杂的自定义节点中,应该怎样去计算和绘制图形,如何给一个图形制作不间断的动画,以及在鼠标事件之后产生动画。(有点难,需要好好理解) <!DOCTYPE html><html><head><meta charset="UTF-8"><title>06