JavaScript設計模式之發佈-訂閱模式（觀察者模式）-Part2

時間 2019-11-07

標籤 javascript 設計模式發佈訂閱觀察者 part2 欄目 JavaScript 简体版

原文原文鏈接

《JavaScript設計模式與開發實踐》讀書筆記。ajax

看此文章前，建議先看JavaScript設計模式之發佈-訂閱模式（觀察者模式）-Part1算法

在Part1中，已經介紹了什麼是發佈-訂閱模式，同時，也實現了發佈-訂閱模式。可是，就Part1中實現的例子來講，仍是存在了兩個小問題：segmentfault

咱們給每一個發佈者對象都添加了listen和trigger方法，以及一個緩存列表clientList，這實際上是一種資源的浪費。設計模式
訂閱者與發佈者之間存在必定的耦合性，訂閱者至少要知道發佈者對象的名字，才能順利訂閱。以下：緩存

// 張三訂閱問題A, sgQuestionSystem是發佈者的對象（問題系統）
sgQuestionSystem.listen('questionA', 3, function(questionTitle, content) {
    console.log('張三您在早前訂閱了問題：questionA');
    console.log('現' + questionTitle + '有了新動態');
    console.log('內容爲：' + content);
});

若是張三還對其它東西感興趣，而發佈者又不是同一個，那麼，這意味着張三須要再對另外一個發佈者對象進行訂閱。以下：數據結構

// 張三訂閱文章A動態, sgArticleSystem是發佈者的對象（文章系統）
sgArticleSystem.listen('articleA', 3, function(articleTitle, content) { 
    console.log('張三您在早前訂閱了文章：articleA');
    console.log('現' + articleTitle+ '有了新動態');
    console.log('內容爲：' + content);
});

全局的發佈-訂閱對象app

相信你們都知道什麼是中介公司吧，在現實生活中，咱們只要把訂閱的請求交給中介公司，而各大發布者也只須要經過中介公司來發布信息。這樣一來，咱們就無需關心消息是哪一個發佈者發佈的，咱們只需關心是否能順利收到消息。固然，訂閱者與發佈者都須要知道這個中介公司。異步

一樣，在程序中，咱們能夠用一個全局的 Event 對象來實現中介公司的做用。Event做爲一個消息中心，把訂閱者和發佈者聯繫起來。見以下代碼：數據結構和算法

var Event = (function(){
    var clientList = {}, // 緩存列表
        listen,
        trigger,
        remove;
    
    listen = function(key, id, fn){
        if(!clientList[key]){
            clientList[key] = [];    // 初始化
        }
        clientList[key].push({      // 將訂閱的id, 回調函數添加到對應的消息列表裏
            id: id,                         
            fn: fn                          
        });
    };
    
    trigger = function() {
        var key = Array.prototype.shift.call(arguments),
            fns = clientList[key];
        if(!fns || fns.length == 0) {
            return false;
        }
        for(var i = 0; i < fns.length; i++) {
            fns[i].fn.apply(this, arguments);
        }
    };
    
    remove = function(key, id) {
        var fns = clientList[key];
        
        if(!fns) {                // 若是key對應的消息沒人訂閱，直接返回
            return false;
        }
        
        if(!id) {           // 若是沒傳具體的惟一標識，則取消key的全部對應消息
            fns && (fns.length = 0);
        } else {
            for(var l = fns.length - 1; l >=0; l--) {
                var _id = fns[l].id;
                if(_id == id) {
                    fns.splice(l, 1);    // 刪除訂閱者的回調函數
                }
            }
        }
    };
    
    return {
        listen: listen,
        trigger: trigger,
        remove: remove
    }
})();

Event.listen('questA', 1, function(content) {
    console.log('內容爲：' + content);
});

Event.trigger('questA', '王五回答了該問題');

必須先訂閱再發布嗎？函數

咱們所瞭解的發佈-訂閱模式，都是訂閱者必須先訂閱一個消息，隨後才能接收到發佈者發佈的消息。若是把順序反過來，發佈者先發佈一個消息，而在此以前並無對象來訂閱它，那麼這條消息就消失在宇宙中了。

而在實際項目在，先發布後訂閱是存在的。例如在商城網站中，獲取到用戶信息以後才能渲染用戶導航模塊，而獲取用戶信息的操做是一個異步請求。當請求成功返回以後才能發佈一個事件，在此以前訂閱了此事件的用戶導航模塊才能接收到這個信息。

然而，由於異步的緣由，咱們不能保證ajax請求的事件，可能用戶的導航模塊還沒加載好（即還沒訂閱消息），請求就返回（即發佈消息）。所以，咱們須要讓咱們的發佈-訂閱對象擁有先發布-後訂閱的能力。

具體的實現請看後續最終代碼。

全局事件的命名衝突

全局的發佈-訂閱對象裏只有一個clientList來存放消息名和回調函數，你們都經過它來訂閱-發佈各類消息，長此以往，不免會出現事件名衝突，因此咱們還能夠給Event對象提供建立命名空間的功能。

最終代碼以下：

var Event = (function(){
    var global = this,
        Event,
        _default = 'default';
   
    Event = function(){
        var _listen,
            _trigger,
            _remove,
            _slice = Array.prototype.slice,
            _shift = Array.prototype.shift,
            _unshift = Array.prototype.unshift,
            namespaceCache = {},
            _creat,
            find,
            each = function(ary, fn){
                var ret;
                for(var i = 0, l = ary.length; i < l; i++) {
                    var n = ary[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; i >=0; i--) {
                            if(cache[key][i] == fn) {
                                cache[key].splice(i, 1);
                            }
                        }
                    }  else {    // 若沒有fn,表示所有清空
                        cache[key] = [];
                    }    
                }
            };
            
            _trigger = function() {
                var cache = _shift.call(arguments),
                      key = _shift.call(arguments),
                      args = arguments,
                      _self= this,
                      ret,
                      stack = cache[key];
                 
                 if(!stack || !stack.length) {
                     return;
                 }
                 
                 return each(stack, function(){
                     return this.apply(_self, args);
                 })
            };
            
            _create = function(namespace) {
                var namespace = namespace || _default;
                var cache = {},
                    offlineStack = [],
                    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,
                                _self = this;
                            
                             _unshift.call(arguments, cache);
                             args = arguments;
                             fn = function() {
                                 return _trigger.apply(_self, 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.one(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;
})();

/********** 先發布後訂閱 ***********/
Event.trigger('click', 1);
Event.listen('click', function(a){
    console.log(a)
});

/********** 使用命名空間 ***********/
Event.create('namespace1').listen('click', function(a){ 
    console.log(a);
});
Event.create('namespace1').trigger('click', 1);

附：
JavaScript數據結構和算法系列：
JS 棧
 JS 隊列-優先隊列、循環隊列

JavaScript設計模式系列：
JavaScript設計模式之策略模式