21

在 Node.js 中使用本机http.get()，我试图将 HTTP 响应通过管道传输到我可以绑定data和end事件的流。

我目前正在处理 gzip 数据，使用：

http.get(url, function(res) {
  if (res.headers['content-encoding'] == 'gzip') {
    res.pipe(gunzip);
    gunzip.on('data', dataCallback);
    gunzip.on('end', endCallback);
  }
});

Gunzip 是一个流，这很有效。我尝试创建流（写入流，然后读取流）并通过管道传输响应，但运气不佳。对于非压缩内容，有什么建议可以复制同样的交易吗？

4

2 回答 2

30

HTTP 请求的响应对象是可读流的实例。因此，您将使用事件收集数据，然后在事件触发data时使用它。end

var http = require('http');
var body = '';

http.get(url, function(res) {
  res.on('data', function(chunk) {
    body += chunk;
  });
  res.on('end', function() {
    // all data has been downloaded
  });
});

readable.pipe(dest)如果在上面的示例中是可写流，则基本上会做同样的事情body。

于 2013-10-25T03:21:48.230 回答
7

现在推荐的管道方式是使用管道功能。它应该可以保护您免受内存泄漏。

const { createReadStream} = require('fs');
const { pipeline } = require('stream')
const { createServer, get } = require('http')

const errorHandler = (err) => err && console.log(err.message);

const server = createServer((_, response) => {
  pipeline(createReadStream(__filename), response, errorHandler)
  response.writeHead(200);
}).listen(8080);

get('http://localhost:8080', (response) => {
  pipeline(response, process.stdout, errorHandler);
  response.on('close', () => server.close())
});

另一种具有更多控制权的方法是使用异步迭代器

async function handler(response){
  let body = ''
  for await (const chunk of response) {
    let text = chunk.toString()
    console.log(text)
    body += text
  }
  console.log(body.length)
  server.close()
}

get('http://localhost:8080', (response) => handler(response).catch(console.warn));
于 2020-05-23T14:37:33.617 回答