爲什麼我的服務器永遠不會收到Node.js中循環內部發出的任何請求？

Question

我的代碼工作循環的罰款外：

var localFolder = '/home/transcripts', 
    apiHost = 'https://someserver' 
    apiCall = '/path', 
    sharedSecret = 'secret'; 
/* includes */ 

var sys = require('sys'), 
    fs = require('fs'), 
    exec = require('child_process').exec, 
    querystring = require('querystring'), 
    crypto = require('crypto') 
    request = require('request'); 
var file = "index_07_03_2013_1209576.csv"; 

console.log('Pushing CSV to API: ' + file); 
var r = request.post(
    apiHost + '/' + apiCall, 
    { form: { 
      'filename': file, 
      'accessToken': crypto.createHash('md5').update(file + sharedSecret).digest('hex') 
     } 
    }, 
    function (error, response, body) { 
     if (!error && response.statusCode == 200) { 
      console.log(body); 
     } 
     console.log(error); 
     console.log(response); 
    } 
); 

file = "index_07_02_2013_1548773.csv"; 

console.log('Pushing CSV to API: ' + file); 
var r = request.post(
    apiHost + '/' + apiCall, 
    { form: { 
      'filename': file, 
      'accessToken': crypto.createHash('md5').update(file + sharedSecret).digest('hex') 
     } 
    }, 
    function (error, response, body) { 
     if (!error && response.statusCode == 200) { 
      console.log(body); 
     } 
     console.log(error); 
     console.log(response); 
    } 
); 

file = "index_07_02_2013_1548773.csv"; 

console.log('Pushing CSV to API: ' + file); 
var r = request.post(
    apiHost + '/' + apiCall, 
    { form: { 
      'filename': file, 
      'accessToken': crypto.createHash('md5').update(file + sharedSecret).digest('hex') 
     } 
    }, 
    function (error, response, body) { 
     if (!error && response.statusCode == 200) { 
      console.log(body); 
     } 
     console.log(error); 
     console.log(response); 
    } 
); 

然而，當我嘗試將其移動到一個foreach循環，沒有請求過由服務器接收。我確實看到輸出表明CSV文件正在被推送到API，但請求似乎永遠不會觸及服務器。下面是該代碼：

#!/usr/local/bin/node 

/* environment vars */ 

var localFolder = '/home/transcripts', 
    apiHost = 'https://someserver' 
    apiCall = '/path', 
    sharedSecret = 'secret'; 

/* includes */ 

var sys = require('sys'), 
    fs = require('fs'), 
    exec = require('child_process').exec, 
    querystring = require('querystring'), 
    crypto = require('crypto') 
    request = require('request'); 

var counter = 0; 

fs.readdir(localFolder, function(err, files) { 

    files.forEach(function(file) { 

     if (file.substr(-3, 3) == 'csv') { 


      console.log('Pushing CSV to API: ' + file); 
      request.post(
       apiHost + '/' + apiCall, 
       { form: { 
         'filename': file, 
         'accessToken': crypto.createHash('md5').update(file + sharedSecret).digest('hex') 
        } 
       }, 
       function (error, response, body) { 
        if (!error && response.statusCode == 200) { 
         console.log(body); 
        } 
        console.log(error); 
        console.log(response); 
       } 
      ); 
      console.log(request); 

     } 

     counter++; 

    }); 

    if (counter >= files.length) { 

     process.exit(0); 

    } 

}); 

任何人有任何想法的問題可能是什麼？

Answer 1

我猜測循環版本會中斷，因爲只要counter >= files.length的計算結果爲true，就運行process.exit(0)。

它實際上打破了預期功能的原因可能是因爲你非常快速地分離了request調用（這是異步的），一旦你完成了這些，你就退出程序。我的猜測是，由於您並未實際等待請求完成（即回調完成時），因此您會提前退出程序。

你需要的基本上是一個等待組，並且在所有回調完成之前確保不要退出程序。

嘗試這樣：

// imports, etc 
// ... 

var counter = 0; 

function done() { 
    counter--; 

    if(counter === 0) { 
    process.exit(0); 
    } 
} 

var callback = function (error, response, body) { 
    if (!error && response.statusCode == 200) { 
    console.log(body); 
    } 
    console.log(error); 
    console.log(response); 

    done(); 
} 


fs.readdir(localFolder, function(err, files) { 
    counter = files.length; 

    files.forEach(function(file) { 
    if (file.substr(-3, 3) == 'csv') { 
     console.log('Pushing CSV to API: ' + file); 
     var data = { 
     form: { 
      'filename': file, 
      'accessToken': crypto.createHash('md5').update(file + sharedSecret).digest('hex') 
     } 
     } 

     request.post(apiHost + '/' + apiCall, , data, callback); 
    } 
    } 
);