为什么不回调

Question

我有以下服务器内部配管工作。

var fs = require('fs'); 
var request = require('request'); 

var crs = fs.createReadStream(__dirname + '/file.txt'); 
var r = request.post('http://0.0.0.0:3000'); 

crs.pipe(r); 

有时可以使用，但大部分时间/output/file.txt都是空的。当我将req.pipe（...）移到mkdir回调之外时，它每次都有效。有谁能解释为什么会发生？

Answer 1

由于mkdir是异步的，请求中的数据是在创建目录时发出的。您需要指示流不发送数据，直到稍后使用pause和resume。

http.createServer(function (req, res) { 
    req.pause(); 
    fs.mkdir(__dirname + '/output', function (err) { 
    req.pipe(fs.createWriteStream(__dirname + '/output/file.txt')); 

    req.resume(); 
    res.end(); 
    }); 
}).listen(3000);