假设我正在异步读取一个500 MB的文件。这需要一些时间来完成。在异步读取文件时,如何停止/中止读取文件并调用回调函数(即成功中止)?
fs.readFile(filePath, function(err, data) {
//Do work
});
假设我正在异步读取一个500 MB的文件。这需要一些时间来完成。在异步读取文件时,如何停止/中止读取文件并调用回调函数(即成功中止)?
fs.readFile(filePath, function(err, data) {
//Do work
});
fs.readFile
确实异步读取文件,但在整个文件被读取之前,它不会调用您的回调函数,因此您无法使用该方法来实现此目的。相反,我认为您必须使用 fs.createReadStream()
,它会给您一个 stream.Readable
。然后,您可以为此对象实现适当的事件。
function readTheFile(fileName, callback) {
var stream = fs.createReadStream(fileName);
stream.on('readable', function() {}); // Do your read logic
stream.on('error', function(err) {}); // Handle the error
}
fs.read
(与fs.open
一起使用),而不是fs.readFile
。 例如:fs.open(filepath, 'r', function(err, fd) {
var finalize = function(buffer) {
fs.close(fd);
console.log(buffer);
};
if (err) {
finalize();
return;
}
fs.fstat(fd, function(err, stats) {
if (err) {
finalize();
return;
}
var bufferSize = stats.size,
chunkSize = 512,
buffer = new Buffer(bufferSize),
bytesRead = 0;
var inner_read = function() {
if ((bytesRead + chunkSize) > bufferSize) {
chunkSize = (bufferSize - bytesRead);
};
if (chunkSize > 0) {
fs.read(fd, buffer, bytesRead, chunkSize, bytesRead, function(err) {
// YOU CAN DO SOMETHING HERE TO STOP READING
if (err) {
finalize(buffer);
return;
}
bytesRead += chunkSize;
inner_read();
});
} else {
finalize(buffer);
}
}
inner_read();
});
});