我正在http://nodejs.org/docs/v0.4.0/api/http.html#http.request上阅读文档,但由于某种原因,我似乎无法在返回的已完成响应对象上找到body/data属性。

> var res = http.get({host:'www.somesite.com', path:'/'})

> res.finished
true

> res._hasBody
true

它完成了(http。Get为您完成这一工作),因此它应该有某种内容。但没有尸体,没有数据,我无法从中读取信息。尸体藏在哪里?


当前回答

我还想添加http。由http.get()返回的ClientResponse有一个结束事件,所以这里是我接收正文响应的另一种方式:

var options = {
  host: 'www.google.com',
  port: 80,
  path: '/index.html'
};

http.get(options, function(res) {
  var body = '';
  res.on('data', function(chunk) {
    body += chunk;
  });
  res.on('end', function() {
    console.log(body);
  });
}).on('error', function(e) {
  console.log("Got error: " + e.message);
}); 

其他回答

针模也不错,这里有一个使用针模的例子

var needle = require('needle');

needle.get('http://www.google.com', function(error, response) {
  if (!error && response.statusCode == 200)
    console.log(response.body);
});

你需要为请求添加一个监听器,因为node.js是异步工作的:

request.on('response', function (response) {
  response.on('data', function (chunk) {
    console.log('BODY: ' + chunk);
 });
});

数据事件在下载数据体的“chunk”时触发多次,在下载完所有数据块时触发结束事件。

现在Node支持Promise,我创建了一个简单的包装器,通过Promise返回连接的块:

const httpGet = url => {
  return new Promise((resolve, reject) => {
    http.get(url, res => {
      res.setEncoding('utf8');
      let body = ''; 
      res.on('data', chunk => body += chunk);
      res.on('end', () => resolve(body));
    }).on('error', reject);
  });
};

你可以从一个异步函数调用它:

const body = await httpGet('http://www.somesite.com');

你不能从http.get()的返回值中获得响应体。

get()不返回响应对象。它返回请求对象(http.clientRequest)。因此,没有任何方法可以从http.get()的返回值获取响应体。

我知道这是一个老问题,但阅读您链接到的文档表明,即使在您发布它时也是如此。

主体并不是作为响应的一部分完全存储的,这是因为主体可以包含非常大量的数据,如果它被存储在响应对象上,程序的内存将很快被消耗。

相反,Node.js使用一种叫做流的机制。这种机制允许只保留一小部分数据,并允许程序员决定是在内存中完全使用它,还是将数据的每个部分作为其流使用。

有多种方法可以将数据完全消耗到内存中,因为HTTP Response是可读流,所以res对象上所有可读方法都可用

监听“data”事件并保存传递给回调的数据块 Const chunks = [] Res.on ("data", (chunk) => { chunks.push(块) }); Res.on ("end", () => { const body = Buffer.concat(chunk); });

当使用这种方法时,您不会干扰流的行为,而只是收集应用程序可用的数据。

使用"readble"事件并调用res.read() Const chunks = []; Res.on ("readable", () => { 让块; While (null !== (chunk = res.read())){ chunks.push(块) } }); Res.on ("end", () => { const body = Buffer.concat(chunk); });

当采用这种方法时,你完全负责流的流,直到res.read被调用,才会有更多的数据被传递到流中。

使用异步迭代器 Const chunks = []; For await (const chunk of readable) { chunks.push(块); } const body = Buffer.concat(chunk);

这种方法类似于“数据”事件方法。它将简化范围,并允许整个过程发生在相同的范围内。

虽然如上所述,完全使用响应中的数据是可能的,但如果确实有必要这样做,始终要记住这一点。在许多情况下,可以简单地将数据定向到目的地,而不将其完全保存到内存中。

Node.js读取流,包括HTTP响应,有一个内置的方法来做这件事,这个方法叫做pipe。用法很简单,readStream.pipe(writeStream);。

例如:

如果数据的最终目的地是文件系统,则可以简单地打开到文件系统的写流,然后将数据通过管道传输到其目的地。

const { createWriteStream } = require("fs");
const writeStream = createWriteStream("someFile");
res.pipe(writeStream);