如何使节点同时工作？

Question

Node.js 以并发而闻名，但是，我对如何使其同时工作感到困惑。我非常快速地从 Chrome 中一一启动了两个请求，我预计控制台中的输出应该是：

1. “获取新请求”
2. 在我的第二个请求之后，应立即打印“get a new request”
3. 几秒钟后，“结束新请求”
4. 几秒钟后，“结束新请求”

然而，我看到的是：

1. “获取新请求”
2. 几秒钟后，“结束新请求”
3. “获取新请求”
4. 几秒钟后，结束新请求

这意味着在第一个请求完成之前不会处理第二个请求。下面是我的示例代码，有什么遗漏的吗？

   var http = require("http");
   var url = require("url");

   function start(route) {
    http.createServer(function(request, response) {
      console.log('get a new request');

      // a time consuming loop           
      for (var i=0; i<10000000000; ++i) {
      }

      route(url.parse(request.url).pathname);
      response.writeHead(200, {"Content-Type": "text/plain"});
      response.end();
      console.log('end the new request');
    }).listen(5858);
   }

   function saySomething(something)  {
     console.log(something);
   }

   exports.start = start;
   exports.saySomething = saySomething;

Answer 1

您可能想查看集群：

http://nodejs.org/api/cluster.html#cluster_how_it_works

http://rowanmanning.com/posts/node-cluster-and-express/

Answer 2

节点无法处理这些：

for (var i=0; i<10000000000; ++i) {}

同时。但它同时处理 IO

Answer 3

你不需要做任何事情。

它基于非阻塞 I/O。简而言之，有一个事件循环。运行一组同步代码，一旦完成，下一次迭代就会运行，它会选择下一组同步代码来运行。任何时候运行异步操作（db fetch、setTimeout、读取文件等），都会运行事件循环的下一个滴答声。这样就永远不会有任何代码在等待。

它没有线程。在您的示例中，for 循环位于一个连续的代码块中，因此 js 将运行整个 for 循环，然后才能处理另一个 http 请求。

尝试在 for 循环周围放置一个 setTimeout，以便节点可以切换到下一个事件循环并在您的情况下处理 Web 请求。

Answer 4

这是预期的行为，̶我们称这种̶̶b̶l̶o̶c̶k̶i̶n̶g̶，该溶液用于处理并发请求是使代码̶̶n̶o̶n̶-̶b̶l̶o̶c̶k̶i̶n̶g̶，一旦你打电话̶̶r̶e̶s̶p̶o̶n̶s̶e̶.̶w̶r̶i̶t̶e̶H̶e̶a̶d̶̶代码开始̶b̶l̶o̶c̶k̶i̶n̶g̶̶w̶a̶i̶t̶i̶n̶g̶̶f̶o̶r̶̶̶r̶e̶s̶p̶o̶n̶s̶e̶.̶e̶n̶d̶̶.

编辑 7/8/14： 最近不得不处理这个问题，发现你可以为此使用线程： https://www.npmjs.org/package/webworker-threads

Webworker-threads 为 Node.js 中缺少的 CPU 密集型任务提供异步 API：

var Worker = require('webworker-threads').Worker;
require('http').createServer(function (req,res) {
  var fibo = new Worker(function() {
    function fibo (n) {
      return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1;
    }
    this.onmessage = function (event) {
      postMessage(fibo(event.data));
    }
  });
  fibo.onmessage = function (event) {
    res.end('fib(40) = ' + event.data);
  };
  fibo.postMessage(40);
}).listen(port);

它不会阻塞事件循环，因为对于每个请求，fibo worker 将在单独的后台线程中并行运行。