千家信息网

在node中如何打印全链路日志

发表于:2026-11-02 作者:千家信息网编辑
千家信息网最后更新 2026年11月02日,这篇文章给大家分享的是有关在node中如何打印全链路日志的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。当用户报问题:线上某个功能使用报错时,如何快速准确地定位?当某个请求接
千家信息网最后更新 2026年11月02日在node中如何打印全链路日志

这篇文章给大家分享的是有关在node中如何打印全链路日志的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。

当用户报问题:线上某个功能使用报错时,如何快速准确地定位?当某个请求接口返回数据缓慢时,如何有效地追踪优化?

一、原理和实践

众所周知,当一个请求到来时,大概会有以下日志产生:

1、AceesLog:用户访问日志

2、Exception:代码异常日志

3、SQL:sql查询日志

4、ThirdParty:第三方服务日志

该如何追踪一条请求产生的所有日志?

一般做法是使用一个requestId来做唯一标识,

然后写一个中间件,把requestId注入到context上下文中,当需要打日志时,再从context中取出打印,

在第三方服务和SQL日志中,还需要把requestId传入到相应的函数里面打印,这样层层传递,实在太麻烦,代码侵入性也比较强。

我们的目标是降低代码侵入性,一次注入,自动跟踪。

经过调研,async_hooks可以追踪异步行为的生命周期,在每个异步资源(每个请求都是一个异步资源)中,它都有2个ID,

分别是asyncId(异步资源当前生命周期ID),trigerAsyncId(父级异步资源ID)。

async_hooks提供了以下生命周期钩子来监听异步资源:

asyncHook = async_hook.createHook({  // 监听异步资源的创建  init(asyncId,type,triggerAsyncId,resource){},  // 异步资源回调函数开始执行之前  before(asyncId){},  // 异步资源回调函数开始执行后  after(asyncId){},  // 监听异步资源的销毁  destroy(asyncId){}})

那如果我们做一个映射,每个asyncId映射一个storage,storage里面再存储对应的requestId,那requestId就可以很容易获取了。

正好cls-hooked这个库已经基于async_hooks做好了封装,在同一份异步资源维护一份数据,以键值对的形式存储。(注意:async_hooked需要在高版本node>=8.2.1使用)当然社区中还有其他的实现,比如cls-session,node-continuation-local-storage等。

下面讲下我把cls-hooked运用在我项目中的实例:

/session.js 创建命名存储空间

const createNamespace = require('cls-hooked').createNamespace const session = createNamespace('requestId-store') module.exports = session

/logger.js 打印日志

const session = require('./session') module.exports = { info: (message) => { const requestId = session.get('requestId')console.log(`requestId:${requestId}`, message) }, error: (message) => { const requestId = session.get('requestId') console.error(`requestId:${requestId}`, message) } }

/sequelize.js sql调用logger打印日志

const logger = require("./logger") new Sequelize( logging: function (sql, costtime) { logger.error( `sql exe : ${sql} | costtime ${costtime} ms` ); } )

/app.js 设置requestId、设置requestId返回响应头、打印访问日志

const session = require('./session') const logger = require('./logger') async function accessHandler(ctx, next) { const requestId = ctx.header['x-request-id'] || uuid()const params = ctx.request.body ? JSON.stringify(ctx.request.body) : JSON.stringify(ctx.request.query)// 设置requestId session.run(() => { session.set('requestId', requestId)logger.info(`url:${ctx.request.path};params:${params}`) next()// 设置返回响应头ctx.res.setHeader('X-Request-Id',requestId)}) }

我们看下当一条请求路径是/home?a=1到来时的日志:

访问日志:requestId:79f422a6-6151-4bfd-93ca-3c6f892fb9ac url:/home;params:{"a":"1"}Sql日志:requestId:79f422a6-6151-4bfd-93ca-3c6f892fb9ac sql exe :Executed (default): SELECT `id` FROM t_user

可以看到同一条请求整个链路的日志requestId是一样的。如果后面有告警发到告警平台,那么我们根据requestId就可以找到这条请求执行的整个链路了。

细心的同学可能会观察到我在接口返回的响应头里面也设置了requestId,目的就是为了后续如果发现某条请求响应缓慢或者有问题,那直接从浏览器就可以知道requestId,就可以做分析了。

二、性能开销

我本地做了一下压测,

这是内存的占用对比:

比未使用async_hook多了约10%。

对于我们qps是百级别的系统还好,但是如果是高并发的服务,可能要慎重考虑下了。

感谢各位的阅读!关于"在node中如何打印全链路日志"这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!

日志 资源 链路 代码 函数 周期 生命 存储 服务 监听 缓慢 内容 接口 数据 更多 用户 第三方 篇文章 问题 不错 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 手冲咖啡和咖啡机区别 保险科技 互联网保险 A股互联网金融科技公司 高科技与互联网 互联网与新科技 亿策互联网科技 互联网科技缩写 中正互联网科技招聘 无锡溥仪互联网科技有限公司 汉立互联网科技有限公司联系电话 湖南洣水互联网科技有限公司扣款 崇明区互联网教育科技售后服务 广西互联网科技孵化中心 工业互联网等科技实现智能化赋能 互联网金融科技元年 半导体行业属于互联网高科技类吗 科技互联网行业投资研究 容联科技互联网电商 互联网的科技体现在哪里 北京瑞云互联网科技有限公司 互联网科技集团 奇酷互联网科技 丰台科技园 互联网公司 中正互联网科技招聘 福州新华互联网科技学校 知乎 昭通互联网科技选哪家 互联网科技的全部知识 云鲸互联网络科技有限公司 江苏互联网智能科技产品出厂价 山东亿川互联网科技有限责任公司
0