Node.js无法处理多个TCP消息

这是一个简单的TCP-Server压力测试。只要我们每个客户仅发送一条消息,一切都会按预期进行。但是,当每个客户端发送两条消息时,服务器突然停止,没有异常或错误。那么,这是错误还是功能?

var net = require("net");
var async = require("async");
var cluster = require("cluster");

// `ulimit -n` tells us that we can open max. 1024 files per process.
//  Creating a socket means opening a file so we are limited.
var CLIENTS = 1000;

// Here is the weird part:
// - sending one message per client works fine
// - sending multiple message per client sucks
var MESSAGES = 2;

var TOTAL = CLIENTS * MESSAGES;
var PORT = 1234;
var HOST = "127.0.0.1";

if (cluster.isMaster) {
  var count = 0;
  var start = new Date;

  var server = net.createServer(function(socket) {
    socket.on("data", function(data) {
      var t;
      count++;
      console.log("server received " + count + " messages");
      socket.write(data, function(err) { if (err) console.error(err); });
      if (count === TOTAL) {
        t = (new Date) - start;
        console.log("server received and sent " + count + " messages within " + t + "ms");
      }
    });
  });

  server.listen(PORT, HOST, function() { cluster.fork(); });

} else {

  var run = function(i) {
    var c = net.connect({ port: PORT, host: HOST }, function() {
      var tasks = (function() {
        var results = [];
        for (var x = 1; x <= MESSAGES; ++x) {
          results.push((function(x) {
            return function(next) { c.write("Hello server!", next); };
          })(x));
        }
        return results;
      })();

      async.series(tasks, function(err) {
        if (err) { console.error(err); }
      });

    });
  };
  for (var i = 1; i <= CLIENTS; ++i) { run(i); }
}

在Linux 3.11,Node.js 0.10.21上进行了测试

罗伯特克莱普

您假设.write从客户端调用两次会在data服务器上触发两次事件,而不考虑可能会进行的缓冲(这些缓冲会合并多次写操作)。

当调用回调to时.write,并不意味着它实际发送的消息,而是意味着该消息被放入某个内核缓冲区中(当发送到服务器时,它可能包含多个消息)。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章