摘要：借助繼承為對(duì)象安裝發(fā)布訂閱功能根據(jù)自己需求定義一個(gè)函數(shù)供事件處理完后調(diào)用創(chuàng)建個(gè)回調(diào)函數(shù)訂閱和這個(gè)事件，并且綁定相關(guān)的完成后的函數(shù)當(dāng)兩個(gè)事件完成時(shí)候，觸發(fā)前幾行綁定的相關(guān)函數(shù)打印實(shí)現(xiàn)中一般用事件模型來(lái)代替?zhèn)鹘y(tǒng)的發(fā)布訂閱模式。

博主按：《每天一個(gè)設(shè)計(jì)模式》旨在初步領(lǐng)會(huì)設(shè)計(jì)模式的精髓，目前采用javascript（_靠這吃飯_）和python（_純粹喜歡_）兩種語(yǔ)言實(shí)現(xiàn)。誠(chéng)然，每種設(shè)計(jì)模式都有多種實(shí)現(xiàn)方式，但此小冊(cè)只記錄最直截了當(dāng)?shù)膶?shí)現(xiàn)方式 :)

每天一個(gè)設(shè)計(jì)模式之訂閱-發(fā)布模式·原文地址

本節(jié)課代碼

《每天一個(gè)設(shè)計(jì)模式·系列》地址

訂閱-發(fā)布模式定義了對(duì)象之間的一種一對(duì)多的依賴關(guān)系，當(dāng)一個(gè)對(duì)象的狀態(tài)發(fā)生改變時(shí)，所有依賴它的對(duì)象都可以得到通知。

了解過(guò)事件機(jī)制或者函數(shù)式編程的朋友，應(yīng)該會(huì)體會(huì)到“訂閱-發(fā)布模式”所帶來(lái)的“時(shí)間解耦”和“空間解耦”的優(yōu)點(diǎn)。借助函數(shù)式編程中閉包和回調(diào)的概念，可以很優(yōu)雅地實(shí)現(xiàn)這種設(shè)計(jì)模式。

訂閱-發(fā)布模式和觀察者模式概念相似，但在訂閱-發(fā)布模式中，訂閱者和發(fā)布者之間多了一層中間件：一個(gè)被抽象出來(lái)的信息調(diào)度中心。

但其實(shí)沒(méi)有必要太深究 2 者區(qū)別，因?yàn)椤禜ead First 設(shè)計(jì)模式》這本經(jīng)典書(shū)都寫(xiě)了：發(fā)布+訂閱=觀察者模式。其核心思想是狀態(tài)改變和發(fā)布通知。在此基礎(chǔ)上，根據(jù)語(yǔ)言特性，進(jìn)行實(shí)現(xiàn)即可。

python 中我們定義一個(gè)事件類Event, 并且為它提供 事件監(jiān)聽(tīng)函數(shù)、（事件完成后）觸發(fā)函數(shù)，以及事件移除函數(shù)。任何類都可以通過(guò)繼承這個(gè)通用事件類，來(lái)實(shí)現(xiàn)“訂閱-發(fā)布”功能。

class Event:
  def __init__(self):
    self.client_list = {}

  def listen(self, key, fn):
    if key not in self.client_list:
      self.client_list[key] = []
    self.client_list[key].append(fn)

  def trigger(self, *args, **kwargs):
    fns = self.client_list[args[0]]

    length = len(fns)
    if not fns or length == 0:
      return False

    for fn in fns:
      fn(*args[1:], **kwargs)

    return False

  def remove(self, key, fn):
    if key not in self.client_list or not fn:
      return False

    fns = self.client_list[key]
    length = len(fns)

    for _fn in fns:
      if _fn == fn:
        fns.remove(_fn)

    return True

# 借助繼承為對(duì)象安裝 發(fā)布-訂閱 功能
class SalesOffice(Event):
  def __init__(self):
    super().__init__()

# 根據(jù)自己需求定義一個(gè)函數(shù)：供事件處理完后調(diào)用
def handle_event(event_name):
  def _handle_event(*args, **kwargs):
    print("Price is", *args, "at", event_name)

  return _handle_event


if __name__ == "__main__":
  # 創(chuàng)建2個(gè)回調(diào)函數(shù)
  fn1 = handle_event("event01")
  fn2 = handle_event("event02")

  sales_office = SalesOffice()

  # 訂閱event01 和 event02 這2個(gè)事件，并且綁定相關(guān)的 完成后的函數(shù)
  sales_office.listen("event01", fn1)
  sales_office.listen("event02", fn2)

  # 當(dāng)兩個(gè)事件完成時(shí)候，觸發(fā)前幾行綁定的相關(guān)函數(shù)
  sales_office.trigger("event01", 1000)
  sales_office.trigger("event02", 2000)

  sales_office.remove("event01", fn1)

  # 打?。篎alse
  print(sales_office.trigger("event01", 1000))

JS 中一般用事件模型來(lái)代替?zhèn)鹘y(tǒng)的發(fā)布-訂閱模式。任何一個(gè)對(duì)象的原型鏈被指向Event的時(shí)候，這個(gè)對(duì)象便可以綁定自定義事件和對(duì)應(yīng)的回調(diào)函數(shù)。

const Event = {
  clientList: {},

  // 綁定事件監(jiān)聽(tīng)
  listen(key, fn) {
    if (!this.clientList[key]) {
      this.clientList[key] = [];
    }
    this.clientList[key].push(fn);
    return true;
  },

  // 觸發(fā)對(duì)應(yīng)事件
  trigger() {
    const key = Array.prototype.shift.apply(arguments),
      fns = this.clientList[key];

    if (!fns || fns.length === 0) {
      return false;
    }

    for (let fn of fns) {
      fn.apply(null, arguments);
    }

    return true;
  },

  // 移除相關(guān)事件
  remove(key, fn) {
    let fns = this.clientList[key];

    // 如果之前沒(méi)有綁定事件
    // 或者沒(méi)有指明要移除的事件
    // 直接返回
    if (!fns || !fn) {
      return false;
    }

    // 反向遍歷移除置指定事件函數(shù)
    for (let l = fns.length - 1; l >= 0; l--) {
      let _fn = fns[l];
      if (_fn === fn) {
        fns.splice(l, 1);
      }
    }

    return true;
  }
};

// 為對(duì)象動(dòng)態(tài)安裝 發(fā)布-訂閱 功能
const installEvent = obj => {
  for (let key in Event) {
    obj[key] = Event[key];
  }
};

let salesOffices = {};
installEvent(salesOffices);

// 綁定自定義事件和回調(diào)函數(shù)

salesOffices.listen(
  "event01",
  (fn1 = price => {
    console.log("Price is", price, "at event01");
  })
);

salesOffices.listen(
  "event02",
  (fn2 = price => {
    console.log("Price is", price, "at event02");
  })
);

salesOffices.trigger("event01", 1000);
salesOffices.trigger("event02", 2000);

salesOffices.remove("event01", fn1);

// 輸出: false
// 說(shuō)明刪除成功
console.log(salesOffices.trigger("event01", 1000));

維基百科·訂閱-發(fā)布模式

觀察者模式和訂閱-發(fā)布模式的不同

《JavaScript 設(shè)計(jì)模式和開(kāi)發(fā)實(shí)踐》