@H_403_0@学习 Node.js 一定要理解的内容之一，文中主要涉及到了 EventEmitter 的使用和一些异步情况的处理，比较偏基础，值得一读。
@H_403_0@大多数 Node.js 对象都依赖了 EventEmitter 模块来监听和响应事件，比如我们常用的 HTTP requests,responses,以及 streams。你准备好了就叫我哈，Node！
@H_403_0@很久很久以前，在 js 里还没有原生支持 Promise，async/await 还只是一个遥远的梦想，回调函数是处理异步问题的最原始的方式。 @H_403_0@回调从本质上讲是传递给其他函数的函数，在 JavaScript 中函数是第一类对象，这也让回调的存在成为可能。 @H_403_0@一定要搞清楚的是，回调在代码中的并不表示异步调用。 回调既可以是同步调用的，也可以是异步调用的。 @H_403_0@举个例子，这里有一个宿主函数 fileSize，它接受一个回调函数 cb，并且可以通过条件判断来同步或者异步地调用该回调函数： {
if (err) {
// Async
return cb(err);
}
// Async
cb(null,stats.size);
});
}
@H_403_0@这其实也是个反例，这样写经常会引起一些意外的错误，在设计宿主函数的时候，应当尽可能的使用同一种风格，要么始终都是同步的使用回调，要么始终都是异步的。
@H_403_0@我们来研究下一个典型的异步 Node 函数的简单示例，它用回调样式编写：
{
if (err) throw err;
const numbers = lines.map(Number);
const oddNumbers = numbers.filter(n => n%2 === 1);
console.log('Odd numbers count:',oddNumbers.length);
});
@H_403_0@这段代码将文件内容读入字符串数组中，回调函数将其解析为数字，并计算奇数的个数。
@H_403_0@这才是最纯粹的 Node 回调风格。回调的第一个参数要遵循错误优先的原则，err 可以为空，我们要将回调作为宿主函数的最后一个参数传递。你应该一直用这种方式这样设计你的函数，因为用户可能会假设。让宿主函数把回调当做其最后一个参数，并让回调函数以一个可能为空的错误对象作为其第一个参数。
@H_403_0@回调在现代 JavaScript 中的替代品
@H_403_0@在现代 JavaScript 中，我们有 Promise，Promise 可以用来替代异步 API 的回调。回调函数需要作为宿主函数的一个参数进行传递（多个宿主回调进行嵌套就形成了回调地狱），而且错误和成功都只能在其中进行处理。而 Promise 对象可以让我们分开处理成功和错误，还允许我们链式调用多个异步事件。 @H_403_0@如果 readFileAsArray 函数支持 Promise，我们可以这样使用它，如下所示： {
const numbers = lines.map(Number);
const oddNumbers = numbers.filter(n => n%2 === 1);
console.log('Odd numbers count:',oddNumbers.length);
})
.catch(console.error);
@H_403_0@我们在宿主函数的返回值上调用了一个函数来处理我们的需求，这个 .then 函数会把刚刚在回调版本中的那个行数组传递给这里的匿名函数。为了处理错误，我们在结果上添加一个 .catch 调用，当发生错误时，它会捕捉到错误并让我们访问到这个错误。
@H_403_0@在现代 JavaScript 中已经支持了 Promise 对象，因此我们可以很容易的将其使用在宿主函数之中。下面是支持 Promise 版本的 readFileAsArray 函数（同时支持旧有的回调函数方式）：
{}) {
return new Promise((resolve,reject) => {
fs.readFile(file,data) {
if (err) {
reject(err);
return cb(err);
}
const lines = data.toString().trim().split('\n');
resolve(lines);
cb(null,lines);
});
});
};
@H_403_0@我们使该函数返回一个 Promise 对象，该对象包裹了 fs.readFile 的异步调用。Promise 对象暴露了两个参数，一个 resolve 函数和一个 reject 函数。
@H_403_0@当有异常抛出时，我们可以通过向回调函数传递 error 来处理错误，也同样可以使用 Promise 的 reject 函数。每当我们将数据交给回调函数处理时，我们同样也可以用 Promise 的 resolve 函数。
@H_403_0@在这种同时可以使用回调和 Promise 的情况下，我们需要做的唯一一件事情就是为这个回调参数设置默认值，防止在没有传递回调函数参数时，其被执行然后报错的情况。 在这个例子中使用了一个简单的默认空函数：（）=> {}。
@H_403_0@通过 async/await 使用 Promise
@H_403_0@当需要连续调用异步函数时，使用 Promise 会让你的代码更容易编写。不断的使用回调会让事情变得越来越复杂，最终陷入回调地狱。 @H_403_0@Promise 的出现改善了一点，Generator 的出现又改善了一点。 处理异步问题的最新解决方式是使用 async 函数，它允许我们将异步代码视为同步代码，使其整体上更加可读。 @H_403_0@以下是使用 async/await 版本的调用 readFileAsArray 的例子： n%2 === 1).length;
console.log('Odd numbers count:',oddCount);
} catch(err) {
console.error(err);
}
}
countOdd();
@H_403_0@首先，我们创建了一个 async 函数 —— 就是一个普通的函数声明之前，加了个 async 关键字。在 async 函数内部，我们调用了 readFileAsArray 函数，就像把它的返回值赋值给变量 lines 一样，为了真的拿到 readFileAsArray 处理生成的行数组，我们使用关键字 await。之后，我们继续执行代码，就好像 readFileAsArray 的调用是同步的一样。
@H_403_0@要让代码运行，我们可以直接调用 async 函数。这让我们的代码变得更加简单和易读。为了处理异常，我们需要将异步调用包装在一个 try/catch 语句中。
@H_403_0@有了 async/await 这个特性，我们不必使用任何特殊的API（如 .then 和 .catch ）。我们只是把这种函数标记出来，然后使用纯粹的 JavaScript 写代码。
@H_403_0@我们可以把 async/await 这个特性用在支持使用 Promise 处理后续逻辑的函数上。但是，它无法用在只支持回调的异步函数上（例如setTimeout）。
@H_403_0@EventEmitter 模块
@H_403_0@EventEmitter 是一个处理 Node 中各个对象之间通信的模块。 EventEmitter 是 Node 异步事件驱动架构的核心。 Node 的许多内置模块都继承自 EventEmitter。 @H_403_0@它的概念其实很简单：emitter 对象会发出被定义过的事件，导致之前注册的所有监听该事件的函数被调用。所以，emitter 对象基本上有两个主要特征： @H_403_0@为了使用 EventEmitter，我们需要创建一个继承自 EventEmitter 的类。事件 !== 异步
@H_403_0@先看看这个例子：class WithLog extends EventEmitter {
execute(taskFunc) {
console.log('Before executing');
this.emit('begin');
taskFunc();
this.emit('end');
console.log('After executing');
}
}
@H_403_0@WithLog 是一个事件触发器，它有一个方法 —— execute，该方法接受一个参数，即具体要处理的任务函数，并在其前后包裹 log 以输出其执行日志。
@H_403_0@为了看到这里会以什么顺序执行，我们在两个命名的事件上都注册了监听器，最后执行一个简单的任务来触发事件。
@H_403_0@下面是上面程序的输出结果：
execute(taskFunc) {
console.log('Before executing');
this.emit('begin');
taskFunc();
this.emit('end');
console.log('After executing');
}
}
const withLog = new WithLog();
withLog.on('begin',() => console.log('About to execute'));
withLog.on('end',() => console.log('Done with execute'));
withLog.execute(() => console.log(' Executing task '));
- 第一行输出了 "Before executing"
- begin 事件被触发，输出 "About to execute"
- 真正应该被执行的任务函数被调用，输出 " Executing task "
- end 事件被触发，输出 "Done with execute"
- 最后输出 "After executing"
withLog.execute(() => {
setImmediate(() => {
console.log(' Executing task ')
});
});
@H_403_0@输出结果变成了这样：
setImmediate(() => {
console.log(' Executing task ')
});
});
异步事件
@H_403_0@我们把刚刚那些同步代码的示例改成异步的：class WithTime extends EventEmitter {
execute(asyncFunc,...args) {
this.emit('begin');
console.time('execute');
asyncFunc(...args,data) => {
if (err) {
return this.emit('error',err);
}
@H_403_0@用 WithTime 类执行 asyncFunc 函数，并通过调用 console.time 和 console.timeEnd 报告该asyncFunc 所花费的时间。它在执行之前和之后都将以正确的顺序触发相应的事件，并且还会发出 error/data 事件作为处理异步调用的信号。
@H_403_0@我们传递一个异步的 fs.readFile 函数来测试一下 withTime emitter。 我们现在可以直接通过监听 data 事件来处理读取到的文件数据，而不用把这套处理逻辑写到 fs.readFile 的回调函数中。
@H_403_0@执行这段代码，我们以预期的顺序执行了一系列事件，并且得到异步函数的执行时间，这些是十分重要的。
execute(asyncFunc,...args) {
this.emit('begin');
console.time('execute');
asyncFunc(...args,data) => {
if (err) {
return this.emit('error',err);
}
this.emit('data',data);
console.timeEnd('execute');
this.emit('end');
});
}
}
const withTime = new WithTime();
withTime.on('begin',() => console.log('About to execute'));
withTime.on('end',() => console.log('Done with execute'));
withTime.execute(fs.readFile,__filename);
事件参数和错误
@H_403_0@在之前的例子中，有两个事件被发出时还携带了别的参数。 @H_403_0@error 事件被触发时会携带一个 error 对象。 {
// do something with data
});
@H_403_0@error 事件比较特殊。在我们基于回调的那个示例中，如果不使用监听器处理 error 事件，node 进程将会退出。
@H_403_0@举个由于错误使用参数而造成程序崩溃的例子：
console.timeEnd('execute');
});
}
}
@H_403_0@第一次调用 execute 将会触发 error 事件，由于没有处理 error ，Node 程序随之崩溃：
});
}
}
const withTime = new WithTime();
withTime.execute(fs.readFile,''); // BAD CALL
withTime.execute(fs.readFile,__filename);
{
// do something with err,for example log it somewhere
console.log(err)
});
@H_403_0@如果我们执行上述操作，将会报告第一次执行 execute 时发送的错误，但是这次 node 进程不会崩溃退出，其他程序的调用也都能正常完成：
@H_403_0@{ Error: ENOENT: no such file or directory,open '' errno: -2,code: 'ENOENT',syscall: 'open',path: '' }
execute: 4.276ms
@H_403_0@需要注意的是，基于 Promise 的函数有些不同，它们暂时只是输出一个警告:
@H_403_0@UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): Error: ENOENT: no such file or directory,open ''
@H_403_0@DeprecationWarning: Unhandled promise rejections are deprecated. In the future,promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.
@H_403_0@另一种处理异常的方式是在监听全局的 uncaughtException 进程事件。 然而，使用该事件全局捕获错误并不是一个好办法。
@H_403_0@关于 uncaughtException，一般都会建议你避免使用它，但是如果必须用它，你应该让进程退出：
{
// something went unhandled.
// Do any cleanup and exit anyway!
@H_403_0@但是，假设在同一时间发生多个错误事件，这意味着上面的 uncaughtException 监听器将被多次触发，这可能会引起一些问题。
@H_403_0@EventEmitter 模块暴露了 once 方法，这个方法发出的信号只会调用一次监听器。所以，这个方法常与 uncaughtException 一起使用。
@H_403_0@console.error(err); // don't do just that.
// FORCE exit the process too.
process.exit(1);
});
监听器的顺序
@H_403_0@如果针对一个事件注册多个监听器函数，当事件被触发时，这些监听器函数将按其注册的顺序被触发。 {
console.log(`Length: ${data.length}`);
});
@H_403_0@上述代码会先输出 Length 信息，再输出 Characters 信息，执行的顺序与注册的顺序保持一致。
@H_403_0@如果你想定义一个新的监听函数，但是希望它能够第一个被执行，你还可以使用 prependListener 方法：
// second
withTime.on('data',(data) => {
console.log(Characters: ${data.toString().length});
});
withTime.execute(fs.readFile,__filename);
{
console.log(`Length: ${data.length}`);
});
@H_403_0@上述代码中，Charaters 信息将首先被输出。
@H_403_0@最后，你可以用 removeListener 函数来删除某个监听器函数。
@H_403_0@以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程之家。withTime.prependListener('data',__filename);
