极客时间对于推广渠道会有返利优惠,比如山月在极客时间买了一门课,再把课程分享给好友购买,这时极客时间会向山月返利20元左右。
而我现在做了一个返利平台,你可以在上边通过山月的链接购买课程,此时极客时间会向我返利。为了共同学习,而你可以添加我的微信 (shanyue94),我将把极客时间给我的返利发一个红包全部返给你

# 如何使用 JS 实现一个发布订阅模式

更多描述

使用 JS 实现一个发布订阅器,Event,示例如下:

const e = new Event()

e.on('click', x => console.log(x.id))

e.once('click', x => console.log(id))

//=> 3
e.emit('click', { id: 3 })

//=> 4
e.emit('click', { id: 4 })

API 如下:

class Event {
  emit (type, ...args) {
  }

  on (type, listener) {
  }

  once (type, listener) {
  }

  off (type, listener) {
  }
}

Issue

欢迎在 Issue 中交流与讨论: Issue 631 (opens new window)

一个简单的订阅发布模式实现如下,主要有两个核心 API

  • emit: 发布一个事件
  • on: 监听一个事件
  • off: 取消一个事件监听

实现该模式,使用一个 events 维护发布的事件:

const events = {
  click: [{
    once: true,
    listener: callback,
  }, {
    listener: callback
  }]
}

具体实现代码如下所示

class Event {
  events = {}
 
  emit (type, ...args) {
    const listeners = this.events[type]
    for (const listener of listeners) {
      listener.listener(...args)
      if (listener.once) {
        this.off(type, listener.listener)
      }
    }
  }

  on (type, listener) {
    this.events[type] = this.events[type] || []
    this.events[type].push({ listener })
  }

  once (type, listener) {
    this.events[type] = this.events[type] || []
    this.events[type].push({ listener, once: true })
  }

  off (type, listener) {
    this.events[type] = this.events[type] || []
    this.events[type] = this.events[type].filter(listener => listener.listener !== listener)
  }
}

以上代码不够优雅,且有点小瑕疵,再次实现如下,代码可见 如何实现发布订阅器 - codepen (opens new window)

class Event {
  events = {}
 
  emit (type, ...args) {
    const listeners = this.events[type]
    for (const listener of listeners) {
      listener(...args)
    }
  }

  on (type, listener) {
    this.events[type] = this.events[type] || []
    this.events[type].push(listener)
  }

  once (type, listener) {
    const callback = (...args) => {
      this.off(type, callback)
      listener(...args)
    }
    this.on(type, callback)
  }

  off (type, listener) {
    this.events[type] = this.events[type] || []
    this.events[type] = this.events[type].filter(callback => callback !== listener)
  }
}

const e = new Event()

const callback = x => { console.log('Click', x.id) }
e.on('click', callback)
e.on('click', callback)

// 只打印一次
const onceCallback = x => console.log('Once Click', x.id)
e.once('click', onceCallback)
e.once('click', onceCallback)

//=> 3
e.emit('click', { id: 3 })

//=> 4
e.emit('click', { id: 4 })

关于山月

我的项目:
我的微信:shanyue94,欢迎交流
Last Updated: 7/25/2021, 7:03:19 AM