我正在入侵一个Node程序，该程序使用SMTP协议捕获SMTP电子邮件并对邮件数据采取行动。库将邮件数据作为流提供，但我不知道如何将其转换为字符串。
我目前正在用stream.pipe(process. pipe)将其写入标准输出。stdout， {end: false})，但正如我所说的，我需要一个字符串中的流数据，一旦流结束，我就可以使用它。
我如何收集所有的数据从一个Node.js流到一个字符串?
当前回答
希望这比上面的答案更有用:
var string = '';
stream.on('data',function(data){
string += data.toString();
console.log('stream data ' + part);
});
stream.on('end',function(){
console.log('final output ' + string);
});
请注意，字符串连接并不是收集字符串部分的最有效方法，但使用它是为了简单(也许您的代码并不关心效率)。
此外，对于非ascii文本，这段代码可能会产生不可预测的失败(它假设每个字符都适合一个字节)，但也许您也不关心这一点。
其他回答
(这个答案是多年前的，当时它是最好的答案。下面有一个更好的答案。我没有跟上node.js，我不能删除这个答案，因为它被标记为“正确的这个问题”。如果你想按下，你想让我做什么?)
关键是使用可读流的数据和结束事件。听下面这些事件:
stream.on('data', (chunk) => { ... });
stream.on('end', () => { ... });
当您收到数据事件时，将新的数据块添加到为收集数据而创建的Buffer中。
当您接收到结束事件时，如果需要，将完成的Buffer转换为字符串。那就做你该做的事。
简单易用的流行(每周超过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 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
});
使用非常流行的stream-buffers包，你可能已经在你的项目依赖项中有了这个包，这是非常简单的:
// imports
const { WritableStreamBuffer } = require('stream-buffers');
const { promisify } = require('util');
const { createReadStream } = require('fs');
const pipeline = promisify(require('stream').pipeline);
// sample stream
let stream = createReadStream('/etc/hosts');
// pipeline the stream into a buffer, and print the contents when done
let buf = new WritableStreamBuffer();
pipeline(stream, buf).then(() => console.log(buf.getContents().toString()));
希望这比上面的答案更有用:
var string = '';
stream.on('data',function(data){
string += data.toString();
console.log('stream data ' + part);
});
stream.on('end',function(){
console.log('final output ' + string);
});
请注意，字符串连接并不是收集字符串部分的最有效方法，但使用它是为了简单(也许您的代码并不关心效率)。
此外，对于非ascii文本，这段代码可能会产生不可预测的失败(它假设每个字符都适合一个字节)，但也许您也不关心这一点。
