如何全局使用节点http请求

Question

我知道Javascript，但对NodeJS非常陌生。我希望在代码中的任何位置，即server.js之外的位置，重用HTTP请求。请看一看：

server.js

    var http = require('http');
    var mongodb = require('./db');
    var settings = require('./settings');
    var oauth = require('./oauth');

    //start mongodb connection
    mongodb.connect(function(error){
        if (error) console.error(error);
        else {
            //set db as mongodb client
            var db = mongodb.use();
            //start http server
            http.createServer(function(request,response){
                //set POST body
                request.body = '';
                request.on('error',function(error){
                    console.error(error);
                    response.statusCode = 404;
                    response.end();
                }).on('data',function(chunk){
                    request.body += chunk;
                }).on('end',function(){
                    //database and http server ready, start logic
                    //Now I want to "require" a file here, such as test.js and call "request.headers" to work
                });
            }).listen(settings.httpPort,function(){
                console.log('Server listening on '+settings.httpServer+':'+settings.httpPort);
            });
        }
    });

    console.log(request.headers);

Answer 1

如果我没有理解错的话，问题似乎是这样的：您希望在其他模块中访问异步函数的结果（HTTP请求）。但是，节点的require()是同步的；不存在异步require()。对此有几个解决方案，如果您了解JavaScript，这些方案都不会感到陌生。

最简单的解决方案是将server.js模块包装在一个接受回调的函数中。然后,一旦请求可用,就调用回调,如下所示：

// server.js
'use strict';

// ...

module.exports = function(callback) {

  // ...

  http.createServer((req, res) => {
    req.body = '';

    // Call end with error on error
    req.on('error', err => res.end(err));

    // Append chunks to body
    req.on('data', chunk => req.body += chunk);

    // Call callback here
    req.on('end', err => {
      // Call with error as first argument on error
      if (err) callback(err);
      // Call with request as second argument on success
      else callback(null, req);
    });

  }).listen(/*...*/);
  // ...
};

在test.js文件中：

// test.js
'use strict';

const server = require('./server');

// Do something with the request here.
server((err, req) => {
  if (err) console.error(err);
  else console.log(req.headers);
});

这种方法有一个问题。每次想要访问请求时，您的服务器功能都将重新运行一遍。如果您希望运行一次服务器，然后可以访问请求的次数不受限制，该怎么办？

考虑为此使用节点的events模块。在server.js文件中，可以导出EventEmitter实例而不是函数。在该模块中发出适当的事件，然后您可以在任何其他需要访问请求的模块中添加侦听器。server.js文件将如下所示：

// server.js
'use strict';

const EventEmitter = require('events');
const emitter = new EventEmitter();

// ...

http.createServer((req, res) => {
  req.body = '';
  req.on('error', err => res.end(err));
  req.on('data', chunk => req.body += chunk);

  // Emit events here:
  req.on('end', err => {
    // Emit 'error' event on error.
    if (err) emitter.emit('error', err);
    // Emit 'data' event on success.
    else emitter.emit('data', req);
  });
}).listen(/*...*/);

// ...

module.exports = emitter;

在test.js文件中：

// test.js
'use strict';

const server = require('./server');

// Do something on error event.
server.on('error', console.error);

// Do something on data event.
server.on('data', req => {
  console.log(req.headers);
});