如何使用Promise处理文件读取

const fs = require('fs').promises; // 注意这里是.promises，这是关键

/**
 * 使用Promise（通过async/await）读取文件内容
 * @param {string} filePath - 文件路径
 * @returns {Promise<string>} - 返回文件内容的Promise
 */
async function readTextFileContent(filePath) {
    console.log(`尝试读取文件: ${filePath}`);
    try {
        // fs.readFile返回一个Promise，await会等待其解析
        const data = await fs.readFile(filePath, 'utf8');
        console.log('文件内容已成功读取（部分预览）:', data.substring(0, 100) + '...');
        return data;
    } catch (error) {
        // 任何读取过程中发生的错误都会被捕获
        console.error(`读取文件 ${filePath} 出错:`, error.message);
        // 通常，我们会选择在这里重新抛出错误，让上层调用者决定如何处理
        throw error;
    }
}

// 示例调用：
// 假设有一个名为 'my_document.txt' 的文件
readTextFileContent('my_document.txt')
    .then(content => {
        // 文件读取成功后的处理逻辑
        // console.log('文件读取完成，可以在这里对内容进行进一步处理。');
    })
    .catch(err => {
        // 最终的错误捕获，处理所有未被内部处理的错误
        console.error('文件操作最终失败:', err.message);
    });

// 你也可以读取二进制文件，比如图片，这时就不需要指定编码
// fs.readFile('my_image.png')
//   .then(imageData => {
//     // 处理二进制数据，比如保存到数据库或进行图片处理
//     console.log('图片文件读取成功，大小:', imageData.length, '字节');
//   })
//   .catch(err => {
//     console.error('读取图片文件失败:', err.message);
//   });

const fs = require('fs').promises;

// 示例1: 使用 .catch() 处理 Promise 链中的错误
fs.readFile('non_existent_file.txt', 'utf8')
    .then(data => {
        console.log('成功读取到内容:', data);
    })
    .catch(err => {
        console.error('Promise链式调用中捕获到错误:', err.message);
        // 根据错误类型进行更细致的判断和处理
        if (err.code === 'ENOENT') { // ENOENT: Error NO ENTry (文件或目录不存在)
            console.error('哎呀，文件找不着！请检查文件路径是否正确。');
        } else if (err.code === 'EACCES') { // EACCES: Error ACCESs (权限不足)
            console.error('没权限读这个文件！请检查文件权限。');
        } else {
            console.error('读取文件遇到其他未知问题。');
        }
    });

// 示例2: 使用 async/await 配合 try...catch 处理错误
async function safeReadFileContent(filePath) {
    try {
        const content = await fs.readFile(filePath, 'utf8');
        console.log(`成功读取 ${filePath}，内容片段: ${content.substring(0, 50)}...`);
        return content;
    } catch (e) {
        console.error(`尝试读取 ${filePath} 失败了:`, e.message);
        // 这里可以根据 e.code 或其他错误属性进行更具体的错误分类和响应
        if (e.code === 'EISDIR') { // EISDIR: Error IS DIRectory (路径指向的是一个目录而不是文件)
            console.error('你给的是个目录，不是文件哦！');
        }
        throw e; // 重新抛出错误，让上层调用者知道操作失败
    }
}

// 调用示例
safeReadFileContent('a_directory/') // 假设这是一个目录
    .catch(err => {
        console.error('上层捕获到错误:', err.message);
    });

safeReadFileContent('/root/secret_file.txt') // 假设没有权限访问
    .catch(err => {
        console.error('上层捕获到错误:', err.message);
    });

const { createReadStream, createWriteStream } = require('fs');
const { pipeline } = require('stream/promises'); // Node.js 15+ 引入的 Promise-based pipeline

/**
 * 使用流（Stream）和 Promise 复制大文件
 * @param {string} sourcePath - 源文件路径
 * @param {string} destPath - 目标文件路径
 */
async function copyLargeFileWithStream(sourcePath, destPath) {
    console.log(`开始流式复制文件：从 ${sourcePath} 到 ${destPath}`);
    const readStream = createReadStream(sourcePath);
    const writeStream = createWriteStream(destPath);

    try {
        // pipeline 会连接流，并在所有流完成或出错时返回一个 Promise
        await pipeline(readStream, writeStream);
        console.log('文件复制完成，流式处理确实高效！');
    } catch (error) {
        console.error('流式复制文件失败:', error.message);
        // 流错误通常也带有 code 属性
        if (error.code === 'ENOENT') {
            console.error('源文件或目标路径不存在，请检查。');
        }
        // ... 其他错误处理，比如磁盘空间不足等
    }
}

// 示例：复制一个可能很大的文件
// copyLargeFileWithStream('very_large_input.log', 'very_large_output.log');
// 实际使用时，请确保 'very_large_input.log' 文件存在

// 对于更老的Node.js版本，或者需要更细致的流事件控制，你可以自己封装一个Promise
function readStreamToPromise(filePath) {
    return new Promise((resolve, reject) => {
        const stream = createReadStream(filePath, { encoding: 'utf8' });
        let data = '';

        stream.on('data', chunk => {
            // 每当有数据块可用时
            data += chunk;
        });

        stream.on('end', () => {
            // 文件读取完毕
            resolve(data);
        });

        stream.on('error', err => {
            // 读取过程中发生错误
            reject(err);
        });

        // 重要的：当流不再需要时，需要确保它被关闭
        // 在 error 或 end 事件发生后，流会自动关闭，但如果提前终止，可能需要手动 stream.destroy()
    });
}

// 示例：使用自定义Promise封装流读取小文件
// readStreamToPromise('small_config.json')
//     .then(content => console.log('流式读取的小文件内容:', content.substring(0, 100)))
//     .catch(err => console.error('流式读取小文件失败:', err.message));