js的订阅发布者模式

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了js的订阅发布者模式相关的知识,希望对你有一定的参考价值。

  前两天在笔试一家知名企业的时候遇到一道题,要实现一个简单的订阅发布者模式,当时由于各种原因我没有做,提前交了卷。现在回想起来,还是有必要好好研究一发。

  首先先说说订阅发布者模式,顾名思义,就是有订阅者和发布者,两者的功能,订阅是请求在某些事件(event)到达时可以通知它并执行对应的动作(action),而发布则相对的是向订阅告知事件(event)已经到达,你可以执行对应的动作(action)了。但是具体是怎么的一个思维呢,听我娓娓道来。

  大家应该都知道nodeJs是由事件来驱动的,也就是每个函数可以说都是某个事件来触发的,这个函数只处理这个事件对应的逻辑,函数间的通信,都是通过事件监听来驱动。玩过游戏的人都知道,一般游戏都有一个发布消息的地方,比如我把某个怪干死之后,要对队友们说:“看,我把怪干死了,你可以过来了”,这个其实就是一个订阅发布者模式。首先,我是发布者,而队友就是订阅者,我把怪干死(这是我自己这个函数处理的逻辑),往消息框输入消息(这就是发布),队友们通过消息存放的地方(相当于订阅)获得数据,再干他们该干的事情(其他函数处理的逻辑)。懂了吧,其实说白了就是我和队友之间夹杂着的消息存放的地方(Listener)就是订阅发布者主要存在的地方。

  接着我们来看一下这个消息存在的地方要实现什么。第一,肯定是要把订阅者想知道什么消息类型,也就是event,以及要执行的动作保存起来,为什么要把动作也放进来呢,明明动作是由订阅者执行的,这就是实际思维和编程思维的不同(容我装下逼),按照编程思维,订阅者执行的动作是个函数,而这个函数什么时候执行完全由消息说了算,所以当然只能由Listener来执行。

  咳咳,如果以上觉得太复杂的话,我再总结一句话:订阅者就是把要执行的函数和要的事件类型给消息存放的地方(Listener),而发布者就是告诉消息存放的地方(Listener)你现在可以执行这个事件类型对应的函数了,并且把我给你的数据也传进去。

  好了有了思路,我们实现起来也方便多了,只要把Listener实现了就可以了,我直接上代码。

  

(function (w) {

    var Listener = function () {
        // 私有变量
        // 全局配置信息
        var _config = {
            // 是否开启多级作用域
            multiLevel: true,
            // 发布者发布后,订阅者相关动作是否需要删除
            removeNow: false,


        },
         _receives = {};

        // 订阅者
        // 需要传入订阅类型,动作
        this.subscribe = function (type, action, removeNow) {

            // 初始化
            removeNow = removeNow || _config.removeNow;

            // 对应的level
            var level = _createLevel(type);

                level.actions = level.actions || [];

            // 保证传入的是函数
            if (action instanceof Function) {
                level.actions.push({
                    action: action,
                    removeNow: removeNow
                });
            }
        };

        // 发布者
        // 需要传入发布类型和数据
        this.publish = function (type, data) {
            // 初始化
            // 获取对应actions
            var level = _searchLevel(type),
                actions = level.actions;

            // 遍历执行actions里的函数
            for(var i = 0, len = actions.length; i < len; i++) {
                actions[i].action.call(null, data);
                if (actions[i].removeNow) {
                    actions.splice(i,1);
                }
            }
            console.log(_receives);
        };

        // 私有函数

        // 寻找执行的Level
        var _searchLevel = function (type) {
            var receives = _receives,
                multiLevel = _config.multiLevel;
            if (multiLevel) {
                // 有多级作用域
                try {
                    // 分割type取得各级作用域
                    var types = type.split(‘.‘);
                    for (var i = 0, len = types.length; i < len; i++) {
                        if (receives[types[i]]) {
                            receives = receives[types[i]];
                        }
                    }

                    return receives;
                } catch (e) {
                    console.log(e);
                } 
            } else {
                return receives[type];
            }
        },
        // 创建对应的Level
        _createLevel = function (type) {
            var receives = _receives,
                multiLevel = _config.multiLevel;
            if (multiLevel) {
                // 有多级作用域
                try {
                    var types = type.split(‘.‘);
                    for (var i = 0, len = types.length; i < len; i++) {
                        // 有则选择,无则初始化
                        receives[types[i]] = receives[types[i]] || {};
                        receives = receives[types[i]];
                    }
                } catch (e) {
                    console.log(e);
                }
            } else {
                receives[type] = receives[type] || {};
                receives = receives[type];
            }
            return receives;
        };
    };

    w.Listener = new Listener();
    console.log(w.Listener);
}) (window)

使用这段代码的方法是

<!DOCTYPE html>
<html>
<head>
    <title>test</title>
</head>
<body>
    <script src="./listener.js"></script>
    <script type="text/javascript">
        var action1 = function (data) {
            console.log("this is action1",data);
        }
        var person1 = Listener.subscribe(action.action1, action1, true);

        var action2 = function () {
            console.log("this is action2");
        }
        var person2 = Listener.subscribe(action.action2, action2);

        Listener.publish("action.action1","hello world");
        Listener.publish("action.action2");
    </script>
</body>
</html>

  其中,我的代码写的是支持多级作用域的,你们可以这样理解,因为在游戏里,你发送消息有可能是希望队友中的某些人能看到,这里我用的"."这个符号区别作用域,千万不要理解成js里的作用域了。当然这些代码有些还很不完善,比如错误处理这些。后面我会继续做的。

  好了,我的文笔真的是很烂,我有自知之明,而且我的代码能力也一般。这种模式其他地方介绍得可能比我好,所以大家不喜勿看,勿喷。

以上是关于js的订阅发布者模式的主要内容,如果未能解决你的问题,请参考以下文章

为啥要使用发布/订阅模式(在 JS/jQuery 中)?

JS设计模式发布订阅模式

js 高阶函数 发布订阅观察者模式 手撕promise

AngularJS的简单订阅发布模式例子

JS的发布订阅模式

js设计模式-发布/订阅模式