如何在 Node.js 中'accumulate'原始流？

Question

目前我将所有内容连接成一个字符串，如下所示

var body = '';
res.on('data', function(chunk){
    body += chunk;
});

如何保留和累积原始流，以便将原始字节传递给需要字节而不是字符串的函数？

Answer 1

最好使用 Buffer.concat - 更简单。在节点 v0.8+ 中可用。

var chunks = [];
res.on('data', function(chunk) { chunks.push(chunk); });
res.on('end', function() {
    var body = Buffer.concat(chunks);
    // Do work with body.
});

Answer 2

首先，检查这些函数是否真的需要一次性全部字节。 它们确实应该接受'data'事件，以便您可以按照接收缓冲区的顺序传递缓冲区。

无论如何，这里有一种在不解码的情况下连接所有数据块缓冲区的蛮力方法：

var bodyparts = [];
var bodylength = 0;
res.on('data', function(chunk){
    bodyparts.push(chunk);
    bodylength += chunk.length;
});
res.on('end', function(){
    var body = new Buffer(bodylength);
    var bodyPos=0;
    for (var i=0; i < bodyparts.length; i++) {
        bodyparts[i].copy(body, bodyPos, 0, bodyparts[i].length);
        bodyPos += bodyparts[i].length;
    }
    doStuffWith(body); // yay
});

Answer 3

或者

，你也可以使用node.js库，如bl或concat-stream：

'use strict'
let http = require('http')
let bl = require('bl')
http.get(url, function (response) {
  response.pipe(bl(function (err, data) {
    if (err)
      return console.error(err)
    console.log(data)
  }))
})