如何在 Node.js 中关闭一个可读流？
var input = fs.createReadStream('lines.txt');
input.on('data', function(data) {
// after closing the stream, this will not
// be called again
if (gotFirstLine) {
// close this stream and continue the
// instructions from this if
console.log("Closed.");
}
});
这将比以下内容更好：
input.on('data', function(data) {
if (isEnded) { return; }
if (gotFirstLine) {
isEnded = true;
console.log("Closed.");
}
});
但这并不能阻止阅读过程...
编辑：好消息！从Node.js 8.0.0开始，readable.destroy已正式发布：https://nodejs.org/api/stream.html#stream_readable_destroy_error
var fs = require("fs");
var readStream = fs.createReadStream("lines.txt");
readStream
.on("data", function (chunk) {
console.log(chunk);
readStream.destroy();
})
.on("end", function () {
// This may not been called since we are destroying the stream
// the first time "data" event is received
console.log("All the data in the file has been read");
})
.on("close", function (err) {
console.log("Stream has been destroyed and file has been closed");
});
ReadStream.destroy没有文档记录（Node.js v0.12.2），但是你可以查看GitHub上的源代码（2012年10月5日提交）。
destroy函数在内部将ReadStream实例标记为已销毁，并调用close函数释放文件。destroy（以及close）函数仅适用于fs.ReadStream。它们不是通用的stream.readable“接口”的一部分。error事件。除此之外，我唯一担心的是事件处理程序泄漏。再次强调，我不能百分之百确定，但根据2010年Isaacs的圣经所言，当发射器被垃圾回收时，处理程序会被修剪：https://groups.google.com/d/msg/nodejs/pXbJVo0NtaY/BxUmF_jp9LkJ - mikermcneilon('data') 只会触发一次，因此不会有 .close()，只需提醒其他人即可。 - bytefishthis.destroy()，除非你使用箭头函数。词法作用域中的 this，我恨你 :D - Moha the almighty camelpipe()，我必须将 on("close") 移动到 .pipe() 和 on("data") 之前，否则无法捕获 "close" 事件。 - Maxim Mazurok调用 input.close()。虽然没有在文档中记录，但是https://github.com/joyent/node/blob/cfcb1de130867197cbc9c6012b7e84e08e53d032/lib/fs.js#L1597-L1620清楚地完成了这项工作 :) 它实际上执行与您的isEnded类似的操作。
编辑2015年4月19日：根据下面的评论澄清和更新：
lib/fs.js后，它仍然有效超过1.5年。destroy()更可取的评论。fs ReadStreams，而不适用于通用的Readable至于通用解决方案：根据我的理解文档以及快速查看_stream_readable.js，似乎没有这样的解决方案。
我的建议是将可读流放置在暂停模式下，至少可以防止上游数据源中的进一步处理。不要忘记unpipe()并删除所有data事件侦听器，以使pause()实际上暂停，如文档所述。
destroy。至少如果将 autoClose 设置为 true，就会这样调用。通过查看源代码（今天），差异很小（destroy 调用 close），但这在未来可能会改变。 - Marcelo Dinizclose() 方法，是否有其他解决方案？我的数据交换总是不完整... - CodeManXclose()，并提供一种类特定的方法来实现这一点（就像在fs中一样，以及其他实现Readable的类中可能也是如此）。 - Nitzan Shaked今天，在Node 10中，readableStream.destroy()是关闭可读流的官方方法。
请参见https://nodejs.org/api/stream.html#stream_readable_destroy_error
在版本4.*.*中，将 null 值推入流中将触发 EOF 信号。
来自 Node.js 文档
如果传递的是除 null 以外的值，则 push() 方法会向队列中添加一块数据，以供后续的流处理器消耗。如果传递的是 null，则表示流结束（EOF），此后不能再写入任何数据。
在此页面尝试了许多其他选项后，这对我有效。
unpipe()调用为我的管道实现.destroy()。 而在所有这些复杂性之后，它并不在所有情况下都有效。destroy() api用于Readable流。这个destroy模块的作用是确保流被销毁，处理不同的API和Node.js的错误。现在它是最好的选择之一。
NB. 从Node 10开始，您可以使用.destroy方法而无需进一步依赖。
这是一个老问题，但我也在寻找答案，并为我的实现找到了最好的答案。因为end和close事件都会被触发，所以我认为这是最干净的解决方案。
在编写时稳定版本的node 4.4.*中，以下代码将解决问题:
var input = fs.createReadStream('lines.txt');
input.on('data', function(data) {
if (gotFirstLine) {
this.end(); // Simple isn't it?
console.log("Closed.");
}
});
yourstream.resume()来清空并关闭流，这将倒出 (dump) 流上的所有内容并最终关闭它。var readable = getReadableStreamSomehow();
readable.resume();
readable.on('end', () => {
console.log('got to the end, but did not read anything');
});
'data'事件监听器，但我们让它检查一个布尔值if (!ignoring) { ... }，所以当我们排空流时它不会处理数据。ignoring = true; readable.resume(); - joeytwiddlefunction closeReadStream(stream) {
if (!stream) return;
if (stream.close) stream.close();
else if (stream.destroy) stream.destroy();
}
writeStream.end() 是关闭 writeStream 的常用方法...
.end。 - g00dnatur3如果要在某个调用后停止回调执行，您需要使用带有特定进程ID的 process.kill。
const csv = require('csv-parser');
const fs = require('fs');
const filepath = "./demo.csv"
let readStream = fs.createReadStream(filepath, {
autoClose: true,
});
let MAX_LINE = 0;
readStream.on('error', (e) => {
console.log(e);
console.log("error");
})
.pipe(csv())
.on('data', (row) => {
if (MAX_LINE == 2) {
process.kill(process.pid, 'SIGTERM')
}
// console.log("not 2");
MAX_LINE++
console.log(row);
})
.on('end', () => {
// handle end of CSV
console.log("read done");
}).on("close", function () {
console.log("closed");
})
stream.destroy()方法。 - joeytwiddlereadable.push(null) && readable.destroy();吗？ - Alexander Mills