欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

[JS设计模式]:观察者模式(即发布-订阅者模式)(4)

程序员文章站 2023-04-05 14:00:40
简介 观察者模式又叫发布 订阅模式,它定义了对象间的一种一对多的关系,让多个观察者对象同时监听某一个主题对象,当一个对象发生改变时,所有依赖于它的对象都将得到通知。 举一个现实生活中的例子,例如小红在淘宝的一家店里看上了一双红色的鞋,小李也在这家店里面看上了一顶黑色的帽子,但是联系卖家时,卖家回答这 ......

简介

观察者模式又叫发布---订阅模式,它定义了对象间的一种一对多的关系,让多个观察者对象同时监听某一个主题对象,当一个对象发生改变时,所有依赖于它的对象都将得到通知。

举一个现实生活中的例子,例如小红在淘宝的一家店里看上了一双红色的鞋,小李也在这家店里面看上了一顶黑色的帽子,但是联系卖家时,卖家回答这两样都没货了。卖家告诉小红小李,要是喜欢的话,可以关注下店铺,到货了,我会给大家通知的。这就是一个典型的发布-订阅模式,卖家是发布者,买家是订阅者。当货来的时候,会依次通知小红、小李等买家,依次给他们发消息通知。

代码实现

var goodsobj = {};
goodsobj.list = []; //存放订阅者

//订阅者
goodsobj.subscribe = function(key,fn){
    if(!this.list[key]){
        this.list[key] = [];
    }
    //订阅的消息存放到缓存列表中
    this.list[key].push(fn);
}

//取消订阅
goodsobj.unsubscribe = function(key,fn){
    var fns = this.list[key];
    //如果key对应的消息没有订阅过的话,则返回
    if(!fns){ 
        return false;
    }
    //如果没有传入具体的回调函数,表示取消key对应消息的所有订阅
    if(!fn){
        fns && (fns.length = 0);
    }else{
        for(var i = fns.length - 1; i >= 0; i--){
            if(fns[i] === fn){
                //删除订阅者的回调函数
                fns.splice(i,1); 
            }
        }
    }
}

//发布者
goodsobj.publish = function(){
    var key = array.prototype.shift.call(arguments);
    var fns = this.list[key];
    //如果没有订阅过该key的消息,直接返回
    if(!fns || fns.length === 0){
        return false;
    }
    for(var i = 0,fn; fn = fns[i++];){
        fn.apply(this,arguments);
    }
}

//小红订阅了鞋
goodsobj.subscribe('shoes',fn1 = function(color){
    console.log('订阅鞋的颜色:' + color + '到货了,可以拍了');
});

//小李订阅了帽子
goodsobj.subscribe('cap',fn2 = function(size){
    console.log('订阅帽子的尺寸:' + size  + '到货了,可以拍了');
});

//发布
goodsobj.publish('shoes','red');
goodsobj.publish('cap',40);

//取消订阅
goodsobj.unsubscribe('shoes',fn1);

//发布消息,看是否能收到
goodsobj.publish('shoes','block');

 优化取消订阅

为了优化取消订阅,在订阅的时候,给每个订阅者一个不同的标识,代码如下:

var goodsobj = {};
goodsobj.list = {}; //存放订阅者
var subuid = -1; //每个订阅者标识不一样

//订阅者
goodsobj.subscribe = function(key,fn){
    if(!this.list[key]){
        this.list[key] = [];
    }
    //订阅的消息存放到缓存列表中
    var token= (++subuid).tostring();
    this.list[key].push({
        token:token,
        fn:fn
    });
    return token;
}

//取消订阅
goodsobj.unsubscribe = function(token){
    for(var m in goodsobj.list){
        if(goodsobj.list.hasownproperty(m)){
            for(var i = 0, j = goodsobj.list[m].length; i < j; i++ ){
                if(goodsobj.list[m][i].token == token){
                    goodsobj.list[m].splice(i,1);
                    break;
                }
            }
        }
    }
}

//发布者
goodsobj.publish = function(){
    var key = array.prototype.shift.call(arguments);
    var fns = this.list[key];
    //如果没有订阅过该key的消息,直接返回
    if(!fns || fns.length === 0){
        return false;
    }
    for(var i = 0,obj; obj = fns[i++];){
        obj.fn.apply(this,arguments);
    }
}

//小红订阅了鞋
var token1 = goodsobj.subscribe('shoes',function(color){
    console.log('订阅鞋的颜色:' + color + '到货了,可以拍了');
});

//小李订阅了帽子
goodsobj.subscribe('cap',function(size){
    console.log('订阅帽子的尺寸:' + size  + '到货了,可以拍了');
});

//发布
goodsobj.publish('shoes','red');
goodsobj.publish('cap',40);

//取消订阅
goodsobj.unsubscribe(token1);

//发布消息,看是否能收到
goodsobj.publish('shoes','block');

封装全局发布订阅对象

封装一个全局的发布-订阅对象,代码如下:

var event = (function(){
    var list = {}, //存放订阅者
        subscribe,
        unsubscribe,
        publish,
        subuid = -1; //每个订阅者标识不一样
        
        //订阅者
        subscribe = function(key,fn){
            if(!list[key]){
                list[key] = [];
            }
            //订阅的消息存放到缓存列表中
            var token= (++subuid).tostring();
            list[key].push({
                token:token,
                fn:fn
            });
            return token;
        };
        
        //取消订阅
        unsubscribe = function(token){
            for(var m in list){
                if(list.hasownproperty(m)){
                    for(var i = 0, j = list[m].length; i < j; i++ ){
                        if(list[m][i].token == token){
                            list[m].splice(i,1);
                            break;
                        }
                    }
                }
            }
        };
        
        //发布者
        publish = function(){
            var key = array.prototype.shift.call(arguments);
            var fns = list[key];
            //如果没有订阅过该key的消息,直接返回
            if(!fns || fns.length === 0){
                return false;
            }
            for(var i = 0,obj; obj = fns[i++];){
                obj.fn.apply(this,arguments);
            }
        };
        
        return {
            publish:publish,
            subscribe:subscribe,
            unsubscribe:unsubscribe
        }        
})();

//小红订阅了鞋
var token1 = event.subscribe('shoes',function(color){
    console.log('订阅鞋的颜色:' + color + '到货了,可以拍了');
});

//小李订阅了帽子
event.subscribe('cap',function(size){
    console.log('订阅帽子的尺寸:' + size  + '到货了,可以拍了');
});

//发布
event.publish('shoes','red');
event.publish('cap',40);

//取消订阅
event.unsubscribe(token1);

//发布消息,看是否能收到
event.publish('shoes','block');

实例

我们使用上面封装的全局的发布-订阅对象来实现两个模块之间的通信问题;比如现在有一个页面有一个按钮,每次点击此按钮后,div中会显示此按钮被点击的总次数;如下代码:

<button id="clickbtn">点击我计数</button>
<div id="showcount">0</div>

js代码如下:

(function(){
    var count = 0;
    //发布(责处理点击操作、发布消息)
    document.getelementbyid('clickbtn').addeventlistener('click',function(){
        event.publish('add',count++);
    },false);
    
    //订阅(负责监听add这个消息,并把点击的总次数显示到页面上来)
    event.subscribe('add',function(curcount){
        document.getelementbyid('showcount').innerhtml = curcount;
    })
})();

订阅发布更精简代码:

var event = function(){
    var listen,obj,remove,one,trigger,__this;
    obj = {};
    __this = this;
    listen = function(key,eventfn){
        var _ref,stack;
        stack = (_ref = obj[key]) != null ? _ref : obj[key] = [];
        return stack.push(eventfn);
    };
    one = function(key,eventfn){
        remove(key);
        return listen(key,eventfn);
    };
    remove = function(key){
        var _ref;
        return (_ref = obj[key]) != null ? _ref.length = 0 : void 0;
    };
    trigger = function(){
        var fn,stack,_i,_len,_ref,key;
        key = array.prototype.shift.call(arguments);
        stack = (_ref = obj[key]) != null ? _ref :obj[key] = [];
        for(_i=0,_len=stack.length;_i<_len;_i++){
            fn = stack[_i];
            if(fn.apply(__this,arguments) === false){
                return false;
            }
        }
    }
    
    return {
        listen:listen,
        one:one,
        remove:remove,
        trigger:trigger
    }
}

var addtv = event();

addtv.listen('play',function(data){
    console.log('今天上午要播放的电影是:' +data.name);
});
addtv.one('play',function(data){
    console.log('只有我订阅的电影信息:' +data.name);
});
addtv.trigger('play',{'name':'国产凌凌漆'});

addtv.remove('play');
addtv.trigger('play',{'name':'国产凌凌漆22'});

 参考