vue 响应式,双向绑定源码解析

1、initState(vm)——初始化porps, methods, data, computed, watch

1. 地址:src/core/instance/init.js
  • 初始化porps,methods,data,computed,watch,并注入到vue实例上,并做响应式处理

2、initData或者observe方法——响应式入口

1. 地址:src/core/instance/state.js
  • 进入initState方法,对data进入处理——响应式入口
export function initState (vm: Component) {
 ......
  if (opts.data) {
    // data做响应式处理
    initData(vm)
  } else {
    observe(vm._data = {}, true /* asRootData */)
  }
......
}

3、observe(value)方法——创建Observer()对象

1. 地址:src/core/observer/index.js
  • 判断value是否是对象,不是直接返回
  • 判断value是否有ob属性,如果有返回;这样做的好处是,如果之前做过响应式处理就可以直接缓存;没有的话创建Observer对象
  • 返回Observer对象
export function observe (value: any, asRootData: ?boolean): Observer | void {
  // 判断value是否是对象
  if (!isObject(value) || value instanceof VNode) {
    return
  }
  let ob: Observer | void
  // 如果value有__ob__(observer对象)属性结束
  // 这样做的好处是,如果之前做过响应式处理就可以直接缓存
  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
  ) {
    // 创建一个Observer对象
    ob = new Observer(value)
  }
  if (asRootData && ob) {
    ob.vmCount++
  }
  return ob
}

4、Observer类——对象,数组处理入口

1. 地址:src/core/observer/index.js
  • 每个Observer类都有一个dep对象
  • 给vaule对象定义ob属性,记录当前的observer对象
  • 对象的响应式处理,调用walk(value)方法中的defineReactive(obj, keys[i])
  • 数组的响应式处理,protoAugment(value, arrayMethods)/copyAugment(value, arrayMethods, arrayKeys)
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
    // 每个Observer类都有一个dep对象
    this.dep = new Dep()
    this.vmCount = 0
    // 将实例挂载到观察对象的__ob__属性
    def(value, '__ob__', this)
    // 数组响应式处理
    if (Array.isArray(value)) {
      // 判断当前浏览器对象是否支持proto
      // protoAugment,copyAugment,重新修补会改变数组元素的方法
      if (hasProto) {
        protoAugment(value, arrayMethods)
      } else {
        copyAugment(value, arrayMethods, arrayKeys)
      }
      this.observeArray(value)
    } else {
      // 遍历对象中的每一个属性,转换成setter/getter
      this.walk(value)
    }
  }

  /**
   * Walk through all properties and convert them into
   * getter/setters. This method should only be called when
   * value type is Object.
   */
  walk (obj: Object) {
    const keys = Object.keys(obj)
    for (let i = 0; i < keys.length; i++) {
      defineReactive(obj, keys[i])
    }
  }

  /**
   * Observe a list of Array items.
   */
  observeArray (items: Array<any>) {
    for (let i = 0, l = items.length; i < l; i++) {
      observe(items[i])
    }
  }
}

5、defineReactive()方法——对象响应式处理

1. 地址: src/core/observer/index.js
  • 为每个属性创建dep对象,这的dep是为了收集依赖与每个Observer类中的dep不一样
  • 如果当前的值是对象,调用observe
  • defineProperty getter
    1. 收集依赖dep.depend(),如果有子对象,同样给子对象收集依赖
    2. 返回属性的值 return value
  • defineProperty setter
    1. 保存新值
    2. 如果新值是对象,深度监听,并返回子的observe(newVal)
    3. 派发更新(发送更新通知)dep.notify()
export function defineReactive (
  obj: Object,
  key: string,
  val: any,
  // 用户自定义函数,很少用到
  customSetter?: ?Function,
  // 是否深度监听
  shallow?: boolean
) {
  // 依赖对象实例
  const dep = new Dep()
  // 获取obj的属性描述对象,为obj定义getter,setter,configurable
  const property = Object.getOwnPropertyDescriptor(obj, key)
  // 属性不可配置,也就是不能重新用defineProperty来定义,直接返回
  if (property && property.configurable === false) {
    return
  }

  // cater for pre-defined getter/setters
  // 有可能用户有些get,set,这样就先取出来,然后重新加入派发和更新
  const getter = property && property.get
  const setter = property && property.set
  // defineReactive只传入两个值的时候,获取到val值
  if ((!getter || setter) && arguments.length === 2) {
    val = obj[key]
  }

  // 判断是否是深度监听,并将子对象属性转化为getter/setter,返回子观察对象
  let childOb = !shallow && observe(val)
  Object.defineProperty(obj, key, {
    enumerable: true,
    configurable: true,
    get: function reactiveGetter () {
      //  先获取用户传入的getter,如果有则使用用户定义的getter,没有的话就刚才设置的val值
      const value = getter ? getter.call(obj) : val
      // 收集依赖
      // 将依赖改属性的watcher对象添加到dep,将来数据发生变化时通知
      // target中存储的是watcher对象
      if (Dep.target) {
        // depend()方法是进行依赖收集,将watcher对象添加到subs数组中
        dep.depend()
        if (childOb) {
          // 给子对象添加依赖
          childOb.dep.depend()
          if (Array.isArray(value)) {
            dependArray(value)
          }
        }
      }
      return value
    },
    set: function reactiveSetter (newVal) {
      //  先获取用户传入的getter,如果有则使用用户定义的getter,没有的话就刚才设置的val值
      const value = getter ? getter.call(obj) : val
      /* eslint-disable no-self-compare */
      // 判断新值与旧值是否相同,如果新值或旧值为NaN则不执行
      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
      // 如果getter存在,setter不存在,只读,直接返回
      if (getter && !setter) return
      // setter存在,则调用,否则直接更新数值
      if (setter) {
        setter.call(obj, newVal)
      } else {
        val = newVal
      }
      // 新值是对象,深度监听,并返回子的observer对象
      childOb = !shallow && observe(newVal)
      // 派发更新(发布更新通知)
      dep.notify()
    }
  })
}

6、if(Dep.target){dep.depend()...}——收集依赖

1. 将watcher对象记录到Dep.target中
1. 地址:src/core/observer/index.js
  • Dep.target,target中存储的是watcher对象,找到watcher定义的地方,查看什么时候给Dep.target赋值
2. 地址: src/core/instance/lifecycle.js
  • new Watcher(vm,undateComponent,...)进入watcher对象
3. 地址: src/core/observer/watcher.js
  • Watcher类中,定义了很多属性,将定义的watcher对象this,存储到vue实例的watchers数组中
// 渲染watcher,侦听器watcher,计算属性watcher都会记录到_watcher中
// 将定义的watcher对象this,存储到vue实例的watchers数组中
vm._watchers.push(this)
  • 调用get方法中的pushTarget(this),this也就是当前的watcher,记录当前watcher,进入pushTarget
    watcher的get方法,每次访问属性时都会执行,首次渲染会执行,数据改变也会执行,也就是当我们访问时会收集依赖
    访问data中的成员的时候收集依赖,触发defineReactive的getter时收集依赖
// this也就是将当前的watcher对象记录下来
get () {
  pushTarget(this)
  ......
}
4. 地址:src/core/observer/dep.js
  • 入栈并将当前的watcher赋值记录Dep.target中
// 当前target用来存放目前正在使用的watcher
// 全局唯一,并且一次也只能又一个watcher被使用
Dep.target = null
const targetStack = []
// 入栈并将当前watcher赋值给Dep.target
// vue2后每个组件对应一个watcher对象,组件有嵌套,B是A的子组件,渲染A时,先渲染B组件,
// A渲染过程被挂载起来,A的watcher先存储到栈中,B渲染完,把父组件watcher出栈,然后父组件渲染
export function pushTarget (target: ?Watcher) {
  targetStack.push(target)
  Dep.target = target
}
2. dep.depend()——将watcher对象添加到dep对象的subs数组中
1. 回到地址:src/core/observer/index.js
  • 进入depend()方法
2. 地址: src/core/observer/dep.js
  • depend()方法将dep对象添加到watcher的依赖中,addDep(this)
3. 地址:src/core/observer/watcher.js
  • 主要是将watcher对象添加到了subs数组中,dep.addSub(this),添加到subs数组中
// 主要是watcher对象添加到了subs数组中
addDep (dep: Dep) {
  const id = dep.id
  if (!this.newDepIds.has(id)) {
    this.newDepIds.add(id)
    this.newDeps.push(dep)
    if (!this.depIds.has(id)) {
      dep.addSub(this)
    }
  }
}
addSub (sub: Watcher) {
  this.subs.push(sub)
}
3. 存在子对象的话,给子对象也添加依赖,目的是子对象添加和删除成员时发送通知
if (childOb) {
  // 给子对象添加依赖
  childOb.dep.depend()
  if (Array.isArray(value)) {
    dependArray(value)
  }
}

7、protoAugment(value, arrayMethods)——数组的响应式处理

1. 地址: src/core/observer/index.js
  • protoAugment(value, arrayMethods),copyAugment,arrayMethods重新修补会改变数组元素的方法
2. 地址:src/core/observer/array.js
  • 对数组,push,pop,shigt,unshift,splice,sort,reverse,这些方法会改变原数组,进行修补变成响应式,先找到数组对象的ob,然后再找到dep,调用notify()发送通知
const arrayProto = Array.prototype
// 使用数组原型创建一个新的对象
export const arrayMethods = Object.create(arrayProto)
// 修改数组元素的方法
const methodsToPatch = [
  'push',
  'pop',
  'shift',
  'unshift',
  'splice',
  'sort',
  'reverse'
]

/**
 * Intercept mutating methods and emit events
 */
// 将数组方法循环
methodsToPatch.forEach(function (method) {
  // cache original method
  // 将原数组的方法赋值给original
  const original = arrayProto[method]
  // 调用object,defineProperty()重新定义修改数组的方法
  def(arrayMethods, method, function mutator (...args) {
    // 执行数组的原始方法
    const result = original.apply(this, args)
    // 获取数组对象的ob对象
    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对象发送通知
    ob.dep.notify()
    return result
  })
})

8、watcher——dep.notify()调用watcher中的update()方法发布更新通知

1. 地址: src/core/observer/index.jssrc/core/observer/dep.js
  • dep.notify() 派发更新,调用watcher中的update()方法
notify () {
  // stabilize the subscriber list first
  const subs = this.subs.slice()
  if (process.env.NODE_ENV !== 'production' && !config.async) {
    // subs aren't sorted in scheduler if not running async
    // we need to sort them now to make sure they fire in correct
    // order
    // 排序,按照watcher的创建顺序
    subs.sort((a, b) => a.id - b.id)
  }
  for (let i = 0, l = subs.length; i < l; i++) {
    // 更新
    subs[i].update()
  }
}
2. 地址:src/core/observer/dep.js
  • update()方法中执行渲染watcher,queueWatcher(this)
update () {
  /* istanbul ignore else */
  if (this.lazy) {
    this.dirty = true
  } else if (this.sync) {
    this.run()
  } else {
    // 渲染watcher执行
    queueWatcher(this)
  }
}
3. 地址: src/core/observer/scheduler.js
  • queueWatcher(),判断watcher现在是否正在处理,如果没有放入queue队列末尾,并触发flushSchedulerQueue()
export function queueWatcher (watcher: Watcher) {
    ......
    // flushing正在处理,如果没有正在处理,就将watcher放到队列的末尾
    if (!flushing) {
      queue.push(watcher)
    } else {
      ......
    }
    // queue the flush
    if (!waiting) {
      waiting = true
      ......
      // 触发flushSchedulerQueue
      nextTick(flushSchedulerQueue)
    }
  }
}
4. 地址:src/core/observer/scheduler.js
  • 触发beforeUpdate()钩子函数
  • 调用run方法,run()->get()->触发getter(渲染watcher实际调用updateComponent位置)->updateComponent
    updateComponent会执行vm._update(vm._render())
    watcher.run()方法执行后可以在页面中看到真正的数据,这时候已经处理完成,剩下一些清理工作
// 调用run方法,watcher.run()后就可以在页面中看到真正的数据
watcher.run()
const value = this.get()
// 渲染watcher实际调用updateComponent位置
value = this.getter.call(vm, vm)
  • 清空上一次的依赖
  • 触发activated钩子函数
  • 触发updated钩子函数
// 触发beforeUpadate
if (watcher.before) {
  watcher.before()
}
......
// 调用run方法,watcher.run()后就可以在页面中看到真正的数据
watcher.run()
......
// 清空上一次的依赖
resetSchedulerState()

// 触发activated钩子函数
callActivatedHooks(activatedQueue)
// 触发updated钩子函数
callUpdatedHooks(updatedQueue)
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,905评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,140评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,791评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,483评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,476评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,516评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,905评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,560评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,778评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,557评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,635评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,338评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,925评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,898评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,142评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,818评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,347评论 2 342

推荐阅读更多精彩内容