3

我创建了一个服务器 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 客户端请求 - 服务器执行另一个请求并附加一个字符串"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）

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

我错了什么？

4

2 回答 2

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......');

另外，值得一读关于nodejitsu的这篇文章

于 2012-09-10T09:14:39.503 回答
0

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

对于这样的事情，我强烈建议使用优秀的请求库（https://github.com/mikeal/request）。

这有一个很棒的 AP​​I，例如：

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.
  }
})
于 2012-09-10T08:44:18.593 回答