1

我正在构建一个简单的 HTTP 服务器，它使用流向客户端提供相当大的文件。我需要同时为多个客户提供服务，我想知道实现这一目标的最简单方法是什么。

我最初的感觉是使用cluster模块并分叉 {num CPUs} 个进程可能是最简单的方法。

var StreamBrake = require('streambrake');
var http = require('http');
var fs = require('fs');

var server = http.createServer(function(req, res) {
  var stream = fs.createReadStream('/data/somefile');
  stream.pipe(new StreamBrake(10240)).pipe(res);
});

server.listen(1234, 10);

编辑：为了澄清，问题是此代码在完成为第一个客户端提供服务之前不会开始为第二个客户端提供服务。

4

1 回答 1

1

在考虑了您的问题后，我对您为什么认为存在问题感到困惑。CreateReadStream 是异步的。这是一个使代码稍微复杂的示例，以证明使用 CreateReadStream 我们确实可以一次为多个连接提供服务。

/*jshint node:true*/
var http = require('http');
var fs = require('fs');
var activeRequests = 0;
var launchFiveRequests = 5;

http.createServer(function (req, res) {

    activeRequests++;

    console.log('Request received');

    var readStream = fs.createReadStream('play.js', {'bufferSize': 1024});

    readStream.setEncoding('utf8');

    readStream.on('data', function (data) {
        console.log(activeRequests);
        res.write(data);
    });

    readStream.on('end', function () {
        res.end();
        console.log('end');
        activeRequests--;
    });

}).listen(8080);

var options = {
    hostname: 'localhost',
    port: 8080,
    path: '/'
};

while(launchTenRequests--) {
    http.get(options, function(res) {
        console.log('response received');
    });
}

提供足够大的文件，您应该会看到所有 5 个请求同时处于活动状态，并且最终都相对同时结束。

于 2013-07-25T17:09:06.750 回答