我正在入侵一个Node程序，该程序使用SMTP协议捕获SMTP电子邮件并对邮件数据采取行动。库将邮件数据作为流提供，但我不知道如何将其转换为字符串。
我目前正在用stream.pipe(process. pipe)将其写入标准输出。stdout， {end: false})，但正如我所说的，我需要一个字符串中的流数据，一旦流结束，我就可以使用它。
我如何收集所有的数据从一个Node.js流到一个字符串?
当前回答
所有列出的答案似乎都以流动模式打开可读流，这不是NodeJS的默认模式，并且可能有局限性，因为它缺乏NodeJS在暂停可读流模式中提供的反压力支持。 这里是一个使用Just Buffers、本机流和本机流转换并支持对象模式的实现
import {Transform} from 'stream';
let buffer =null;
function objectifyStream() {
return new Transform({
objectMode: true,
transform: function(chunk, encoding, next) {
if (!buffer) {
buffer = Buffer.from([...chunk]);
} else {
buffer = Buffer.from([...buffer, ...chunk]);
}
next(null, buffer);
}
});
}
process.stdin.pipe(objectifyStream()).process.stdout
其他回答
最简洁的解决方案可能是使用“string-stream”包，它将流转换为带有承诺的字符串。
const streamString = require('stream-string')
streamString(myStream).then(string_variable => {
// myStream was converted to a string, and that string is stored in string_variable
console.log(string_variable)
}).catch(err => {
// myStream emitted an error event (err), so the promise from stream-string was rejected
throw err
})
简单易用的流行(每周超过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
})();
还有一个是使用承诺的字符串:
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指出这是可能的。
(这个答案是多年前的，当时它是最好的答案。下面有一个更好的答案。我没有跟上node.js，我不能删除这个答案，因为它被标记为“正确的这个问题”。如果你想按下，你想让我做什么?)
关键是使用可读流的数据和结束事件。听下面这些事件:
stream.on('data', (chunk) => { ... });
stream.on('end', () => { ... });
当您收到数据事件时，将新的数据块添加到为收集数据而创建的Buffer中。
当您接收到结束事件时，如果需要，将完成的Buffer转换为字符串。那就做你该做的事。
以上这些方法对我都没用。我需要使用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));
});
