前言
最近在公司的 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 事件即可。
参考:
谬误的流传和拦挡
浅谈前端中的错误处理