将node.js流写入字符串变量

Question

我正在攻击node.js程序,该程序捕获SMTP邮件并对邮件数据进行操作.'smtp-protocol'节点库以流形式提供邮件数据,作为node.js新手,我不知道如何将该流写入字符串变量.我目前使用该行写入stdout:

__PRE__

正如我所说,我需要将此流数据写入字符串变量,然后在流结束后我将使用它.

非常感谢!

Answer 1

希望这比上面的答案(现在有一个断开的链接)更有用.

另请注意,字符串连接不是收集字符串部分的有效方法,但它用于简单(也许您的代码不关心效率)

var string = '';
stream.on('data',function(data){
  string += data.toString();
  console.log('stream data ' + part);
});

stream.on('end',function(){
  console.log('final output ' + string);
});

Answer 2

以上都不适合我.我需要使用Buffer对象:

  const chunks = [];

  readStream.on("data", function (chunk) {
    chunks.push(chunk);
  });

  // Send the buffer or you can put it into a var
  readStream.on("end", function () {
    res.send(Buffer.concat(chunks));
  });

Answer 3

另一种方法是将流转换为promise(请参阅下面的示例)并使用then(或await)将已解析的值分配给变量.

function streamToString (stream) {
  const chunks = []
  return new Promise((resolve, reject) => {
    stream.on('data', chunk => chunks.push(chunk))
    stream.on('error', reject)
    stream.on('end', () => resolve(Buffer.concat(chunks).toString('utf8')))
  })
}

const result = await streamToString(stream)

Answer 4

你怎么看待这件事 ？

// lets have a ReadableStream as a stream variable

const chunks = [];

for await (let chunk of stream) {
    chunks.push(chunk)
}

const buffer  = Buffer.concat(chunks);
const str = buffer.toString("utf-8")

Answer 5

关键是要使用这两个Stream事件:

• 事件:'数据'
• 事件:'结束'

因为data您应该将数据数据收集到Buffer(如果是二进制)或字符串中.

因为end您应该使用完成的缓冲区调用回调,或者如果您可以内联它并使用Promises库返回.

Answer 6

我通常使用这个简单的函数将流转换为字符串:

function streamToString(stream, cb) {
  const chunks = [];
  stream.on('data', (chunk) => {
    chunks.push(chunk.toString());
  });
  stream.on('end', () => {
    cb(chunks.join(''));
  });
}

用法示例:

let stream = fs.createReadStream('./myFile.foo');
streamToString(stream, (data) => {
  console.log(data);  // data is now my string variable
});

Answer 7

还有另一个使用 Promise 的字符串：

function getStream(stream) {
  return new Promise(resolve => {
    const chunks = [];

    # Buffer.from is required if chunk is a String, see comments
    stream.on("data", chunk => chunks.push(Buffer.from(chunk)));
    stream.on("end", () => resolve(Buffer.concat(chunks).toString()));
  });
}

用法：

const stream = fs.createReadStream(__filename);
getStream(stream).then(r=>console.log(r));

.toString()如果需要，删除与二进制数据一起使用的 。

更新：@AndreiLED 正确指出这有字符串问题。我无法获得返回带有我拥有的节点版本的字符串的流，但api指出这是可能的。

Answer 8

使用 Node.js 内置的StreamConsumers.text最简单：

import { text } from 'node:stream/consumers';
import { Readable } from 'node:stream';

const readable = Readable.from('Hello world from consumers!');
const string = await text(readable);

Answer 9

从nodejs 文档中你应该这样做 - 永远记住一个字符串,而不知道编码只是一堆字节:

var readable = getReadableStreamSomehow();
readable.setEncoding('utf8');
readable.on('data', function(chunk) {
  assert.equal(typeof chunk, 'string');
  console.log('got %d characters of string data', chunk.length);
})

Answer 10

Streams没有一个简单的.toString()函数(我理解)也没有.toStringAsync(cb)函数(我不理解).

所以我创建了自己的辅助函数:

var streamToString = function(stream, callback) {
  var str = '';
  stream.on('data', function(chunk) {
    str += chunk;
  });
  stream.on('end', function() {
    callback(str);
  });
}

// how to use:
streamToString(myStream, function(myStr) {
  console.log(myStr);
});

Answer 11

我这样使用比较幸运：

let string = '';
readstream
    .on('data', (buf) => string += buf.toString())
    .on('end', () => console.log(string));

我使用节点v9.11.1，这readstream是回调的响应http.get。

Answer 12

使用流行的（每周下载量超过 500 万次）和轻量级的get-stream库的简单方法：

https://www.npmjs.com/package/get-stream

const fs = require('fs');
const getStream = require('get-stream');

(async () => {
    const stream = fs.createReadStream('unicorn.txt');
    console.log(await getStream(stream)); //output is string
})();