JS事件循環(huán)問(wèn)題

我的需求：

 我的需求可以簡(jiǎn)單描述為，對(duì)一個(gè)大文件進(jìn)行分片切割上傳。我實(shí)現(xiàn)的思路為，
 對(duì)一個(gè)大文件，按照設(shè)定的chunksSize切分為N = file.size/chunkSize塊，
 然后循環(huán)創(chuàng)建N個(gè)讀流讀取每個(gè)分片的內(nèi)容，然后發(fā)起N個(gè)http.request的Post請(qǐng)求去上傳文件。
 

代碼如下
（說(shuō)明： upload函數(shù)用來(lái)根據(jù)分塊的個(gè)數(shù)n,計(jì)算每塊起始標(biāo)志位和終止標(biāo)識(shí)位，并調(diào)用senddataPromise函數(shù)對(duì)每片進(jìn)行操作）

function  upload(username,filepath,file_id,filelength,n,alreadychunks,chunkSize) {
    return new Promise(function (resolve,reject) {
            var start = 0,end = 0;
            var promiseall = [];
            for (let curindex = 0;curindex < n;curindex++) {
                if(filelength - start <= chunkSize) {
                    end  =  filelength - 1;
                }else {
                    end = start+chunkSize - 1; // 因讀取時(shí)包含start和end位
                }
                if(alreadychunks.indexOf(curindex) == -1) {
                    let options = {
                        flags: 'r',
                        highWaterMark: chunkSize,
                        start: start,
                        end: end
                    };
                    promiseall.push(senddataPromise(filepath,options,username,file_id,curindex,end-start+1));
                }
                start = end + 1;
            }
            let timer = setInterval(() => {
                if(promiseall.length == n) {
                    clearInterval(timer);
                    Promise.all(promiseall).then(values=>{
                        console.log(values);
                        console.log("all done");
                        resolve(true)
                    }).catch(err => {
                        console.log(err);
                        reject(err);
                    })
                }
            },500)
    })
}

senddataPromise函數(shù)是對(duì)第i塊分片創(chuàng)建讀流讀取內(nèi)容，并調(diào)用doapost函數(shù)發(fā)送到后端

function senddataPromise(path,options,username,summary,curindex,length) {
    return new Promise(function (resolve,reject) {
        let readSteam = fs.createReadStream(path,options);
        readSteam.on("data",(chunk) => {
            console.log("第"+curindex+"塊 JSON開始")
            let chunkjson = JSON.stringify(chunk);
            console.log("第"+curindex+"塊 JSON結(jié)束")
            let tempcell = {
                data: chunkjson,
                n: curindex,
                file_id: summary,
                username: username,
                length: length
            };
            chunk = null;
            chunkjson = null;
            doapost(tempcell).then(values=>{
                resolve(values)
            }).catch(err=>{
                reject(err);
            });
        })
    })
}

doapost函數(shù)發(fā)起post請(qǐng)求發(fā)送分片數(shù)據(jù)

function  doapost(data) {
    return new Promise(function (resolve,reject) {
        let i = data.n;
        console.log("第"+i+"份請(qǐng)求準(zhǔn)備發(fā)出")
        let contents = queryString.stringify(data);
        data = null;
        let options = {
            host: "localhost",
            path: "/nodepost/",
            port: 8000,
            method: 'POST',
            headers: {
                'Content-Type': 'application/x-www-form-urlencoded',
                'Content-Length': contents.length
            }
        };
        let req = http.request(options, function (res) {
            console.log("第"+i+"份請(qǐng)求返回?cái)?shù)據(jù)")
            res.on("data", function (chunk) {
                console.log(chunk.toString());
            });
            res.on("end", function (d) {
                resolve("end");
            });
            res.on("error", function (e) {
                reject(e);
            })
        });
        req.write(contents);
        req.end();
        contents = null;
        console.log("第"+i+"份請(qǐng)求已發(fā)出")
    })
}

我的問(wèn)題：

  按照正常的思路，因?yàn)樽x取文件內(nèi)容為異步操作，后面發(fā)送請(qǐng)求也為異步操作，所以
  也就是說(shuō)會(huì)出現(xiàn)對(duì)于n個(gè)分片，讀取數(shù)據(jù)已經(jīng)讀取了p片，并且已經(jīng)有q（**q < p**）片
  已經(jīng)完成上傳完成返回?cái)?shù)據(jù)的情況，但是現(xiàn)在問(wèn)題是，***發(fā)現(xiàn)并沒(méi)有分片上傳完返回?cái)?shù)據(jù)的
  情況出現(xiàn)，都是在n個(gè)分片讀取完成后，才開始統(tǒng)一執(zhí)行分片內(nèi)容上傳操作***
  圖片如下：(由于圖片無(wú)法上傳，我把程序運(yùn)輸出拷貝一下)

{ 
 kind: 'upload',
username: 'moran999',
filepath: 'F:/my_upload_test/NowTest.pdf',
file_id: '-196987878-472217752177633040957425519',
alreadychunks: [],
chunkSize: 1048576,
n: 9 }
第0塊 JSON開始
第0塊 JSON結(jié)束
第0份請(qǐng)求準(zhǔn)備發(fā)出
第0份請(qǐng)求已發(fā)出
第1塊 JSON開始
第1塊 JSON結(jié)束
第1份請(qǐng)求準(zhǔn)備發(fā)出
第1份請(qǐng)求已發(fā)出
第2塊 JSON開始
第2塊 JSON結(jié)束
第2份請(qǐng)求準(zhǔn)備發(fā)出
第2份請(qǐng)求已發(fā)出
第3塊 JSON開始
第3塊 JSON結(jié)束
第3份請(qǐng)求準(zhǔn)備發(fā)出
第3份請(qǐng)求已發(fā)出
第5塊 JSON開始
第5塊 JSON結(jié)束
第5份請(qǐng)求準(zhǔn)備發(fā)出
第5份請(qǐng)求已發(fā)出
第4塊 JSON開始
第4塊 JSON結(jié)束
第4份請(qǐng)求準(zhǔn)備發(fā)出
第4份請(qǐng)求已發(fā)出
第6塊 JSON開始
第6塊 JSON結(jié)束
第6份請(qǐng)求準(zhǔn)備發(fā)出
第6份請(qǐng)求已發(fā)出
第8塊 JSON開始
第8塊 JSON結(jié)束
第8份請(qǐng)求準(zhǔn)備發(fā)出
第8份請(qǐng)求已發(fā)出
第7塊 JSON開始
第7塊 JSON結(jié)束
第7份請(qǐng)求準(zhǔn)備發(fā)出
第7份請(qǐng)求已發(fā)出
第8份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第4份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第6份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第1份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第2份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第0份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第3份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第7份請(qǐng)求返回?cái)?shù)據(jù)
moran999
第5份請(qǐng)求返回?cái)?shù)據(jù)
moran999
[ 'end', 'end', 'end', 'end', 'end', 'end', 'end', 'end', 'end' ]
all done

  可以看到其POST數(shù)據(jù)的發(fā)出并不是和讀流無(wú)關(guān)的，即任何一個(gè)POST都不會(huì)發(fā)出，
  直到到所有的讀流讀取完數(shù)據(jù)，想問(wèn)一下各位碼友是什么原因尼？？因?yàn)檎?  理解下當(dāng)?shù)趇個(gè)讀流讀的時(shí)候，前面已經(jīng)讀取完內(nèi)容的讀流完全可以進(jìn)行post操作
  了啊，但實(shí)際上并沒(méi)有。

  之所以會(huì)問(wèn)這個(gè)問(wèn)題是因?yàn)楫?dāng)我輸入的文件比較大時(shí)，他執(zhí)行到《第12塊 JSON開始時(shí)，
  就內(nèi)存溢出了》，而如果程序是post不用等待所有的讀流讀完時(shí)，當(dāng)有一部分post執(zhí)行完之后，其對(duì)應(yīng)的數(shù)據(jù)就被回收了，釋放相應(yīng)的內(nèi)存，就不會(huì)出現(xiàn)內(nèi)存溢出了。