Vue.js数组的依赖收集

前言

前面说了 Object 数据的变化侦测方式,下面我们来看一下对 Array 型数据的变化 Vue 是如何进行侦测的。

为什么 Object 数据和 Array 型数据会有两种不同的变化侦测方式?

这是因为对于 Object 数据我们使用的是 JS 提供的对象原型上的方法 Object.defineProperty,而这个方法是对象原型上的,所以 Array 无法使用这个方法,所以我们需要对 Array 型数据设计一套另外的变化侦测机制。

万变不离其宗,虽然对 Array 型数据设计了新的变化侦测机制,但是其根本思路还是不变的。那就是:还是在获取数据时收集依赖,数据变化时通知依赖更新。

下面我们就通过源码来看看 Vue 对 Array 型数据到底是如何进行变化侦测的。

如何收集依赖

我们知道 Object 的变化时通过 setter 来追踪的,只有某个数据发生了变化,就一定会触发这个数据上的 setter。但是 Array 型数据没有 setter,怎么办?

我们试想一下,要想让 Array 型数据发生变化,那必然是操作了 Array,而 JS 中提供的操作数组的方法就那么几种,我们可以把这些方法都重写一遍,在不改变原有功能的前提下,我们为其新增一些其他功能,例如下面这个例子:

1
2
3
4
5
6
7
var arr = [1, 2, 3];
arr.push(4);
Array.prototype.newPush = function (val) {
console.log("数据变化了");
this.push(val);
};
arr.newPush(5);

在上面这个例子中,我们针对数组的原生 push 方法定义个一个新的 newPush 方法,这个 newPush 方法内部调用了原生 push 方法,这样就保证了新的 newPush 方法跟原生 push 方法具有相同的功能,而且我们还可以在新的 newPush 方法内部干一些别的事情,比如通知变化。

数组方法拦截器

基于上一小节的思想,在 Vue 中创建了一个数组方法拦截器,它拦截在数组实例与 Array.prototype 之间,在拦截器内重写了操作数组的一些方法,当数组实例使用操作数组方法时,其实使用的是拦截器中重写的方法,而不再使用 Array.prototype 上的原生方法。
源码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
// 源码位置:/src/core/observer/array.js

import { def } from "../util/index";

const arrayProto = Array.prototype;
// 创建一个对象作为拦截器
export const arrayMethods = Object.create(arrayProto);

// 改变数组自身内容的7个方法
const methodsToPatch = [
"push",
"pop",
"shift",
"unshift",
"splice",
"sort",
"reverse",
];

/**
* Intercept mutating methods and emit events
*/
methodsToPatch.forEach(function (method) {
// cache original method
const original = arrayProto[method];
def(arrayMethods, method, function mutator(...args) {
const result = original.apply(this, args);
const ob = this.__ob__;
let inserted;
switch (method) {
case "push":
case "unshift":
inserted = args;
break;
case "splice":
inserted = args.slice(2);
break;
}
if (inserted) ob.observeArray(inserted);
// notify change
ob.dep.notify();
return result;
});
});

在上面的代码中可以看出,Array 原型中可以改变数组自身内容的方法有 7 个,分别是:push,pop,shift,unshift,splice,sort,reverse。

然后创建了继承自 Array 原型的空对象 arrayMethods,接着在 arrayMethods 上使用 object.defineProperty 方法将那些可以改变数组自身的 7 个方法遍历逐个进行封装。最后,当我们使用 push 方法的时候,其实用的是 arrayMethods.push,而 arrayMethods.push 就是封装的新函数 mutator,也就后说,实标上执行的是函数 mutator,而 mutator 函数内部执行了 original 函数,这个 original 函数就是 Array.prototype 上对应的原生方法。 那么,接下来我们就可以在 mutator 函数中做一些其他的事,比如说发送变化通知。

数组拦截器使用

上面我们已经定义好了数据拦截器,下面还要把它挂载到数组实例与 Array.prototype 之间,这样拦截器才能够生效。
其实挂载不难,我们只需把数据的proto属性设置为拦截器 arrayMethods 即可,源码实现如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
export class Observer {
constructor (value: any) {
this.value = value
def(value, '__ob__', this)
if (Array.isArray(value)) {
if (hasProto) {
protoAugment(value, arrayMethods)
} else {
copyAugment(value, arrayMethods, arrayKeys)
}
this.observeArray(value)
} else {
this.walk(value)
}
}
...
}
function protoAugment (target, src: Object) {
target.__proto__ = src
}
function copyAugment (target: Object, src: Object, keys: Array<string>) {
for (let i = 0, l = keys.length; i < l; i++) {
const key = keys[i]
def(target, key, src[key])
}
}

面代码中首先判断了浏览器是否支持proto(hasProto),如果支持,则调用 protoAugment 函数把 value.proto = arrayMethods;如果不支持,则调用 copyAugment 函数把拦截器中重写的 7 个方法循环加入到 value 上。

拦截器生效以后,当数组数据再发生变化时,我们就可以在拦截器中通知变化了,也就是说现在我们就可以知道数组数据何时发生变化了,OK,以上我们就完成了对 Array 型数据的可观测。

依赖收集

把依赖收集到哪里

前面我们已经知道对象的依赖收集在 getter 中,数组数据的依赖也在 getter 中收集,而给数组数据添加 getter/setter 都是在 Observer 类中完成的,所以我们也应该在 Observer 类中收集依赖,源码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
export class Observer {
constructor (value: any) {
this.value = value
this.dep = new Dep(); // 实例化一个依赖管理器,用来收集数组依赖
def(value, '__ob__', this)
if (Array.isArray(value)) {
if (hasProto) {
protoAugment(value, arrayMethods)
} else {
copyAugment(value, arrayMethods, arrayKeys)
}
this.observeArray(value)
} else {
this.walk(value)
}
}
observeArray (items: Array<any>) {
for (let i = 0, l = items.length; i < l; i++) {
observe(items[i])
}
}
...
}

上面代码中,在 Observer 类中实例化了一个依赖管理器,用来收集数组依赖。

如何收集依赖

数组的依赖也在 getter 中收集,那么在 getter 中到底该如何收集呢?这里有一个需要注意的点,那就是依赖管理器定义在 Observer 类中,而我们需要在 getter 中收集依赖,也就是说我们必须在 getter 中能够访问到 Observer 类中的依赖管理器,才能把依赖存进去。源码是这么做的:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
export function defineReactive(
obj: Object,
key: string,
val: any,
customSetter?: ?Function,
shallow?: boolean
) {
const dep = new Dep();

const property = Object.getOwnPropertyDescriptor(obj, key);
if (property && property.configurable === false) {
return;
}

// cater for pre-defined getter/setters
const getter = property && property.get;
const setter = property && property.set;
if ((!getter || setter) && arguments.length === 2) {
val = obj[key];
}

let childOb = !shallow && observe(val);
Object.defineProperty(obj, key, {
enumerable: true,
configurable: true,
get: function reactiveGetter() {
const value = getter ? getter.call(obj) : val;
if (Dep.target) {
dep.depend();
if (childOb) {
childOb.dep.depend();
if (Array.isArray(value)) {
dependArray(value);
}
}
}
return value;
},
set: function reactiveSetter(newVal) {
const value = getter ? getter.call(obj) : val;
/* eslint-disable no-self-compare */
if (newVal === value || (newVal !== newVal && value !== value)) {
return;
}
/* eslint-enable no-self-compare */
if (process.env.NODE_ENV !== "production" && customSetter) {
customSetter();
}
// #7981: for accessor properties without setter
if (getter && !setter) return;
if (setter) {
setter.call(obj, newVal);
} else {
val = newVal;
}
childOb = !shallow && observe(newVal);
dep.notify();
},
});
}
/**
* 尝试为value创建一个0bserver实例,如果创建成功,直接返回新创建的Observer实例。
* 如果 Value 已经存在一个Observer实例,则直接返回它
*/
export function observe(value: any, asRootData: ?boolean): Observer | void {
if (!isObject(value) || value instanceof VNode) {
return;
}
let ob: Observer | void;
if (hasOwn(value, "__ob__") && value.__ob__ instanceof Observer) {
ob = value.__ob__;
} else if (
shouldObserve &&
!isServerRendering() &&
(Array.isArray(value) || isPlainObject(value)) &&
Object.isExtensible(value) &&
!value._isVue
) {
ob = new Observer(value);
}
if (asRootData && ob) {
ob.vmCount++;
}
return ob;
}

在上面代码中,我们首先通过 observe 函数为被获取的数据 arr 尝试创建一个 Observer 实例,在 observe 函数内部,先判断当前传入的数据上是否有ob属性,因为在上篇文章中说了,如果数据有ob属性,表示它已经被转化成响应式的了,如果没有则表示该数据还不是响应式的,那么就调用 new Observer(value)将其转化成响应式的,并把数据对应的 Observer 实例返回。

调用 Observer 类生成实例时,在 defineReactive 函数中,首先获取数据对应的 Observer 实例 childOb,然后在 getter 中调用 Observer 实例上依赖管理器,从而将依赖收集起来。

如何通知依赖

到现在为止,依赖已经收集好了,并且也已经存放好了,那么我们该如何通知依赖呢?

其实不难,在前文说过,我们应该在拦截器里通知依赖,要想通知依赖,首先要能访问到依赖。要访问到依赖也不难,因为我们只要能访问到被转化成响应式的数据 value 即可,因为 vaule 上的ob就是其对应的 Observer 类实例,有了 Observer 类实例我们就能访问到它上面的依赖管理器,然后只需调用依赖管理器的 dep.notify()方法,让它去通知依赖更新即可。源码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
/**
* Intercept mutating methods and emit events
*/
methodsToPatch.forEach(function (method) {
// cache original method
const original = arrayProto[method];
def(arrayMethods, method, function mutator(...args) {
const result = original.apply(this, args);
const ob = this.__ob__;
let inserted;
switch (method) {
case "push":
case "unshift":
inserted = args;
break;
case "splice":
inserted = args.slice(2);
break;
}
if (inserted) ob.observeArray(inserted);
// notify change
ob.dep.notify();
return result;
});
});

上面代码中,由于我们的拦截器是挂载到数组数据的原型上的,所以拦截器中的 this 就是数据 value,拿到 value 上的 Observer 类实例,从而你就可以调用 Observer 类实例上面依赖管理器的 dep.notify()方法,以达到通知依赖的目的。

OK,以上就基本完成了 Array 数据的变化侦测。

深度侦测

在前文所有讲的 Array 型数据的变化侦测都仅仅说的是数组自身变化的侦测,比如给数组新增一个元素或删除数组中一个元素,而在 Vue 中,不论是 Object 型数据还是 Array 型数据所实现的数据变化侦测都是深度侦测,所谓深度侦测就是不但要侦测数据自身的变化,还要侦测数据中所有子数据的变化。源码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
export class Observer {
value: any;
dep: Dep;
vmCount: number; // number of vms that have this object as root $data

constructor(value: any) {
this.value = value;
this.dep = new Dep();
this.vmCount = 0;
def(value, "__ob__", this);
if (Array.isArray(value)) {
if (hasProto) {
protoAugment(value, arrayMethods);
} else {
copyAugment(value, arrayMethods, arrayKeys);
}
this.observeArray(value);
} else {
this.walk(value);
}
}
observeArray(items: Array<any>) {
for (let i = 0, l = items.length; i < l; i++) {
observe(items[i]);
}
}
}
export function observe(value: any, asRootData: ?boolean): Observer | void {
if (!isObject(value) || value instanceof VNode) {
return;
}
let ob: Observer | void;
if (hasOwn(value, "__ob__") && value.__ob__ instanceof Observer) {
ob = value.__ob__;
} else if (
shouldObserve &&
!isServerRendering() &&
(Array.isArray(value) || isPlainObject(value)) &&
Object.isExtensible(value) &&
!value._isVue
) {
ob = new Observer(value);
}
if (asRootData && ob) {
ob.vmCount++;
}
return ob;
}

在上面代码中,对于 Array 型数据,调用了 observeArray()方法,该方法内部会遍历数组中的每一个元素,然后通过调用 observe 函数将每一个元素都转化成可侦测的响应式数据。

而对应 object 数据,在上一篇文章中我们已经在 defineReactive 函数中进行了递归操作。

数组新增元素的侦测

对于数组中已有的元素我们已经可以将其全部转化成可侦测的响应式数据了,但是如果向数组里新增一个元素的话,我们也需要将新增的这个元素转化成可侦测的响应式数据。

这个实现起来也很容易,我们只需拿到新增的这个元素,然后调用 observe 函数将其转化即可。我们知道,可以向数组内新增元素的方法有 3 个,分别是:push、unshift、splice。我们只需对这 3 中方法分别处理,拿到新增的元素,再将其转化即可。源码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
/**
* Intercept mutating methods and emit events
*/
methodsToPatch.forEach(function (method) {
// cache original method
const original = arrayProto[method];
def(arrayMethods, method, function mutator(...args) {
console.log(this);
const result = original.apply(this, args);
const ob = this.__ob__;
let inserted;
switch (method) {
case "push":
case "unshift":
inserted = args;
break;
case "splice":
inserted = args.slice(2);
break;
}
if (inserted) ob.observeArray(inserted);
// notify change
ob.dep.notify();
return result;
});
});

在上面拦截器定义代码中,如果是 push 或 unshift 方法,那么传入参数就是新增的元素;如果是 splice 方法,那么传入参数列表中下标为 2 的就是新增的元素,拿到新增的元素后,就可以调用 observe 函数将新增的元素转化成响应式的了。

总结

在本篇文章中,首先我们分析了对于 Array 型数据也在 getter 中进行依赖收集;其次我们发现,当数组数据被访问时我们轻而易举可以知道,但是被修改时我们却很难知道,为了解决这一问题,我们创建了数组方法拦截器,从而成功的将数组数据变的可观测。接着我们对数组的依赖收集及数据变化如何通知依赖进行了深入分析;最后我们发现 Vue 不但对数组自身进行了变化侦测,还对数组中的每一个元素以及新增的元素都进行了变化侦测,我们也分析了其实现原理。

参考文献