面试题：Node.js异步编程与性能优化

利用异步编程和事件驱动机制优化Node.js中I/O性能瓶颈的策略

使用Promise
- 策略：Promise是一种处理异步操作的方式，它允许将异步操作以链式调用的形式进行处理，避免了回调地狱。在Node.js中，许多I/O操作都可以被包装成Promise。
- 代码示例：

const fs = require('fs');
const { promisify } = require('util');

// 将fs.readFile包装成Promise
const readFileAsync = promisify(fs.readFile);

async function readFiles() {
    try {
        const data1 = await readFileAsync('file1.txt', 'utf8');
        const data2 = await readFileAsync('file2.txt', 'utf8');
        console.log('File 1 content:', data1);
        console.log('File 2 content:', data2);
    } catch (err) {
        console.error('Error reading files:', err);
    }
}

readFiles();

在这个示例中，promisify将Node.js的传统回调风格的fs.readFile方法转换为返回Promise的函数。然后在readFiles函数中，使用await等待Promise的解决，使得代码看起来更像同步代码，提高了可读性。

async/await
- 策略：async/await是基于Promise构建的语法糖，它使得异步代码看起来像同步代码。async函数总是返回一个Promise，await只能在async函数内部使用，用于暂停函数执行直到Promise被解决。
- 代码示例：

const http = require('http');
const { promisify } = require('util');

// 将http.get包装成Promise
const getAsync = (url) => {
    return new Promise((resolve, reject) => {
        http.get(url, (res) => {
            let data = '';
            res.on('data', (chunk) => {
                data += chunk;
            });
            res.on('end', () => {
                resolve(data);
            });
            res.on('error', (err) => {
                reject(err);
            });
        });
    });
};

async function fetchData() {
    try {
        const response1 = await getAsync('http://example.com/api/data1');
        const response2 = await getAsync('http://example.com/api/data2');
        console.log('Response 1:', response1);
        console.log('Response 2:', response2);
    } catch (err) {
        console.error('Error fetching data:', err);
    }
}

fetchData();

这里将http.get操作包装成Promise，然后在fetchData的async函数中使用await来顺序地获取两个不同URL的数据，避免了复杂的嵌套回调。

事件驱动机制
- 策略：Node.js本身是基于事件驱动的。在处理I/O操作时，可以利用事件监听来在I/O操作完成时执行相应的回调。例如，fs.ReadStream可以监听data事件来逐块读取文件内容，而不是一次性读取整个文件，这在处理大文件时可以节省内存。
- 代码示例：

const fs = require('fs');

const readableStream = fs.createReadStream('largeFile.txt', 'utf8');

readableStream.on('data', (chunk) => {
    console.log('Received chunk:', chunk.length);
    // 在这里处理每一块数据，例如写入另一个文件等
});

readableStream.on('end', () => {
    console.log('All data has been read.');
});

readableStream.on('error', (err) => {
    console.error('Error reading file:', err);
});

在这个例子中，fs.createReadStream创建了一个可读流，通过监听data事件，我们可以逐块处理文件内容，当所有数据读取完毕时，end事件被触发。如果在读取过程中发生错误，error事件会被触发。这样在处理大量I/O操作时，特别是大文件的读取，能有效优化内存使用和性能。

星途面试题库

面试题：Node.js异步编程与性能优化

知识考点

面试题答案

利用异步编程和事件驱动机制优化Node.js中I/O性能瓶颈的策略