Node.js怎么实现逐行读取和写入文件内容

在Node.js中，处理文件是一个常见的任务。无论是读取配置文件、处理日志文件，还是生成报告，逐行读取和写入文件内容都是非常实用的操作。本文将详细介绍如何在Node.js中实现逐行读取和写入文件内容，并提供相应的代码示例。

1. 逐行读取文件内容

在Node.js中，逐行读取文件内容可以通过多种方式实现。以下是几种常见的方法：

1.1 使用readline模块

readline是Node.js内置的一个模块，专门用于逐行读取文件内容。它提供了一个简单的接口来处理输入流，并且非常适合处理大文件，因为它不会一次性将整个文件加载到内存中。

const fs = require('fs');
const readline = require('readline');

const filePath = 'example.txt';

const rl = readline.createInterface({
    input: fs.createReadStream(filePath),
    output: process.stdout,
    terminal: false
});

rl.on('line', (line) => {
    console.log(`Line: ${line}`);
});

rl.on('close', () => {
    console.log('File reading completed.');
});

在这个例子中，我们使用readline.createInterface创建了一个接口，并通过fs.createReadStream将文件内容作为输入流传递给它。rl.on('line', callback)事件监听器会在每一行被读取时触发，rl.on('close', callback)事件监听器会在文件读取完成时触发。

1.2 使用fs.readFile和split方法

如果你处理的文件较小，并且可以一次性将文件内容加载到内存中，那么可以使用fs.readFile方法读取整个文件内容，然后通过split方法将内容按行分割。

const fs = require('fs');

const filePath = 'example.txt';

fs.readFile(filePath, 'utf8', (err, data) => {
    if (err) {
        console.error('Error reading file:', err);
        return;
    }

    const lines = data.split('\n');
    lines.forEach((line, index) => {
        console.log(`Line ${index + 1}: ${line}`);
    });
});

在这个例子中，我们使用fs.readFile读取整个文件内容，然后通过split('\n')将内容按行分割成一个数组。最后，我们遍历数组并逐行处理。

1.3 使用fs.createReadStream和readline模块

如果你需要处理大文件，并且希望逐行读取文件内容，但又不想使用readline模块，那么可以结合fs.createReadStream和自定义的缓冲区来实现。

const fs = require('fs');

const filePath = 'example.txt';
const readStream = fs.createReadStream(filePath, { encoding: 'utf8' });

let remaining = '';

readStream.on('data', (chunk) => {
    remaining += chunk;
    let index = remaining.indexOf('\n');
    while (index !== -1) {
        const line = remaining.substring(0, index);
        console.log(`Line: ${line}`);
        remaining = remaining.substring(index + 1);
        index = remaining.indexOf('\n');
    }
});

readStream.on('end', () => {
    if (remaining.length > 0) {
        console.log(`Line: ${remaining}`);
    }
    console.log('File reading completed.');
});

在这个例子中，我们使用fs.createReadStream创建一个可读流，并通过data事件监听器逐块读取文件内容。我们将读取到的内容存储在remaining变量中，并通过indexOf('\n')查找换行符的位置。每次找到换行符时，我们提取出一行内容并处理它。最后，在end事件中处理剩余的内容。

2. 逐行写入文件内容

在Node.js中，逐行写入文件内容通常使用fs.appendFile或fs.createWriteStream方法。以下是几种常见的方法：

2.1 使用fs.appendFile方法

fs.appendFile方法可以将内容追加到文件的末尾。如果你需要逐行写入文件内容，可以在每次写入时调用fs.appendFile。

const fs = require('fs');

const filePath = 'output.txt';
const lines = ['Line 1', 'Line 2', 'Line 3'];

lines.forEach((line) => {
    fs.appendFile(filePath, line + '\n', (err) => {
        if (err) {
            console.error('Error writing to file:', err);
        }
    });
});

在这个例子中，我们使用fs.appendFile方法将每一行内容追加到文件中。需要注意的是，fs.appendFile是异步操作，因此在处理大量数据时可能会影响性能。

2.2 使用fs.createWriteStream方法

如果你需要逐行写入大量数据，使用fs.createWriteStream方法会更加高效。fs.createWriteStream创建一个可写流，允许你逐块写入数据。

const fs = require('fs');

const filePath = 'output.txt';
const lines = ['Line 1', 'Line 2', 'Line 3'];

const writeStream = fs.createWriteStream(filePath, { flags: 'a' });

lines.forEach((line) => {
    writeStream.write(line + '\n');
});

writeStream.end();

在这个例子中，我们使用fs.createWriteStream创建一个可写流，并通过write方法逐行写入数据。最后，我们调用writeStream.end()来关闭流。

2.3 使用readline模块和fs.createWriteStream方法

如果你需要从一个文件中逐行读取内容，并将处理后的内容逐行写入另一个文件，可以结合readline模块和fs.createWriteStream方法。

const fs = require('fs');
const readline = require('readline');

const inputFilePath = 'input.txt';
const outputFilePath = 'output.txt';

const rl = readline.createInterface({
    input: fs.createReadStream(inputFilePath),
    output: process.stdout,
    terminal: false
});

const writeStream = fs.createWriteStream(outputFilePath, { flags: 'a' });

rl.on('line', (line) => {
    const processedLine = line.toUpperCase(); // 示例处理：将每一行转换为大写
    writeStream.write(processedLine + '\n');
});

rl.on('close', () => {
    writeStream.end();
    console.log('File processing completed.');
});

在这个例子中，我们使用readline模块逐行读取输入文件的内容，并通过fs.createWriteStream将处理后的内容逐行写入输出文件。

3. 总结

在Node.js中，逐行读取和写入文件内容是非常常见的操作。通过使用readline模块、fs.readFile、fs.createReadStream、fs.appendFile和fs.createWriteStream等方法，你可以轻松地实现这些功能。根据具体的需求和文件大小，选择合适的方法可以提高代码的效率和可维护性。

无论是处理大文件还是小文件，Node.js都提供了灵活的工具来满足你的需求。希望本文的介绍和示例代码能够帮助你在实际项目中更好地处理文件内容。