Node.js 中的非阻塞代码不起作用

Question

我正在尝试学习如何在 node.js 中创建非阻塞应用程序，但我的代码似乎不起作用。

非阻塞.js

var http = require('http');
var exec = require('child_process').exec;

var userRequests = 0;
http.createServer(function (request, response) {
    userRequests++;

    response.writeHead(200, {'Content-Type': 'text/plain'});

    if( userRequests == 1 ){
        exec("node wait.js", function(){
            response.write('Thanks for waiting!');
            response.end();
        });
    }
    else{
        response.write('Hello!');
        response.end();
    }
}).listen(8080);

console.log('Server start');

等待.js

var startTime = new Date().getTime();
while (new Date().getTime() < startTime + 15000);

Answer 1

根据定义，您的示例涉及阻塞逻辑。它可能不是阻塞的主要进程，但它仍然有点违背了目的。

Node 使用事件循环，就像浏览器中的 JavaScript 一样。网络上有大量可用资源可用于学习 JavaScript 的工作原理。

我建议您看一下这些：

• http://blog.mixu.net/2011/02/01/understanding-the-node-js-event-loop/
• http://code.danyork.com/2011/01/25/node-js-doctors-offices-and-fast-food-restaurants-understanding-event-driven-programming/

关键是节点中的一切都是由某种事件触发的。在您发布的示例代码中，该事件是生成的进程退出。但您不需要启动单独的进程来等待 15 秒。 所有节点的 API 都是事件驱动的，基于时间的事件实际上是 JavaScript 本身的一部分。

以下是您如何编写类似示例的示例：

var http = require('http'),
    userRequests = 0;

http.createServer(function (request, response) {
  userRequests++;

  response.writeHead(200, {'Content-Type': 'text/plain'});

  if( userRequests == 1 ){
    setTimeout(function(){
      response.write('Thanks for waiting!');
      response.end();
    }, 15000);
  }
  else{
    response.write('Hello!');
    response.end();
  }
}).listen(8080, function() {
  console.log('Server start');
});

您在评论中提到了文件。要发送文件，您可以这样做：

var http = require('http'),
    exec = require('child_process').exec,
    userRequests = 0;

http.createServer(function (request, response) {
  userRequests++;

  response.writeHead(200, {'Content-Type': 'text/plain'});

  if( userRequests == 1 ){
    var stream = fs.createReadStream('./somefile.txt');
    stream.on('data', function(data) {
      response.write(data);
    });
    stream.on('end', function() {
      response.end();
    });
  }
  else{
    response.write('Hello!');
    response.end();
  }
}).listen(8080, function() {
  console.log('Server start');
});

一般来说，它实际上更简单，因为您可以这样做：

if( userRequests == 1 ){
  fs.createReadStream('./somefile.txt').pipe(response);
}

Node 有一个“流”的标准定义，它会发出数据和结束事件，以及“管道”方法自动处理绑定我在上面的示例中手动添加的数据和事件处理程序。

正如我所说，首先阅读这些文章。它们非常有用，可以让您朝着正确的方向前进。