我的博客:blog.skrskrskrskr.comhtml
软件程序中,咱们能够将错误大体分为外部错误和内部错误两大类。node
外部错误是正确编写的程序在运行时产生的错误。它并非程序自己的 bug,更可能是一些外部缘由致使的问题,好比请求超时、服务器返回 500、内存不足等。git
而内部错误是程序里的 bug。好比传参类型错误、读取 undefined 的一个属性等。这类问题跟你选择的开发语言、开发者的编程经验、系统复杂度等因素息息相关,虽然没法避免,但能够经过修改代码来修复它。程序员
对应到 Node.js 程序上,通常遇到如下四类错误:github
注:本文中不区分错误和异常,都将其统称为错误。redis
当错误发生后,咱们须要第一时间去处理它。针对不一样类型的错误,有不一样的措施。处理错误的整体原则:npm
程序运行过程当中,可能会遇到各类外部因素致使的问题,这些问题须要具体问题具体分析。咱们没办法保证外部服务提供方的稳定性,可是遇到此类问题时,能够作一些事情,来保证咱们的程序不至于直接崩溃。编程
举个例子,秒杀场景的业务常常会承受很是大的 QPS,在一波瞬间大流量的冲击,后端服务扛不住的话会报 5XX 错误。在后端服务挂掉后,咱们可能会去读 redis 等缓存中的数据,用旧数据来兜底。而当 Node.js 应用也挂掉了,还能够在 Nginx 层进行 CDN 降级,给用户输出一个兜底的静态页。bootstrap
还有些来自后端服务的错误,只须要进行简单的重试就能解决。若是要重试的话,要肯定重试的次数,以及重试的间隔。后端
有人建议在发生错误后直接崩溃掉,防止错误扩散。我的认为实际上是不合理的,会下降服务的可用性。咱们能够在出现一些严重的错误后,先记录下错误,而后重启进程。在 Node.js 中,未捕获的 JavaScript 异常一直冒泡回到事件循环时,会触发 process.uncaughtException 事件。咱们能够在事件回调中作错误上报,而后重启 Node.js 进程。这时,还须要借助 Cluster 来启动多个 Node 进程,保证单进程崩溃重启不会影响总体服务的可用性。实际的生产环境中,使用 PM2 来管理 Node.js 进程是一个更好的选项。
咱们永远也没法阻止外部错误,它跟你的业务场景、用户终端等各类不可控的因素相关。可是咱们若是作好监控、告警、日志、缓存等工做,能够方便程序员迅速定位/解决问题,从而将损失降至最低。
对于 JavaScript 错误,咱们可使用 throw 抛出,并用 try catch 来捕获住。
try {
throw new Error('some error')
} catch(e) {
console.error(e)
}
复制代码
并且对于 throw 抛出的异常必需要 try catch 包裹,不然 Node.js 进程会直接退出。这种写法能够获取到完整的错误调用堆栈。好比:
fs.js:115
throw err;
^
Error: ENOENT: no such file or directory, scandir '/Users/frank/code/work/wxapp/src/componentsa'
at Object.readdirSync (fs.js:783:3)
at getDirFilePaths (/Users/frank/code/m/demo/readdir.js:8:22)
at Object.<anonymous> (/Users/frank/code/m/demo/readdir.js:27:15)
at Module._compile (internal/modules/cjs/loader.js:688:30)
at Object.Module._extensions..js (internal/modules/cjs/loader.js:699:10)
at Module.load (internal/modules/cjs/loader.js:598:32)
at tryModuleLoad (internal/modules/cjs/loader.js:537:12)
at Function.Module._load (internal/modules/cjs/loader.js:529:3)
at Function.Module.runMain (internal/modules/cjs/loader.js:741:12)
at startup (internal/bootstrap/node.js:285:19)
复制代码
众所周知,JS 函数调用会造成一系列的栈帧,为了尽量的恢复错误发生现场,最好在错误上报时带上堆栈信息。Node.js 中,Error.captureStackTrace()
方法是 v8 引擎暴露出来的,处理错误堆栈信息的 API。
Error.captureStackTrace(targetObject[, constructorOpt]) 在 targetObject 中添加一个 .stack 属性。对该属性进行访问时,将以字符串的形式返回 Error.captureStackTrace() 语句被调用时的代码位置信息(即:调用栈历史)。
值得注意的是,它的第二个参数能够用来控制栈帧的终点。在一些底层库中,这个参数能够用来向开发者隐藏内部实现细节。
实际的生产环境中,咱们可使用 nested-error-stacks
这类 npm 包来采集堆栈信息,原理其实也是基于 Error.captureStackTrace()。
这里有个问题是:try catch 代码块是同步的,对于异步 API 发生的错误,它不能捕获到。
好比下列代码:
try {
setTimeout(() => {
throw new Error('some error')
}, 1000)
} catch(e) {
console.log('some error...')
}
复制代码
错误并不能被捕获住。这个跟 Node.js 的事件循环机制有关,由于异步任务是经过事件队列来实现的,每次从事件队列中取出一个函数来执行时,实际上这个函数是在调用栈的最顶层执行的,若是它抛出了一个异常,也是没法沿着调用栈回溯到这个异步任务的建立者的。
下面介绍下在异步流程中,咱们应该怎么处理错误。
Node.js 中常见异步场景包括三类:
大部分异步 API 都遵循错误回调优先的约定,将 Error 做为 callback 的第一个参数来传递,这种风格比较相似函数式编程中的 Continuation-passing style。
fs.readFile(path, 'r', (err, data) => {
if (err) {
throw err
} else {
try {
// handle data
} catch(e) {
}
}
})
复制代码
这种写法很容易形成回调地狱。另外一方面,对于回调函数中的同步逻辑,咱们还须要用 try catch 去单独处理,这致使错误逻辑的处理被分散了两处。Promise 被正式 ES6 标准化后,咱们能够用 Promise 的链式调用来处理错误。
new Promise((resolve, reject) => {
reject(new Error('some error'));
})
.then(() => {
...
})
.then(() => {
...
})
.catch(err => {
});
复制代码
这样,Promise 链上的错误都会在 catch 方法上捕获住。对于没有 catch 的 Promise 异常,会一直冒泡到顶层,在 process.unhandledRejection
事件上被捕获住。
还有一类是 EventEmitter 对象上的错误。它们会被分发到 error 事件上进行处理,好比 Stream 等。咱们须要去为每个流去监听 error 事件,不然会冒泡到process.uncaughtException 事件上去。
异步场景中,还有个问题就是,会丢失异步回调前的错误堆栈。缘由仍是上文提到的 Node.js 事件循环机制。
const foo = function () {
throw new Error('some error')
}
const bar = function () {
setTimeout(foo)
}
bar()
复制代码
输出结果:
Error: some error
at Timeout.foo [as _onTimeout] (/Users/frank/code/m/demo/readdir.js:47:9)
at ontimeout (timers.js:436:11)
at tryOnTimeout (timers.js:300:5)
at listOnTimeout (timers.js:263:5)
at Timer.processTimers (timers.js:223:10)
复制代码
能够看到丢失了 bar 的调用栈。然而在 Node.js 中,异步调用场景还挺多的,有什么办法能够将多个异步调用给串起来,获取到完整的调用链信息呢?答案是有的。Node.js v8+ 上提供了 async_hooks 模块,用来完善异步场景的监控。
async_hooks 提供了一些 API 用于跟踪 Node.js 中的异步资源的生命周期。有几个概念:
console.log('global.asyncId:', async_hooks.executionAsyncId()); // global.asyncId: 1
console.log('global.triggerAsyncId:', async_hooks.triggerAsyncId()); // global.triggerAsyncId: 0
fs.open('./app.js', 'r', (err, fd) => {
console.log('fs.open.asyncId:', async_hooks.executionAsyncId()); // fs.open.asyncId: 7
console.log('fs.open.triggerAsyncId:', async_hooks.triggerAsyncId()); // fs.open.triggerAsyncId: 1
});
复制代码
回调函数中的 triggerAsyncId 为 1,它等于 global scope 上的 asyncId。这样就能够拿到多个异步调用的调用链。
国内的赵坤大神写过一个 koa 日志中间件 koa-await-breakpoint,用于实如今每一个 await 执行的语句先后进行自动打点工做。
// On top of the main file
const koaAwaitBreakpoint = require('koa-await-breakpoint')({
name: 'api',
files: ['./routes/*.js']
})
const Koa = require('koa')
const app = new Koa()
// Generally, above other middlewares
app.use(koaAwaitBreakpoint)
...
app.listen(3000)
复制代码
每一个请求到来时,生成一个 requestId 挂载到 ctx 上,经过 requestId 将日志串起来。核心原理是 hack 了模块的 require 方法(重载 Module.prototype._compile),用 esprima 将模块代码转成 AST,找到其中的 awaitExpression 节点,对其用日志函数包裹后从新插入到 AST,最后用 escodegen 将 AST 生成代码。其中还用到了 async_hooks,在日志函数中,基于 async_hooks 的 init 钩子中将异步调用关系存储到一个 Map 中,最终实现函数调用链的自动日志打点。
不过,使用 async_hooks 在目前有较严重的性能损耗。建议生产环境慎用。下图展现了 Node.js 9.4.0 上,async_hooks 在 Hapi 和 Koa 这两款框架上的性能比较。
错误可分为外部错误和内部错误两类。对外部错误的处理主要考验系统架构的设计,只有系统设计的足够健壮,才可以抵御各类外部挑战,并损失降到最低。对于内部错误,本文分别讨论了同步和异步两种场景,介绍了 Error.captureStackTrace()
、async_hooks
等 API 在收集错误堆栈、异步调用链上的用途,并结合 koa-await-breakpoint 源码,解释了 Node.js 自动化打点的核心原理。
参考连接: