面试题：Node.js 可写流 Writable 在高并发场景下的性能优化与资源管理

可写流的配置优化

高水位线（highWaterMark）：
- 优化思路：可写流的 highWaterMark 定义了内部缓冲区的大小。默认情况下，highWaterMark 是 16384 字节（16KB）。在高并发写入大量数据时，可以适当调整这个值。如果写入目标（如文件系统或数据库连接）处理速度较慢，可以降低 highWaterMark，避免缓冲区过大占用过多内存。但如果目标处理速度快，适当提高 highWaterMark 可以减少流暂停和恢复的次数，提高写入效率。
- 示例代码：

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt', {
    highWaterMark: 8192 // 设置为8KB
});

自动刷新（autoFlush）：
- 优化思路：autoFlush 默认为 true，意味着只要缓冲区有数据就会尝试写入目标。在高并发场景下，如果写入目标处理能力有限，频繁的写入尝试可能会导致性能问题。可以将 autoFlush 设置为 false，然后手动控制缓冲区的刷新，在缓冲区满或者特定条件下进行写入，这样可以减少不必要的写入操作，提高效率。
- 示例代码：

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt', {
    autoFlush: false
});
let data = 'a'.repeat(1024 * 1024); // 1MB 数据
writeStream.write(data);
writeStream.cork(); // 阻止数据自动写入
// 某些条件满足后
writeStream.uncork(); // 一次性将缓冲区数据写入

数据处理逻辑优化

数据分块处理：
- 优化思路：不要一次性将大量数据写入可写流，而是将数据分成小块进行写入。这样可以避免在内存中一次性存储大量数据，同时也能更好地控制写入节奏，适应目标的处理能力。
- 示例代码：

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt');
const largeData = 'a'.repeat(1024 * 1024 * 10); // 10MB 数据
const chunkSize = 1024 * 1024; // 1MB 分块
for (let i = 0; i < largeData.length; i += chunkSize) {
    let chunk = largeData.substring(i, i + chunkSize);
    writeStream.write(chunk);
}
writeStream.end();

异步处理与背压（Backpressure）：
- 优化思路：当可写流的缓冲区已满，继续写入数据可能会导致数据丢失或性能问题。通过处理背压，可以在缓冲区满时暂停写入，等待可写流准备好接收更多数据时再恢复写入。在 Node.js 中，可以通过监听 drain 事件来处理背压。
- 示例代码：

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt');
let data = 'a'.repeat(1024 * 1024 * 10); // 10MB 数据
let offset = 0;
const writeChunk = () => {
    let chunk = data.substring(offset, offset + 1024 * 1024); // 1MB 分块
    let writeResult = writeStream.write(chunk);
    offset += chunk.length;
    if (offset < data.length &&!writeResult) {
        writeStream.once('drain', writeChunk);
    } else if (offset >= data.length) {
        writeStream.end();
    }
};
writeChunk();

内存管理优化

及时释放内存：
- 优化思路：在数据成功写入目标后，及时释放相关的内存。例如，如果使用数组或字符串存储待写入数据，在写入完成后将其设置为 null，让垃圾回收机制回收内存。
- 示例代码：

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt');
let data = 'a'.repeat(1024 * 1024); // 1MB 数据
writeStream.write(data);
writeStream.on('finish', () => {
    data = null; // 释放内存
});
writeStream.end();

使用对象池：
- 优化思路：如果在写入过程中频繁创建对象（如数据库操作对象、文件句柄等），可以使用对象池来复用这些对象，减少对象创建和销毁的开销，从而优化内存使用。
- 示例代码：以简单的文件写入为例，使用 pool 来管理文件描述符（实际应用中需要更完善的对象池实现）：

const fs = require('fs');
const pool = [];
const getFileDescriptor = () => {
    if (pool.length > 0) {
        return pool.pop();
    }
    return fs.openSync('output.txt', 'w');
};
const releaseFileDescriptor = (fd) => {
    pool.push(fd);
};
let data = 'a'.repeat(1024 * 1024); // 1MB 数据
const fd = getFileDescriptor();
fs.writeSync(fd, data);
fs.closeSync(fd);
releaseFileDescriptor(fd);

通过以上从可写流配置、数据处理逻辑和内存管理等方面的优化，可以有效提高在高并发场景下大量数据写入不同目标时系统的整体性能和稳定性。

星途面试题库

面试题：Node.js 可写流 Writable 在高并发场景下的性能优化与资源管理

知识考点

面试题答案

可写流的配置优化

数据处理逻辑优化

内存管理优化