4

在每秒大约 500-600 个请求的高负载服务器上进行测试。经过数小时的调试，我最终得到了一个简单的 HTTP 服务器。

我注意到当响应体更大时，比如说 60k，我收到了这个错误：

(node) warning: possible EventEmitter memory leak detected. 11 listeners added. Use emitter.setMaxListeners() to increase limit.
Trace
    at Socket.EventEmitter.addListener (events.js:160:15)
    at Socket.Readable.on (_stream_readable.js:679:33)
    at Socket.EventEmitter.once (events.js:179:8)
    at TCP.onread (net.js:527:26)

在那之后 CPU 就疯了

但是，使用完全相同的代码，当响应设置为 10k 的文本时，一切都很顺利。诡异的...

有没有人遇到过这个？？？请求帮助。

这是完整的脚本：

var
cluster = require('cluster'),
numCPUs = require('os').cpus().length;



if(cluster.isMaster){

    for (var i = 0; i < numCPUs; i++) cluster.fork();

    cluster.on("exit", function(worker, code, signal) {
        cluster.fork();
    });

}
else{


    var http = require('http');


    var app = function(req, res){

        res.writeHead(200, {'Content-Type': 'text/html', 'Access-Control-Allow-Origin': '*'});
        res.end( 60k_of_text___or___10k_of_text );

    };


    http.createServer(app).listen(80);


}
4

1 回答 1

0

现在所有字符串都首先转换为 Buffer 实例。这会给垃圾收集器带来沉重的负担，以便在每次请求后进行清理。运行您的应用程序--prof并使用检查v8.log文件，tools/*-tick-processor您可能会看到。

正在做一些工作来纠正这个问题，因此字符串直接写入内存，然后在请求完成时清理。它已针对f5e13ae中的文件系统写入实现，但尚未针对其他情况（实现起来比听起来要困难得多）。

将字符串转换为缓冲区也非常昂贵。特别是对于utf8字符串（默认）。在可能的情况下，绝对将字符串预先缓存为 Buffer 并使用它。这是一个示例脚本：

var http = require('http');
var str = 'a';
for (var i = 0; i < 60000; i++)
  str += 'a';

//str = new Buffer(str, 'binary');

http.createServer(function(req, res) {
  res.writeHead(200, {'Content-Type': 'text/plain',
                      'Access-Control-Allow-Origin': '*'});
  res.end(str);
}).listen(8011, '127.0.0.1');

wrk 'http://127.0.0.1:8011/'以下是针对服务器运行的结果，首先str作为字符串传递，然后作为持久缓冲区传递：

Running 10s test @ http://127.0.0.1:8011/
  2 threads and 10 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency     0.00us    0.00us   0.00us    -nan%
    Req/Sec     0.00      0.00     0.00      -nan%
  8625 requests in 10.00s, 495.01MB read
Requests/sec:    862.44
Transfer/sec:     49.50MB


Running 10s test @ http://127.0.0.1:8011/
  2 threads and 10 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency   624.07us  100.77us   4.45ms   99.17%
    Req/Sec     7.98k   729.82     9.00k    57.59%
  158711 requests in 10.00s, 8.90GB read
Requests/sec:  15871.44
Transfer/sec:      0.89GB

至少，如果您知道您传递的字符串仅包含 ascii 字符，则替换res.end(str)为res.end(new Buffer(str, 'binary')). 这将使用v8::String::WriteOneByte更快的方法。以下是使用该更改的结果：

Running 10s test @ http://127.0.0.1:8011/
  2 threads and 10 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency   827.55us  540.57us   7.03ms   97.38%
    Req/Sec     6.06k     1.11k    8.00k    85.93%
  121425 requests in 10.00s, 6.81GB read
Requests/sec:  12142.62
Transfer/sec:    696.89MB
于 2013-07-03T19:03:37.393 回答