3Day:异步编程

2017-08-15  本文已影响0人  美得冒泡的姗迪

一.观察者模式(发布/订阅)

  如果不知道观察者模式的童鞋,可以参看我的另一个学习文档:    
  http://www.jianshu.com/p/007c6ed95c18

  异步编程有三种解决方案,其中“事件的发布订阅模式”是其中一种。

  node自身提供的events模块是发布订阅模式的一个简单实现,node中部分模块都继承自他。具有一些基本的事件监听模式的实现方法(下面会介绍)。

  事件发布订阅模式可以实现一个事件与多个回调函数的关联,这些回调函数又称为事件侦听器,通过emit()发布事件后,消息会立即出阿迪给当前事件的所有侦听器执行。

  在一些典型的场景中,通过事件发布订阅模式进行组件封装,将不变的部分封装在组件内部,将容易变化的,需自定义的部分通过事件暴露给外部处,这是一种典型的逻辑分离方式。

二.Event

  以下代码出处(我看的版本是v6.4.0):https://nodejs.org/docs/latest/api/events.html
  也可以读源码:https://github.com/nodejs/node-v0.x-archive/blob/828f14556e0daeae7fdac08fceaa90952de63f73/lib/events.js#L43

  const EventEmitter = require('events');
  var m = 0;
  //1.EventEmitter 类.
  class MyEmitter extends EventEmitter {}
  const myEmitter = new MyEmitter();

  //2.订阅事件.
  myEmitter.on('event',() => {
            console.log('an event occurred !'+ ++m);
  });
  //3.发布.
  myEmitter.emit('event');

  //4.传参.
   myEmitter.on('event',function(a,b){  //es5写法
  //myEmitter.on('event',(a,b) => { //es6写法.
       console.log('function a b is called !');
  });
  myEmitter.emit('event','a','b');

  //5.同步异步.
  myEmitter.on('event', (a, b,c) => {
  setImmediate(() => {
          console.log('this happens asynchronously');
    });
  });
  //myEmitter.emit('event', 'a', 'b','c');

  //6.Once the event is emitted, the listener is unregistered and then called.
  myEmitter.once('event', (a,b,c,d) => {
        console.log('this is called once ');
  });

  //7.打印event监听者数量.
  console.log(EventEmitter.listenerCount(myEmitter, 'event'));

  //8.获取实例最大的事件监听数量.
  console.log(myEmitter.getMaxListeners());

  //9.对于一个事件添加超过10个监听器将会得到一个⚠️,调用emitter.setMaxListeners(0)可以将这个限制去掉.
      
  //10.捕获error.
  //To guard against crashing the Node.js process, a listener can be registered on the [process object's uncaughtException event](https://nodejs.org/docs/latest/api/process.html#process_event_uncaughtexception) .
    process.on('uncaughtException', (err) => {
        console.log('whoops! there was an error');
    });

  //11.注册error事件来处理error捕获.
  //As a best practice, listeners should always be added for the 'error' events..
    myEmitter.on('error', (err) => {
        console.log('whoops! there was an error');
    });

三.观察者模式(Promise/Deferred)

1.前言知识
  javascript的继承机制设计思想(作者:[阮一峰]):http://www.ruanyifeng.com/blog/2011/06/designing_ideas_of_inheritance_mechanism_in_javascript.html

  javascript封装(作者:[阮一峰]):http://www.ruanyifeng.com/blog/2010/05/object-oriented_javascript_encapsulation.html

  构造函数的继承(作者:[阮一峰]):http://www.ruanyifeng.com/blog/2010/05/object-oriented_javascript_inheritance.html

  非构造函数的继承(作者:[阮一峰]):http://www.ruanyifeng.com/blog/2010/05/object-oriented_javascript_inheritance_continued.html
上一篇 下一篇

猜你喜欢

热点阅读