使用 Node.js 读取文件
在 Node.js 中读取文件最简单的方法是使用 fs.readFile()
方法,传递文件路径、编码和一个回调函数,该函数将使用文件数据(和错误)调用
const fs = require('node:fs');
fs.readFile('/Users/joe/test.txt', 'utf8', (err, data) => {
if (err) {
console.error(err);
return;
}
console.log(data);
});
或者,您可以使用同步版本 fs.readFileSync()
const fs = require('node:fs');
try {
const data = fs.readFileSync('/Users/joe/test.txt', 'utf8');
console.log(data);
} catch (err) {
console.error(err);
}
您也可以使用 fs/promises
模块提供的基于 Promise 的 fsPromises.readFile()
方法
const fs = require('node:fs/promises');
async function example() {
try {
const data = await fs.readFile('/Users/joe/test.txt', { encoding: 'utf8' });
console.log(data);
} catch (err) {
console.error(err);
}
}
example();
fs.readFile()
、fs.readFileSync()
和 fsPromises.readFile()
这三个方法都会在返回数据之前将文件的完整内容读取到内存中。
这意味着大文件会对您的内存消耗和程序执行速度产生重大影响。
在这种情况下,更好的选择是使用流读取文件内容。
import fs from 'fs';
import path from 'path';
import { pipeline } from 'node:stream/promises';
const fileUrl = 'https://www.gutenberg.org/files/2701/2701-0.txt';
const outputFilePath = path.join(process.cwd(), 'moby.md');
async function downloadFile(url, outputPath) {
const response = await fetch(url);
if (!response.ok || !response.body) {
throw new Error(`Failed to fetch ${url}. Status: ${response.status}`);
}
const fileStream = fs.createWriteStream(outputPath);
console.log(`Downloading file from ${url} to ${outputPath}`);
await pipeline(response.body, fileStream);
console.log('File downloaded successfully');
}
async function readFile(filePath) {
const readStream = fs.createReadStream(filePath, { encoding: 'utf8' });
try {
for await (const chunk of readStream) {
console.log('--- File chunk start ---');
console.log(chunk);
console.log('--- File chunk end ---');
}
console.log('Finished reading the file.');
} catch (error) {
console.error(`Error reading file: ${error.message}`);
}
}
try {
await downloadFile(fileUrl, outputFilePath);
await readFile(outputFilePath);
} catch (error) {
console.error(`Error: ${error.message}`);
}