数据事件在下载数据体的“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。请求文档包含了如何通过处理数据事件接收响应体的示例:

var options = {
  host: 'www.google.com',
  port: 80,
  path: '/upload',
  method: 'POST'
};

var req = http.request(options, function(res) {
  console.log('STATUS: ' + res.statusCode);
  console.log('HEADERS: ' + JSON.stringify(res.headers));
  res.setEncoding('utf8');
  res.on('data', function (chunk) {
    console.log('BODY: ' + chunk);
  });
});

req.on('error', function(e) {
  console.log('problem with request: ' + e.message);
});

// write data to request body
req.write('data\n');
req.write('data\n');
req.end();

http。Get做的事情与http相同。请求，除非它自动调用req.end()。

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

http.get(options, function(res) {
  console.log("Got response: " + res.statusCode);

  res.on("data", function(chunk) {
    console.log("BODY: " + chunk);
  });
}).on('error', function(e) {
  console.log("Got error: " + e.message);
});

如果你想用。get，你可以这样做

http.get(url, function(res){
    res.setEncoding('utf8');
    res.on('data', function(chunk){
        console.log(chunk);
    });

});

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

相反，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);

我还想添加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);
}); 

编辑:6年后回复自己

await关键字是从HTTP请求获得响应的最佳方式，避免了回调和.then()

您还需要使用返回promise的HTTP客户机。get()仍然返回一个Request对象，因此这将不起作用。

fetch是一个低级客户端，从npm和nodeJS 17起都可以使用。 superagent是一个成熟的HTTP客户端，具有更合理的默认值，包括更简单的查询字符串编码，正确使用mime类型，默认为JSON，以及其他常见的HTTP客户端特性。 Axios也很受欢迎，具有与超级代理类似的优势

await将等待Promise有一个值—在本例中是一个HTTP响应!

const superagent = require('superagent');

(async function(){
  const response = await superagent.get('https://www.google.com')
  console.log(response.text)
})();

使用await，一旦superagent.get()返回的promise有值，控制就会简单地传递到下一行。