針對使用非塊運行和塊運行併發壓測對比

時間 2019-11-08

標籤針對使用運行併發對比简体版

原文原文鏈接

該文使用源碼地址：地址html

爲何會有這個實驗

因爲cnode上的一篇提問 node.js單線程,是否是就不用消息隊列了啊?

我當時的回答是
node

舉個例子，你要在數據表查是否有同名的，沒同名則插入。
由於node沒法按整個請求的sql塊做爲執行單元，而是按sql條做爲了執行單元，那麼按上面的來講兩個select會前後到達，而第一條insert並無插入，致使第二個select查詢爲空，還會繼續插入用戶。（若是表小可能不會出現，表大必現）
而消息隊列則至關因而已將請求的整個sql塊做爲執行單元，即完成了整個請求的select和insert，纔會執行下一個請求的select和insert。

這個回答是根據我以往在node遇到的坑，來回答的。貌似頗有道理，畢竟咱們平時執行node都是按條做爲異步的最小單元執行的。

可是過後我想，那爲何不能將node塊作爲順序執行單位呢？
git

沒錯，它確實能夠

遂在當天晚上作了一個簡單的塊運行庫，簡單測試了一下，感受好像是實現了，但因爲業務繁忙（產品需求激增），因此一直沒有時間去作優化和針對數據庫的實際的測試！遂於週末來測試一下。

我這邊實現了三套針對數據庫的併發測試
github

樂觀鎖抗併發
事務加樂觀鎖抗併發
塊執行加樂觀鎖抗併發

主要代碼以下

樂觀鎖抗併發

async function sqlCommon(sqlCommonName = 'sqlCommon')
{
    let conn;
    try{
        conn = await getConn();
        let testSelete = await queryPromise(
            conn,
            'SELECT * FROM `test` WHERE `name`= ? AND `version`=?',
            [getName(sqlCount),sqlCount]
        );
        if(testSelete.length>0)
        {
            let testRes = await queryPromise(
                conn,
                'UPDATE `test` SET `name`= ?,`version`=?+1 WHERE `version`=?',
                [getName(sqlCount+1),sqlCount,sqlCount]
            );
            if(testRes.affectedRows>0)
            {
                sqlCount++;
            } else {
                console.log(`${sqlCommonName} failed:${sqlCount}`)
            }
        } else {
            console.log(`${sqlCommonName} failed:${sqlCount}`)
        }
        conn.release();
    } catch(e){
        console.log(`${sqlCommonName} failed:${sqlCount}`)
        conn.release();
        // console.log(e.stack)
    }
}

事務加樂觀鎖抗併發

async function sqlTrans()
{
    let conn;
    try{
        conn = await getConn();
        await queryPromise(conn,'SET TRANSACTION ISOLATION LEVEL SERIALIZABLE;')
        beginTransaction(conn);
        let testSelete = await queryPromise(
            conn,
            'SELECT * FROM `test` WHERE `name`= ? AND `version`=?',
            [getName(sqlCount),sqlCount]
        );
        if(testSelete.length>0)
        {
            let testRes = await queryPromise(
                conn,
                'UPDATE `test` SET `name`= ?,`version`=?+1 WHERE `version`=?',
                [getName(sqlCount+1),sqlCount,sqlCount]
            );
            if(testRes.affectedRows>0)
            {
                sqlCount++;
            } else {
                console.log(`sqlTrans failed:${sqlCount}`)
                rollback(conn);
            }
        } else {
            console.log(`sqlTrans failed:${sqlCount}`)
        }
        commit(conn);
        conn.release();
    } catch(e){
        console.log(`sqlTrans failed:${sqlCount}`)
        // console.log(e.stack);//這裏會爆出不少事務鎖錯誤
        rollback(conn);
        conn.release();
    }
}

塊執行加樂觀鎖抗併發(僅僅是將樂觀鎖，放如塊執行的某個渠道，改造很簡單)

樂觀鎖須要的包地址

 樂觀鎖須要的倉庫地址
sql

function sqlBlock()
{
    return new Promise ((reslove,rejected)=>{
        BlockRun.run('sqlBlockChannel1',async ()=>{
            await sqlCommon('sqlBlock');
            reslove(true)
        },3000);
    });
}

主服務入口

http.createServer( async (request, response) => {
    try {
    let pathname = url.parse(request.url).pathname;
    //console.log(`url:http://127.0.0.1:${port}{$pathname}`)
    let showText = 'test';
    switch (pathname)
    {
        case '/clear':
            await sqlClear();
            showText = 'clear';
            break;
        case '/common':
            await sqlCommon();
            showText = 'common';
            break;
        case '/trans':
            await sqlTrans();
            showText = 'trans';
            break;
        case '/block':
            await sqlBlock();
            showText = 'block';
            break;
    }
    response.writeHead(200, {'Content-Type': 'text/html'});    
    response.write(showText);
    response.end();
    } catch(e) {
        console.log(e.stack)
    }
 }).listen(port);