摘要：發(fā)布訂閱的作用發(fā)布訂閱模式可以廣泛應(yīng)用與異步編程中，這是一種替代傳統(tǒng)回調(diào)函數(shù)的方案。發(fā)布訂閱模式讓兩個對象松散耦合地聯(lián)系在一起，雖然不清楚彼此的細(xì)節(jié)，但不影響它們之間的通信。

發(fā)布-訂閱模式又叫觀察者模式，它定義與對象間的一種一對多的關(guān)系，當(dāng)一個對象的狀態(tài)發(fā)生改變時，所有依賴與它的對象都將得到通知。

發(fā)布-訂閱模式可以廣泛應(yīng)用與異步編程中，這是一種替代傳統(tǒng)回調(diào)函數(shù)的方案。

比如訂閱ajax的succ,error等事件，只需訂閱事件發(fā)生點，而無需關(guān)注異步運行期間狀態(tài)

發(fā)布-訂閱可以取代對象之間硬編碼的通信機制，一個對象不再顯式地調(diào)用另外一個對象的某個接口。

發(fā)布-訂閱模式讓兩個對象松散耦合地聯(lián)系在一起，雖然不清楚彼此的細(xì)節(jié)，但不影響它們之間的通信。

當(dāng)有新的訂閱者出現(xiàn)時，發(fā)布者的代碼不需要任何修改；同樣發(fā)布者改變時，也不會影響到之前的訂閱者。

var event = {
    //緩存列表，存放訂閱者的回調(diào)函數(shù)
    clientList: [],
    //增加訂閱者, key:事件名，fn:回調(diào)函數(shù)
    listen: function(key, fn){
        if(!this.clientList[key]){
            this.clientList[key] = []
        }
        this.clientList[key].push(fn)
    },
    //發(fā)布消息
    trigger: function(){
        // 取出消息類型
        var key = Array.prototype.shift.call(arguments)
            // 取出消息類型對應(yīng)的回調(diào)函數(shù)集合
            fns = this.clientList[key]
        // 如果沒有訂閱該消息，則返回
        if(!fns || fns.length === 0) {
            return false
        }
        for(var i = 0, fn; fn = fns[i++];) {
            fn.apply(this, arguments)
        }
    },
    //取消訂閱
    remove: function(key, fn) {
        var fns = this.clientList[key]
        // 如果對應(yīng)的消息沒人訂閱，直接返回
        if(!fns) {    
            return false
        }
        // 如果沒有傳入回調(diào)函數(shù)，表示取消key對應(yīng)消息的所有訂閱
        if(!fn){    
            fns && (fns.length = 0)
        } else {
            for(var l = fns.length - 1; l >= 0; l--) {
                var _fn = fns[l]
                if (_fn === fn) {
                    fns.splice(l, 1)
                }
            }
        }
    }
}

var salesOffices = {}
// 給對象安裝發(fā)布-訂閱功能
var installEvent = function(obj){
    for(var i in event){
        obj[i] = event[i]
    }
}
installEvent(salesOffices)


salesOffices.listen("squareMeter88", fn1 = function(price){
    console.log("價格1："+price)
})

salesOffices.listen("squareMeter87", fn2 = function(price){
    console.log("價格2："+price)
})    

salesOffices.trigger("squareMeter88", 20000) // 價格1: 20000

salesOffices.remove("squareMeter88")

salesOffices.trigger("squareMeter88", fn1)  // 打印結(jié)果為空

其實在這個發(fā)布-訂閱模式中還存在兩個問題：

給對象多帶帶添加其實是一種資源浪費

發(fā)布者與訂閱者存在一定耦合性，至少要知道salesOffices這個對象

所以接下來實現(xiàn)一個全局的發(fā)布-訂閱對象

var Event = (function(){
    var clientList = {},
        listten,
        trigger,
        remove;
    listen = function(key, fn){
        if(!clientList[key]){
            clientList[key] = []
        }
        clientList[key].push(fn)
    }
    trigger = function(){
        var key = Array.prototype.shift.call(arguments)
            fns = clientList[key]
        if(!fns || fns.length === 0) {
            return false
        }
        for(var i = 0, fn; fn = fns[i++];) {
            fn.apply(this, arguments)
        }
    },
    remove = function(key, fn) {
        var fns = clientList[key]
        if(!fns) {    
            return false
        }
        if(!fn){    
            fns && (fns.length = 0)
        } else {
            for(var l = fns.length - 1; l >= 0; l--) {
                var _fn = fns[l]
                if (_fn === fn) {
                    fns.splice(l, 1)
                }
            }
        }
    }    
    return {
        listen,
        trigger,
        remove
    }
})()
Event.listen("squareMeter88", fn1 = function(price){ // 訂閱消息
    console.log("價格1："+price)
})
Event.trigger("squareMeter88", 20000) // 價格1: 20000

我們所了解的訂閱發(fā)布都是訂閱者必須先訂閱一個消息，隨后才能接受到發(fā)布者發(fā)布的消息。如果順序反過來，發(fā)布者先發(fā)布一條消息，而此時沒有訂閱者，無疑消息會消失。

在某些情況下，我們需要先講這條消息保存下來，等到有對象訂閱它的時候，再重新把消息發(fā)布給訂閱者，如果QQ中的離線消息，離線消息先被保存在服務(wù)器中，接收人下次登陸之后，可以從新接收到這條消息。

再假如一個商城系統(tǒng)中，獲取到用戶信息后才能渲染導(dǎo)航模塊，無疑這是一個異步的過程，不能保證ajax何時返回。所以我們需要我們發(fā)布訂閱對象擁有先發(fā)布后訂閱的能力。

為了滿足這種需要，我們要建立一個存放離線事件的堆棧，當(dāng)事件發(fā)布的時候，如果此時還沒有訂閱者來訂閱這個事件，我們暫時把發(fā)布事件的動作包裹在一個函數(shù)里，這些包裹函數(shù)被存入堆棧中，等到終于有對象來訂閱此事件，我們將遍歷堆棧并且依次執(zhí)行這些包裝函數(shù)，也就是重新發(fā)布里面的事件。當(dāng)然離線事件的生命周期只有一次，就像QQ未讀消息只會被重新閱讀一次。

全局的訂閱-發(fā)布對象里只有一個clientList來存放消息名和回調(diào)函數(shù)，我們都通過它來訂閱和發(fā)布各種消息，久而久之，難免會出現(xiàn)事件名沖突的情況，所以需要給Event對象提供創(chuàng)建命名空間的功能。

具體實現(xiàn)

var Event = (function() {

    var Event,
        _default = "default";

    Event = function() {
        var _listen,
            _trigger,
            _remove,
            _shift = [].shift,
            _unshift = [].unshift,
            namespaceCache = {},
            _create,
            each = function(arr, fn) {
                var ret;
                for (var i = 0, l = arr.length; i < l; i++) {
                    var n = arr[i];
                    ret = fn.call(n, i, n);
                }

                return ret;
            };

        _listen = function(key, fn, cache) {
            if (!cache[key]) {
                cache[key] = [];
            }
            cache[key].push(fn);
        };

        _remove = function(key, cache, fn) {
            if (cache[key]) {
                if (fn) {
                    for (var i = cache[key].length - 1; i >= 0; i--) {
                        if (cache[key][i] === fn) { 
                            // 刪除訂閱回調(diào)函數(shù)
                            cache[key].splice(i, 1);
                        }
                    }
                }
                else {
                    cache[key] = [];
                }
            }
        };

        _trigger = function() {
            var cache = _shift.call(arguments);
            var key = _shift.call(arguments);
            var args = arguments;
            var _this = this;
            var stack = cache[key];

            if (!stack || !stack.length) {
                return;
            }

            return each(stack, function() {
                return this.apply(_this, args);
            })
        };

        _create = function(namespace) {
            namespace = namespace || _default;
            var cache = {};
            var offlineStack = []; //離線事件
            var ret = {
                listen: function(key, fn, last) {
                    _listen(key, fn, cache);

                    if (offlineStack === null) {
                        return;
                    }

                    if (last === "last") {
                        offlineStack.length && offlineStack.pop()();
                    }
                    else {
                        each(offlineStack, function() {
                            this();
                        });
                    }

                    offlineStack = null;
                },
                one: function(key, fn, last) {
                    _remove(key, cache);
                    this.listen(key, fn, last);
                },
                remove: function(key, fn) {
                    _remove(key, cache, fn);
                },
                trigger: function() {
                    var fn,
                        args,
                        _this = this;

                    _unshift.call(arguments, cache);
                    args = arguments;

                    fn = function() {
                        return _trigger.apply(_this, args);
                    };

                    if (offlineStack) {
                        return offlineStack.push(fn);
                    }

                    return fn();
                }
            };

            return namespace ?
                (namespaceCache[namespace] ?
                    namespaceCache[namespace] : namespaceCache[namespace] = ret)
                : ret;
        };

        return {
            create: _create,
            one: function(key, fn, last) {
                var event = this.create();
                event.one(key, fn, last);
            },
            remove: function(key, fn) {
                var event = this.create();
                event.remove(key, fn);
            },
            listen: function(key, fn, last) {
                var event = this.create();
                event.listen(key, fn, last);
            },
            trigger: function() {
                var event = this.create();
                event.trigger.apply(this, arguments);
            }
        }
    }();

    return Event;
}());

var fn1 = function(price) {
    console.log(price);
};

// 實例
Event.listen("squareMeter88", fn1);
Event.remove("squareMeter88", fn1);

Event.listen("squareMeter88", function(price) {
    console.log("fn2: " + price);
});


Event.trigger("squareMeter88", 20000);   // fn2: 20000

時間與對象之間的解耦，應(yīng)用非常廣泛，既可以用在異步編程中，也可以幫助我們完成更松耦合的代碼編寫，從架構(gòu)上看，無論MVC還是MVVM都少不了發(fā)布-訂閱的參與

創(chuàng)建訂閱者本身要消耗一定時間和內(nèi)存，無論消息是否發(fā)生，一直存在內(nèi)存中。雖然發(fā)布-訂閱模式雖然可以弱化對象之間的聯(lián)系，但是過度使用，對象之間的必然聯(lián)系會被深埋，特別是多個訂閱者和發(fā)布者嵌套會造成難以追蹤的bug。