前言

最近在公司的Koa.js我的项目中遇到一个问题，应用thrift库创立一个connection，在接口中应用该连贯的client来发送申请，后果抛错连贯失败且中断了程序的执行，用try/catch无奈捕捉到该谬误。遂查看创立连贯的源码，发现Connection构造函数中有如下代码：

var Connection = exports.Connection = function(stream, options) {  var self = this;  EventEmitter.call(this);    this.connection = stream;    // ...其余代码    this.connection.addListener("error", function(err) {    // Only emit the error if no-one else is listening on the connection    // or if someone is listening on us, because Node turns unhandled    // 'error' events into exceptions.    if (self.connection.listeners('error').length === 1 ||        self.listeners('error').length > 0) {      self.emit("error", err);    }  });    // ...其余代码}

正文翻译：只有在没有人监听连贯或有人监听咱们（this）时才收回谬误，因为 Node 会将未解决的“谬误”事件变成异样。

Node错误处理

同步API

除了多数例外，同步的 API（任何不承受 callback 函数的阻塞办法，例如 fs.readFileSync）都应用 throw 来报告谬误。任何应用 JavaScript throw 机制都会引发异样，必须应用 try…catch 解决，否则 Node.js 过程将立刻退出。

try {  throw new Error('something error');} catch(e) {  // 解决error}

异步API

当你应用try/catch尝试捕捉异步操作中的谬误时，会发现无奈捕捉到

try {  setTimeout(() => {    throw new Error('something error');  }, 1000);} catch(e) {  console.log(e);}// 执行后果// Uncaught Error: something error//     at <anonymous>:3:11

异步的 API 中产生的谬误能够以多种形式报告：

  • 大多数承受 callback 函数的异步办法将承受作为第一个参数传给该函数的 Error 对象。 如果第一个参数不是 null 并且是 Error 的实例，则产生了应该解决的谬误。

    const fs = require('node:fs');fs.readFile('a file that does not exist', (err, data) => {  if (err) {    console.error('There was an error reading the file!', err);    return;  }  // 否则解决数据});

  • 当在 EventEmitter 对象上调用异步办法时，谬误能够路由到该对象的 'error' 事件。

    const net = require('node:net');const connection = net.connect('localhost');// 向流中增加 'error' 事件句柄：connection.on('error', (err) => {  // 如果连贯被服务器重置，  // 或者根本无法连贯，或者连贯遇到任何类型的谬误，  // 则谬误将发送到这里。  console.error(err);});connection.pipe(process.stdout);
  • Node.js API 中的一些典型的异步办法可能依然应用 throw 机制来引发必须应用 try…catch 解决的异样。

留神：应用async/await解决异步函数时，应应用同步函数的try/catch来解决。

对于所有的 EventEmitter 对象，如果未提供 'error' 事件句柄，则将抛出谬误，导致 Node.js 过程报告未捕捉的异样并解体，除非：domain 模块应用切当或已为 'uncaughtException'事件注册句柄。

EventEmitter

EventEmitter是Node.js的内置模块events提供的一个类，它的外围就是事件触发与事件监听器性能的封装。通过require("events");来拜访该模块：

const { EventEmitter } = require('event');let eventEmitter = new EventEmitter();

提供了以下办法：

  • addListener(event, listener) 为指定事件增加一个监听器到监听器数组的尾部。
  • on(event, listener) 为指定事件注册一个监听器，承受一个字符串 event 和一个回调函数。
  • once(event, listener) 为指定事件注册一个单次监听器，即 监听器最多只会触发一次，触发后立即解除该监听器。
  • removeListener(event, listener) 移除指定事件的某个监听器，监听器必须是该事件曾经注册过的监听器。它承受两个参数，第一个是事件名称，第二个是回调函数名称。
  • removeAllListeners([event]) 移除所有事件的所有监听器， 如果指定事件，则移除指定事件的所有监听器。
  • setMaxListeners(n) 默认状况下， EventEmitters 如果你增加的监听器超过 10 个就会输入正告信息。 setMaxListeners 函数用于扭转监听器的默认限度的数量。
  • listeners(event) 返回指定事件的监听器数组。
  • emit(event, [arg1], [arg2], [...]) 按监听器的程序执行执行每个监听器，如果事件有注册监听返回 true，否则返回 false。

问题起因及解决方案

因为没有在connection上增加额定的error监听，所以self.emit("error", err);会执行，然而没有对应的listener，就导致了未捕捉的异样，导致node中断执行。故只须要在createConnection创立的对象上监听error事件即可。

参考：

谬误的流传和拦挡

浅谈前端中的错误处理