在 NodeJs 服务器中发出请求？

Question

我已经创建了一个服务器 http 监听器：

var http = require('http');
http.createServer(function (req, res)
{
        res.writeHead(200,
        {
                'Content-Type': 'text/plain'
        });
        res.write('aaa');
        res.end();
}).listen(1337, '127.0.0.1');
console.log('waiting......');

它正在查找并响应。

现在，我想要 - foreach 客户端请求 - 服务器执行 another 请求并 追加 一个字符串 "XXX"：

所以我写了：

var http = require('http');
var options = {
        host: 'www.random.org',
        path: '/integers/?num=1&min=1&max=10&col=1&base=10&format=plain&rnd=new'
};
http.createServer(function (req, res)
{
        res.writeHead(200,
        {
                'Content-Type': 'text/plain'
        });
        res.write('aaa');

        http.request(options, function (r)
        {
                r.on('data', function (chunk)
                {
                        res.write('XXX');
                });
                r.on('end', function ()
                {
                        console.log(str);
                });
                res.end();
        });

        res.end();
}).listen(1337, '127.0.0.1');
console.log('waiting......');

所以现在 foreach 请求应该写成：aaaXXX (aaa+XXX)

但它不起作用。它仍然产生相同的输出。

我哪里错了？

Answer 1

试试这个：

var http = require('http');
var options = {
        host: 'www.random.org',
        path: '/integers/?num=1&min=1&max=10&col=1&base=10&format=plain&rnd=new'
};
http.createServer(function (req, res)
{
        res.writeHead(200,
        {
                'Content-Type': 'text/plain'
        });
        res.write('aaa');

        var httpreq = http.request(options, function (r)
        {
            r.setEncoding('utf8');
            r.on('data', function (chunk)
            {
                res.write(' - '+chunk+' - ');
            });
            r.on('end', function (str)
            {
                res.end();
            });

        });

        httpreq.end();

}).listen(1337, '127.0.0.1');
console.log('waiting......');

另外，值得一读this article on nodejitsu

Answer 2

你打电话给res.end() 太早了……你只想在所有东西都写好后做事（例如，当 r.on('end') 被调用时）。

对于这样的事情，我会强烈推荐使用优秀的请求库 (https://github.com/mikeal/request)。

这有一个很棒的API，例如：

var request = require('request');
request('http://www.google.com', function (error, response, body) {
  if (!error && response.statusCode == 200) {
    console.log(body) // Print the google web page.
  }
})