Nodeはリクエスト追跡にasync_hooksモジュールを使用します

const { createHook、AsyncResource、executionAsyncId } = require('async_hooks')

constフック = createHook({
 init (asyncId、タイプ、トリガーAsyncId、リソース) {},
 前 (asyncId) {},
 (asyncId) {} の後、
 破棄 (非同期 ID) {}
})
フックを有効にする()

関数fn(){
 コンソールログ(executionAsyncId())
}

const asyncResource = 新しい AsyncResource('demo')
asyncResource.run(fn)
asyncResource.run(fn)
asyncResource.emitDestroy()

定数 http = require('http')
const { createHook, 実行AsyncId } = require('async_hooks')
定数 fs = require('fs')

// 呼び出しチェーンを追跡し、呼び出しチェーン ストレージ オブジェクトを作成します。const cache = {}
constフック = createHook({
 init (asyncId、タイプ、トリガーAsyncId、リソース) {
  if (type === 'TickObject') 戻り値
  // console.log も Node.js の非同期動作であるため、init フックがトリガーされ、同期メソッドを通じてのみログを記録できます。 fs.appendFileSync('log.out', `init ${type}(${asyncId}: trigger: ${triggerAsyncId})\n`);
  // 呼び出しチェーンストレージオブジェクトが初期化されているかどうかを判定します if (!cache[triggerAsyncId]) {
   キャッシュ[triggerAsyncId] = {}
  }
  // 親ノードのストレージを現在の非同期リソースと参照で共有します。cache[asyncId] = cache[triggerAsyncId]
 }
})
フックを有効にする()

// httpを書き換える
定数 httpRequest = http.request
http.request = (オプション、コールバック) => {
 const client = httpRequest(オプション、コールバック)
 // 現在のリクエストに対応する非同期リソースに格納されているリクエストIDを取得し、それをヘッダーに書き込みます
 定数 requestId = キャッシュ[executionAsyncId()].requestId
 console.log('キャッシュ', キャッシュ[executionAsyncId()])
 client.setHeader('リクエストID', リクエストID)

 顧客を返す
}

関数タイムアウト（）{
 新しい Promise を返します ((resolve, reject) => {
  setTimeout(resolve, Math.random() * 1000)
 })
}
// サービス http を作成する
 .createServer(非同期(req, res) => {
  // 現在のリクエストのリクエスト ID を取得し、ストレージ キャッシュに書き込みます [executionAsyncId()].requestId = req.headers['request-id']
  //他の時間のかかる操作をシミュレートする await timeout()
  // リクエストを送信 http.request('http://www.baidu.com', (res) => {})
  res.write('hello\n')
  res.end()
 })
 .聞く(3000)

  if (!cache[triggerAsyncId]) {
   キャッシュ[トリガー同期ID] = {
    id: トリガー非同期Id
   }
  }

関数タイムアウト（）{
 新しい Promise を返します ((resolve, reject) => {
  setTimeout(解決、[1000, 5000].pop())
 })
}

定数 http = require('http')
const { createHook, 実行AsyncId } = require('async_hooks')
定数 fs = require('fs')
定数キャッシュ = {}

定数 httpRequest = http.request
http.request = (オプション、コールバック) => {
 const client = httpRequest(オプション、コールバック)
 定数 requestId = キャッシュ[executionAsyncId()].requestId
 console.log('キャッシュ', キャッシュ[executionAsyncId()])
 client.setHeader('リクエストID', リクエストID)

 リターンクライアント
}

// ストレージの初期化を独立したメソッドに抽出します。async function cacheInit (callback) {
 // await 操作を使用して、await 後のコードが新しい非同期コンテキストに入るようにします。await Promise.resolve()
 キャッシュ[executionAsyncId()] = {}
 // 後続の操作がこの新しい非同期コンテキストに属するようにコールバック実行を使用します。callback() を返します。
}

constフック = createHook({
 init (asyncId、タイプ、トリガーAsyncId、リソース) {
  if (!cache[triggerAsyncId]) {
   // init フックはもはや初期化しません return fs.appendFileSync('log.out', `cacheInit メソッドを使用して初期化されていません`)
  }
  キャッシュ[非同期ID] = キャッシュ[トリガー非同期ID]
 }
})
フックを有効にする()

関数タイムアウト（）{
 新しい Promise を返します ((resolve, reject) => {
  setTimeout(解決、[1000, 5000].pop())
 })
}

http
.createServer(非同期(req, res) => {
 // 後続の操作をcacheInitへのコールバックとして渡す
 cacheInitを待機します(非同期関数fn() {
  cache[executionAsyncId()].requestId = req.headers['リクエストID']
  タイムアウトを待つ()
  http.request('http://www.baidu.com', (res) => {})
  res.write('hello\n')
  res.end()
 })
})
.聞く(3000)

非同期関数ミドルウェア (ctx, next) {
 Promise.resolve() を待つ
 キャッシュ[executionAsyncId()] = {}
 次を返す()
}

const { AsyncLocalStorage } = require('async_hooks')
// asyncLocalStorage ストレージインスタンスを直接作成します。非同期ライフサイクルフックを管理する必要がなくなります。const asyncLocalStorage = new AsyncLocalStorage()
定数ストレージ = {
 有効にする（コールバック）{
  // 新しいストレージを作成するには run メソッドを使用し、その後の操作は新しい非同期リソース コンテキストを使用するために run メソッドのコールバックとして実行する必要があります asyncLocalStorage.run({}, callback)
 },
 取得 (キー) {
  asyncLocalStorage.getStore()[キー]を返す
 },
 (キー、値) を設定する {
  asyncLocalStorage.getStore()[キー] = 値
 }
}

// httpを書き換える
定数 httpRequest = http.request
http.request = (オプション、コールバック) => {
 const client = httpRequest(オプション、コールバック)
 // 非同期リソースストレージのリクエストIDを取得し、ヘッダーに書き込みます
 client.setHeader('リクエストID', storage.get('リクエストId'))

 リターンクライアント
}

// http を使用する
 .createServer((req, res) => {
  ストレージを有効にする(非同期関数() {
   // 現在のリクエストのリクエスト ID を取得し、ストレージに書き込みます。storage.set('requestId', req.headers['request-id'])
   http.request('http://www.baidu.com', (res) => {})
   res.write('hello\n')
   res.end()
  })
 })
 .聞く(3000)