国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

node.js與ThreadLocal

jasperyang / 2395人閱讀

摘要:變量的說法來自于,這是在多線程模型下出現并發問題的一種解決方案。目前已經有庫實現了應用層棧幀的可控編碼,同時可以在該棧幀存活階段綁定相關數據,我們便可以利用這種特性實現類似多線程下的變量。

ThreadLocal變量的說法來自于Java,這是在多線程模型下出現并發問題的一種解決方案。
ThreadLocal變量作為線程內的局部變量,在多線程下可以保持獨立,它存在于
線程的生命周期內,可以在線程運行階段多個模塊間共享數據。那么,ThreadLocal變量
又如何與node.js扯上關系呢?

node模型

node的運行模型無需再贅言: “事件循環 + 異步執行”,可是node開發工程師比較感興趣的點
大多集中在 “編碼模式”上,即異步代碼同步編寫,由此提出了多種解決回調地獄的解決方案:

yield

thunk

promise

await

可是如果從代碼執行流程的微觀視角中跳出來,宏觀上看待node服務器處理每個HTTP請求,就會
發現這其實是多線程web服務器的另一種體現,雖然設計上并不像多線程模型那么直觀。在單核cpu中
每一時刻node服務器只能處理一個請求,可是node在當前請求中執行異步調用時,就會“中斷”進入下一個
事件循環處理另一個請求,直到上一個請求的異步任務事件觸發執行對應回調,繼續執行該請求的后續邏輯。
這在某種程度上類似于CPU的時間片搶占機制,微觀上的順序執行,宏觀上卻是同步執行。

node在單進程單線程(js執行線程)中“模擬”了常見的多線程處理邏輯,雖然在單個node進程中無法
充分利用CPU的多核及超線程特性,可是卻避免了多線程模型下的臨界資源同步和線程上下文
切換的問題,同時內存資源開銷相對較小,因此在I/O密集型的業務下使用node開發web服務
往往有著意想不到的好處。

可是在node開發中需要追蹤每個請求的調用鏈路,通過獲取請求頭的traceId字段在每一級
的調用鏈路中傳遞該字段,包括“http請求、dubbo調用、dao操作、redis和日志打點”等操作。
這樣通過追蹤traceId,就可以分析請求所經過的所有中間鏈路,評估每個環節的時延與瓶頸,
更容易進行性能優化和錯誤排查。

那么,如何在業務代碼中無侵入性的獲取到相關的traceId呢?這就引出了本文的ThreadLocal變量。

傳統的日志追蹤模式

需手動傳遞traceId給日志中間件:

var koa = require("koa");
var app =  new koa();
var Logger = {
    info(msg,traceId){
        console.log(msg,traceId);
    }
};
let business = async function(ctx){
    let v = await new Promise((res)=>{
        setTimeout(()=>{
            Logger.info("service執行結束",ctx.request.headers["traceId"])
            res(123);
        },1000);
    });
    ctx.body = "hello world";
    Logger.info("請求返回",ctx.request.headers["traceId"])
};

app.use(async(ctx,next)=>{
    ctx.request.headers["traceId"] = Date.now() + Math.random();
    await next();
});

app.use(async(ctx,next)=>{
    await business(ctx);
});

app.listen(8080);

在business業務處理函數中,在service執行結束和body返回后都進行日志打點,同時手動
傳遞請求頭traceId給日志模塊,方便相關系統追蹤鏈路。

目前這樣編碼無法規范化日志接口,同時也對開發人員造成了很大的困擾。對于業務開發人員他們
理應不關心如何進行鏈路追蹤,而目前的編碼則直接侵入了業務代碼中,這塊功能應該由日志模塊
Logger來實現,可是在與請求上下文沒有任何聯系的Logger模塊如何獲取每個請求的traceId呢?

這就需要依靠node.js中的ThreadLocal變量。文章開頭提到,多線程下ThreadLocal變量是與
每個線程的生命周期對應的,那么如果在node.js的“單線程+異步調用+事件循環”的特性下實現
類似的ThreadLocal變量,不就可以在每個請求的異步回調執行時獲取到對應的ThreadLocal變量,
拿到相關的上下文信息嗎?

ThreadLocal的node實現

單純實現web服務器的中間鏈路請求追蹤其實并不復雜,使用全局變量Map并通過每個請求的唯一標識
存儲上下文信息,當執行到該請求的下一個異步調用時便通過在全局Map中獲取到與該請求綁定的ThreadLocal
變量,不過這是在應用層面的一種投機行為,是與請求緊耦合的簡易實現。

最徹底的方案則是在node應用層實現一種棧幀,在該棧幀內重寫所有的異步函數,并添加各個
hook在異步函數的各個生命周期執行,實現異步函數執行上下文與棧幀的映射,這便是最為
徹底的ThreadLocal實現,而不是僅僅停留在與HTTP請求的映射過程中。

目前已經有zone.js庫實現了node應用層棧幀的可控編碼,同時可以在該棧幀存活階段綁定
相關數據,我們便可以利用這種特性實現類似多線程下的ThreadLocal變量。

我們的目標是實現無侵入的編寫包含鏈路追蹤的業務代碼,如下所示:

app.use(async(ctx,next)=>{
    let v = await new Promise((res)=>{
        setTimeout(()=>{
            Logger.info("service執行結束")
            res(123);
        },1000);
    });
    ctx.body = "hello world";
    Logger.info("請求返回")
});

相比較,Logger.info中不需要手動傳遞traceId變量,由日志模塊通過訪問ThreadLocal變量獲取。

通過zone.js提供的創建Zone(對應于棧幀)功能,我們不僅可以獲取當前請求(類似于多線程下的單個線程)的
ThreadLocal變量,還可以獲取上一個請求的相關信息。

require("zone.js");
var koa = require("koa");
var app =  new koa();
var Logger = {
    info(msg){
        console.log(msg,Zone.current.get("traceId"));
    }
};

var koaZoneProperties = {
    requestContext: null
};
var koaZone = Zone.current.fork({
    name: "koa",
    properties: koaZoneProperties
});
let business = async function(ctx){
    let v = await new Promise((res)=>{
        setTimeout(()=>{
            Logger.info("service執行結束")
            res(123);
        },1000);
    });
    ctx.body = "hello world";
    Logger.info("請求返回")
};
koaZone.run(()=>{
    app.use(async(ctx,next)=>{
        console.log(koaZone.get("requestContext"))
        ctx.request.headers["traceId"] = Date.now();
        await next();
    });
    
    app.use(async(ctx,next)=>{
        await new Promise((resolve)=>{
            let koaMidZone = koaZone.fork({
                name: "koaMidware",
                properties: {
                    traceId: ctx.request.headers["traceId"]
                }
            }).run(async()=>{
                // 保存請求上下文至parent zone
                koaZoneProperties.requestContext = ctx;
                await business(ctx);
                resolve();
            });
        });
    });
    
    app.listen(8080);
});

創建了兩個有繼承關系的zone(棧幀),koaZone的requestContext屬性存儲上一個請求的上下文信息;
koaMidZone的traceId屬性存儲traceId變量,這是一個ThreadLocal變量。
Logger.info中通過Zone.current.get("traceId") 獲取當前“線程”的
ThreadLocal變量,無需開發人員手動傳遞traceId變量。

關于zone.js的其他用法,讀者有興趣可以自行研究。本文主要利用zone.js保存一個執行棧幀
內的多個異步函數的執行上下文與特定數據(即ThreadLocal變量)的映射。

說明

目前,這套模型已在線上業務中用來追蹤各級鏈路,各級中間件包括dubbo client、dubbo provider、
配置中心等都依賴ThreadLocal變量實現數據透傳和調用傳遞,因此可以放心使用。

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/95306.html

相關文章

  • ThreadLocal 線程安全機制小地雷

    摘要:多線程類庫對于共享數據的讀寫控制主要采用鎖機制保證線程安全,本文所要探究的則采用了一種完全不同的策略。所以出現內存泄露的前提必須是持有的線程一直存活,這在使用線程池時是很正常的,在這種情況下一直不會被,因為 Java 多線程類庫對于共享數據的讀寫控制主要采用鎖機制保證線程安全,本文所要探究的 ThreadLocal 則采用了一種完全不同的策略。ThreadLocal 不是用來解決共享數...

    xiao7cn 評論0 收藏0
  • ThreadLocal詳解

    摘要:在方法中取出開始時間,并計算耗時。是一個數組主要用來保存具體的數據,是的大小,而這表示當中元素數量超過該值時,就會擴容。如果這個剛好就是當前對象,則直接修改該位置上對象的。 想要獲取更多文章可以訪問我的博客?-?代碼無止境。 什么是ThreadLocal ThreadLocal在《Java核心技術 卷一》中被稱作線程局部變量(PS:關注公眾號itweknow,回復Java核心技術獲取該...

    2501207950 評論0 收藏0
  • java并發編程學習17--ThreadLocal

    摘要:概念類用來存放線程的局部變量,每個線程都有自己的局部變量彼此之間不共享。返回當前線程的局部變量初始值。工作流程的時候我們可以看見是從中獲取的,也就是說這些局部變量真正存儲在中的時候從中獲取到了,然后再從中獲取。和都用于解決多線程并發訪問。 【概念 ThreadLocal類用來存放線程的局部變量,每個線程都有自己的局部變量彼此之間不共享。TheadLocal主要有以下三個方法: pub...

    jayce 評論0 收藏0
  • 【源起Netty 外傳】FastThreadLocal怎么Fast?

    摘要:實現原理淺談幫助理解的示意圖中有一屬性,類型是的靜態內部類。剛剛說過,是一個中的靜態內部類,則是的內部節點。這個會在線程中,作為其屬性初始是一個數組的索引,達成與類似的效果。的方法被調用時,會根據記錄的槽位信息進行大掃除。 概述 FastThreadLocal的類名本身就充滿了對ThreadLocal的挑釁,快男FastThreadLocal是怎么快的?源碼中類注釋坦白如下: /** ...

    gxyz 評論0 收藏0

發表評論

0條評論

最新活動
閱讀需要支付1元查看
<