初入Nodejs 还请指教

初入Nodejs 还请指教

异步遍历文件及查找文件 response结果 如何得知所有异步结束 (递归遍历)

4 回复

当然可以！在Node.js中处理异步操作时，尤其是涉及到递归遍历文件系统，确保所有异步操作完成后再进行下一步处理是一个常见的需求。我们可以使用fs/promises模块来实现这一点，并结合Promise.all来等待所有异步操作完成。

示例代码

假设我们要递归遍历一个目录及其子目录中的所有文件，并获取这些文件的响应结果（例如读取文件内容）。

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

async function readFilesRecursively(dir) {
    let files = await fs.readdir(dir);
    
    const filePromises = files.map(async (file) => {
        const filePath = path.join(dir, file);
        const stats = await fs.stat(filePath);
        
        if (stats.isDirectory()) {
            // 如果是目录，则递归调用
            return readFilesRecursively(filePath);
        } else {
            // 如果是文件，则读取文件内容
            const content = await fs.readFile(filePath, 'utf-8');
            return { path: filePath, content };
        }
    });

    // 使用 Promise.all 等待所有异步操作完成
    const results = await Promise.all(filePromises);

    // 将二维数组扁平化为一维数组
    return results.flat();
}

// 调用函数并打印结果
readFilesRecursively('/path/to/your/directory')
    .then((results) => {
        console.log(results); // 打印所有文件的路径和内容
    })
    .catch((err) => {
        console.error(err);
    });

解释

  1. 读取目录内容：

    const files = await fs.readdir(dir);

    使用fs.promises.readdir方法读取指定目录下的所有文件和子目录。

  2. 递归遍历：

    const filePromises = files.map(async (file) => {
    const filePath = path.join(dir, file);
    const stats = await fs.stat(filePath);
    
    if (stats.isDirectory()) {
        // 如果是目录，则递归调用
        return readFilesRecursively(filePath);
    } else {
        // 如果是文件，则读取文件内容
        const content = await fs.readFile(filePath, 'utf-8');
        return { path: filePath, content };
    }
});

    对于每个文件或子目录，我们使用fs.promises.stat方法检查其类型。如果是目录，则递归调用readFilesRecursively；如果是文件，则读取文件内容。

  3. 等待所有异步操作完成：

    const results = await Promise.all(filePromises);

    使用Promise.all等待所有异步操作完成。这将返回一个包含所有结果的数组。

  4. 扁平化结果：

    return results.flat();

    使用flat()方法将多维数组扁平化为一维数组。

通过这种方式，你可以确保所有异步操作完成后再进行下一步处理，从而避免遗漏任何文件或数据。希望这对您有所帮助！


https://github.com/alsotang/node-lessons

https://www.npmjs.org/package/glob

在处理异步遍历文件及查找文件时，经常会遇到如何确定所有异步操作完成的问题。为了解决这个问题，我们可以使用 Promise 和 async/await 来管理异步操作，同时利用数组或集合来存储所有的 Promise，并通过 Promise.all 等方法来确保所有操作完成后才执行下一步。

以下是一个简单的示例代码，展示如何使用 fs/promises 模块来递归遍历目录并获取所有文件的路径列表：

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

async function readDir(dir) {
    let results = [];
    
    const items = await fs.readdir(dir, { withFileTypes: true });
    
    for (const item of items) {
        const resPath = path.join(dir, item.name);
        
        if (item.isDirectory()) {
            // 如果是目录，递归读取该目录
            const subItems = await readDir(resPath);
            results = results.concat(subItems);
        } else {
            // 如果是文件，将其路径添加到结果列表中
            results.push(resPath);
        }
    }
    
    return results;
}

(async () => {
    try {
        const files = await readDir('/your/directory/path');
        console.log(files);
    } catch (error) {
        console.error(error);
    }
})();

解释：

  1. 引入模块：使用 fs.promises 提供了 promise 版本的文件系统 API，使得我们可以更方便地处理异步操作。
  2. 递归函数：定义了一个 readDir 函数，该函数接受一个目录路径作为参数。
  3. 读取目录：使用 fs.readdir 方法读取目录中的文件和子目录。
  4. 判断类型：使用 Dirent 对象的 isDirectory 方法判断当前项是否为目录。
  5. 递归处理：如果是目录，则递归调用 readDir 函数；如果是文件，则将其路径添加到结果列表中。
  6. 返回结果：最终返回包含所有文件路径的数组。
  7. 主程序：通过 async IIFE 调用 readDir 函数，并处理可能出现的错误。

这样，我们就能在所有异步操作完成后得到一个包含所有文件路径的结果数组。

回到顶部