Async Hooks 是 Node8 新出來的特性，提供了一些 API 用于跟蹤 NodeJs 中的異步資源的生命周期，屬于 NodeJs 內(nèi)置模塊，可以直接引用。

const async_hooks = require('async_hooks');

這是一個(gè)很少使用的模塊，為什么會(huì)有這個(gè)模塊呢？

我們都知道，JavaScript在設(shè)計(jì)之初就是一門單線程語言，這和他的設(shè)計(jì)初衷有關(guān)，最初的JavaScript僅僅是用來進(jìn)行頁(yè)面的表單校驗(yàn)，在低網(wǎng)速時(shí)代降低用戶等待服務(wù)器響應(yīng)的時(shí)間成本。隨著Web前端技術(shù)的發(fā)展，雖然前端功能越來越強(qiáng)大，越來越被重視，但是單線程似乎也沒有什么解決不了的問題，相比較而言多線程似乎更加的復(fù)雜，所以單線程依舊被沿用至今。

既然JavaScript是單線程，但是在日常開發(fā)中總是會(huì)有一些比較耗時(shí)的任務(wù)，比如說定時(shí)器，再比如說如今已經(jīng)標(biāo)準(zhǔn)化的Ajax，JavaScript為了解決這些問題，將自身分為了BOM，DOM，ECMAScript，BOM會(huì)幫我們解決這些耗時(shí)的任務(wù)，稱之為異步任務(wù)。

正因?yàn)闉g覽器的BOM幫我們處理了異步任務(wù)，所以大部分的程序員對(duì)異步任務(wù)除了會(huì)用幾乎一無所知，比如同時(shí)有多少異步任務(wù)在隊(duì)列中？異步是否擁堵等，我們都是沒有辦法直接獲得相關(guān)信息的，很多情況下，底層確實(shí)也不需要我們關(guān)注相關(guān)的信息，但如果我們?cè)谀承┣闆r下想要相關(guān)信息的時(shí)候，NodeJS提供了一個(gè)Experimental的API供我們使用，也就是async_hooks。為什么是NodeJS呢，因?yàn)橹挥性贜ode中定時(shí)器，http這些異步模塊，才是開發(fā)者可以控制的，瀏覽器中的BOM是不被開發(fā)者控制的，除非瀏覽器提供對(duì)應(yīng)的API。

async_hooks規(guī)則

async_hooks約定每一個(gè)函數(shù)都會(huì)提供一個(gè)上下文，我們稱之為async scope，每一個(gè)async scope中都有一個(gè) asyncId, 是當(dāng)前async scope的標(biāo)志，同一個(gè)的async scope中asyncId必然相同。

這在多個(gè)異步任務(wù)并行的時(shí)候，asyncId可以使我們可以很好的區(qū)分要監(jiān)聽的是哪一個(gè)異步任務(wù)。

asyncId是一個(gè)自增的不重復(fù)的正整數(shù)，程序的第一個(gè)asyncId必然是1。

async scope通俗點(diǎn)來說就是一個(gè)不能中斷的同步任務(wù)，只要是不能中斷的，無論多長(zhǎng)的代碼都共用一個(gè)asyncId，但如果中間是可以中斷的，比如是回調(diào)，比如中間有await，都會(huì)創(chuàng)建一個(gè)新的異步上下文，也會(huì)有一個(gè)新的asyncId。

每一個(gè)async scope中都有一個(gè)triggerAsyncId表示當(dāng)前函數(shù)是由那個(gè)async scope觸發(fā)生成的；

通過 asyncId 和 triggerAsyncId 我們可以很方便的追蹤整個(gè)異步的調(diào)用關(guān)系及鏈路。

async_hooks.executionAsyncId()用于獲取asyncId，可以看到全局的asyncId是1。

async_hooks.triggerAsyncId()用于獲取triggerAsyncId，目前值為0。

const async_hooks = require('async_hooks');
console.log('asyncId:', async_hooks.executionAsyncId()); // asyncId: 1
console.log('triggerAsyncId:', async_hooks.triggerAsyncId()); // triggerAsyncId: 0

我們這里使用fs.open打開一個(gè)文件，可以發(fā)現(xiàn)fs.open的asyncId是7，而fs.open的triggerAsyncId變成了1，這是因?yàn)閒s.open是由全局調(diào)用觸發(fā)的，全局的asyncId是1。

const async_hooks = require('async_hooks');
console.log('asyncId:', async_hooks.executionAsyncId()); // asyncId: 1
console.log('triggerAsyncId:', async_hooks.triggerAsyncId()); // triggerAsyncId: 0
const fs = require('fs');
fs.open('./test.js', 'r', (err, fd) => {
    console.log('fs.open.asyncId:', async_hooks.executionAsyncId()); // 7
    console.log('fs.open.triggerAsyncId:', async_hooks.triggerAsyncId()); // 1
});

異步函數(shù)的生命周期

當(dāng)然實(shí)際應(yīng)用中的async_hooks并不是這樣使用的，他正確的用法是在所有異步任務(wù)創(chuàng)建、執(zhí)行前、執(zhí)行后、銷毀后，觸發(fā)回調(diào)，所有回調(diào)會(huì)傳入asyncId。

我們可以使用async_hooks.createHook來創(chuàng)建一個(gè)異步資源的鉤子，這個(gè)鉤子接收一個(gè)對(duì)象作為參數(shù)來注冊(cè)一些關(guān)于異步資源生命周期中可能發(fā)生事件的回調(diào)函數(shù)。每當(dāng)異步資源被創(chuàng)建/執(zhí)行/銷毀時(shí)這些鉤子函數(shù)會(huì)被觸發(fā)。

const async_hooks = require('async_hooks');

const asyncHook = async_hooks.createHook({
  init(asyncId, type, triggerAsyncId, resource) { },
  destroy(asyncId) { }
})

目前 createHook 函數(shù)可以接受五類 Hook Callbacks 如下：

1.init(asyncId, type, triggerAsyncId, resource)

• init 回調(diào)函數(shù)一般在異步資源初始化的時(shí)候被觸發(fā)。
• asyncId: 每一個(gè)異步資源都會(huì)生成一個(gè)唯一性標(biāo)志
• type: 異步資源的類型，一般都是資源的構(gòu)造函數(shù)的名字。

FSEVENTWRAP, FSREQCALLBACK, GETADDRINFOREQWRAP, GETNAMEINFOREQWRAP, HTTPINCOMINGMESSAGE,
HTTPCLIENTREQUEST, JSSTREAM, PIPECONNECTWRAP, PIPEWRAP, PROCESSWRAP, QUERYWRAP,
SHUTDOWNWRAP, SIGNALWRAP, STATWATCHER, TCPCONNECTWRAP, TCPSERVERWRAP, TCPWRAP,
TTYWRAP, UDPSENDWRAP, UDPWRAP, WRITEWRAP, ZLIB, SSLCONNECTION, PBKDF2REQUEST,
RANDOMBYTESREQUEST, TLSWRAP, Microtask, Timeout, Immediate, TickObject

• triggerAsyncId: 表示觸發(fā)當(dāng)前異步資源被創(chuàng)建的對(duì)應(yīng)的 async scope 的 asyncId
• resource: 代表被初始化的異步資源對(duì)象

我們可以通過 async_hooks.createHook 函數(shù)來注冊(cè)關(guān)于每個(gè)異步資源在生命周期中發(fā)生的 init/before/after/destory/promiseResolve 等相關(guān)事件的監(jiān)聽函數(shù)；
同一個(gè) async scope 可能會(huì)被調(diào)用及執(zhí)行多次，不管執(zhí)行多少次，其 asyncId 必然相同，通過監(jiān)聽函數(shù)，我們很方便追蹤其執(zhí)行的次數(shù)及時(shí)間及上線文關(guān)系；

2.before(asyncId)

before函數(shù)一般在 asyncId 對(duì)應(yīng)的異步資源操作完成后準(zhǔn)備執(zhí)行回調(diào)前被調(diào)用，before回調(diào)函數(shù)可能被執(zhí)行多次，由其被回調(diào)的次數(shù)來決定，使用時(shí)這里需要注意。

3.after(asyncId)

after回調(diào)函數(shù)一般在異步資源執(zhí)行完回調(diào)函數(shù)后會(huì)立即被調(diào)用，如果在執(zhí)行回調(diào)函數(shù)的過程中發(fā)生未捕獲的異常，after 事件會(huì)在觸發(fā) “uncaughtException” 事件后被調(diào)用。

4.destroy(asyncId)

當(dāng)asyncId對(duì)應(yīng)的異步資源被銷毀時(shí)調(diào)用，有些異步資源的銷毀要依賴?yán)厥諜C(jī)制，所以有些情況下由于內(nèi)存泄漏的原因，destory事件可能永遠(yuǎn)不會(huì)被觸發(fā)。

5.promiseResolve(asyncId)

當(dāng) Promise 構(gòu)造器中的 resovle 函數(shù)被執(zhí)行時(shí)，promiseResolve 事件被觸發(fā)。有些情況下，有些 resolve 函數(shù)是被隱式執(zhí)行的，比如 .then 函數(shù)會(huì)返回一個(gè)新的 Promise，這個(gè)時(shí)候也會(huì)被調(diào)用。

const async_hooks = require('async_hooks');

// 獲取當(dāng)前執(zhí)行上下文的 asyncId
const eid = async_hooks.executionAsyncId();

// 獲取觸發(fā)當(dāng)前函數(shù)的 asyncId
const tid = async_hooks.triggerAsyncId();

// 創(chuàng)建新的AsyncHook實(shí)例。所有這些回調(diào)都是可選的
const asyncHook =
    async_hooks.createHook({ init, before, after, destroy, promiseResolve });

// 需要顯示聲明 才能執(zhí)行
asyncHook.enable();

// 禁止監(jiān)聽新的異步事件。
asyncHook.disable();

function init(asyncId, type, triggerAsyncId, resource) { }

function before(asyncId) { }

function after(asyncId) { }

function destroy(asyncId) { }

function promiseResolve(asyncId) { }

Promise

promise是比較特殊的一種情況，如果足夠細(xì)心init方法中的type中你就會(huì)發(fā)現(xiàn)其中并沒有PROMISE。如果僅使用ah.executionAsyncId()來獲取Promise的的asyncId的話，是不能取得正確的ID的，只有在添加了實(shí)際的hook只后，async_hooks才會(huì)給Promise的回調(diào)創(chuàng)建asyncId。

換句話說，由于V8對(duì)于獲取 asyncId 的執(zhí)行成本比較高，所以默認(rèn)情況下，我們是不給 Promise 分配新的 asyncId。
也就是說默認(rèn)情況下，我們使用promises或者 async/await 時(shí)是獲取不到當(dāng)前上下文正確的asyncId和triggerId。不過沒關(guān)系，我們可以通過執(zhí)行async_hooks.createHook(callbacks).enable()函數(shù)強(qiáng)制開啟對(duì)Promise分配asyncId。

const async_hooks = require('async_hooks');

const asyncHook = async_hooks.createHook({
  init(asyncId, type, triggerAsyncId, resource) { },
  destroy(asyncId) { }
})

asyncHook.enable();

Promise.resolve(123).then(() => {
  console.log(`asyncId ${async_hooks.executionAsyncId()} triggerId ${async_hooks.triggerAsyncId()}`);
});

另外Promise只會(huì)觸發(fā)init和promiseResolve鉤子事件函數(shù)，而before和after事件的鉤子函數(shù)只會(huì)在Promise的鏈?zhǔn)秸{(diào)用時(shí)被觸發(fā)，也就是說只有在.then/.catch函數(shù)中生成的Promise時(shí)才會(huì)被觸發(fā)。

new Promise(resolve => {
    resolve(123);
}).then(data => {
    console.log(data);
})

可以發(fā)現(xiàn)，上面的存在兩個(gè)Promise，第一個(gè)是new實(shí)例化創(chuàng)建的，第二個(gè)是then創(chuàng)建的(不明白的可以查看之前的Promise源碼文章)。

這里的順序是執(zhí)行new Promise的時(shí)候會(huì)調(diào)用自身的init函數(shù)，然后在執(zhí)行resolve的時(shí)候調(diào)用promiseResolve函數(shù)。接著在then方法中執(zhí)行第二個(gè)Promise的init函數(shù)，然后執(zhí)行第二個(gè)Promise的before，promiseResovle，after函數(shù)。

異常處理

如果注冊(cè)的async-hook回調(diào)函數(shù)中發(fā)生異常，那么服務(wù)將打印錯(cuò)誤日志并立即退出，同時(shí)所有de 監(jiān)聽器將被移除，同時(shí)會(huì)觸發(fā) ‘exit' 事件退出程序。

之所以會(huì)立即退出進(jìn)程，是因?yàn)槿绻@些async-hook 函數(shù)運(yùn)行不穩(wěn)定，下一個(gè)相同事件被觸發(fā)時(shí)很可能又拋出異常，這些函數(shù)主要就是為了監(jiān)聽異步事件的，如果不穩(wěn)定應(yīng)該及時(shí)發(fā)現(xiàn)并進(jìn)行更正。

在異步鉤子回調(diào)中打印日志

由于 console.log 函數(shù)也是一個(gè)異步調(diào)用，如果我們?cè)?async-hook 函數(shù)中再調(diào)用 console.log 那么將再次觸發(fā)相應(yīng)的 hook 事件，造成死循環(huán)調(diào)用，所以我們?cè)?async-hook 函數(shù)中必須使用同步打印日志方式來跟蹤，可以使用 fs.writeSync 函數(shù)：

const fs = require('fs');
const util = require('util');

function debug(...args) {
  fs.writeFileSync('log.out', `${util.format(...args)}\n`, { flag: 'a' });
}

[參考文獻(xiàn)-AsyncHooks] (https://nodejs.org/dist/latest-v15.x/docs/api/async_hooks.html)

到此這篇關(guān)于Node8中AsyncHooks異步生命周期的文章就介紹到這了,更多相關(guān)Node AsyncHooks異步生命周期內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！