示例 上一篇讲解了dojo connect事件机制,这一篇讲解dojo订阅发布模式,主要使用的方法为dojo.subscribe、dojo.unsubscribe、dojo.publish三个函数,如果理解了上一篇, 订阅发布模式理解起来就很
示例
上一篇讲解了dojo connect事件机制,这一篇讲解dojo订阅发布模式,主要使用的方法为dojo.subscribe、dojo.unsubscribe、dojo.publish三个函数,如果理解了上一篇, 订阅发布模式理解起来就很简单。不多说了,先来个示例:var topic = "alarm"; function Foo() { this.alarm = function() { console.info("do something in Foo's alarm function"); //发布主题 dojo.publish(topic); }; } function Bar() { this.getup = function() { console.info("alarming now, need to getup"); } } function Baz() { this.name = "Baz"; this.work = function() { console.info("alarming now, need to start working"); } } var foo = new Foo(); var bar = new Bar(); var baz = new Baz(); // 订阅主题 dojo.subscribe(topic, bar, "getup"); dojo.subscribe(topic, baz, "work"); // 该函数调用中发布主题,然后会触发订阅的监听器 foo.alarm();
源码解析
//所有的主题都在存储在该对象中 dojo._topics = {}; // 订阅某主题 dojo.subscribe = function(/*String*/ topic, /*Object|null*/ context, /*String|Function*/ method){ // 是不是很简单,主要就调用了一个函数:dojo._listener.add // 该函数已经在上一篇详细讲解过了,add函数执行过后,会在dojo._topics对象中存储一个分发器函数(代理函数),key就为topic // 这个分发器函数的_listeners数组属性存储了所有监听器 // dojo.hitch返回设置了this变量后的监听器函数 return [topic, dojo._listener.add(dojo._topics, topic, dojo.hitch(context, method))]; /*Handle*/ }; // 发布主题,并且可以传递参数 dojo.publish = function(/*String*/ topic, /*Array*/ args){ // 是不是就更简单了,从dojo._topics对象中取出分发器函数 var f = dojo._topics[topic]; // 判断分发器函数是否存在 if(f){ // 调用分发器函数,该函数中先调用原目标函数,随即调用_listeners数组中存储的各个监听器函数 // 监听器参数列表就为publish函数的args数组 f.apply(this, args||[]); } }; // 取消订阅 dojo.unsubscribe = function(/*Handle*/ handle){ // handle为subscribe函数的返回值 if(handle){ // 调用dojo._listener.remove函数,从dojo._topics对象中key为topic的分发器函数监听器列表中移除指定位置的监听器 dojo._listener.remove(dojo._topics, handle[0], handle[1]); } };
dojo.connectPublisher函数
还有一个dojo.connectPublisher函数需要说一下,通过该函数可以将dojo.publish从函数中脱离出来,更加方便:dojo.connectPublisher = function( /*String*/ topic, /*Object|null*/ obj, /*String*/ event){ //该代理函数的参数列表与目标对象obj的函数参数一致 var pf = function(){ dojo.publish(topic, arguments); } return event ? dojo.connect(obj, event, pf) : dojo.connect(obj, pf); //Handle };
PS:dojo版本为dojo-release-1.6.3