Node.js实现纯异步文件夹复制

本文主要探讨了如何在Node.js中实现纯异步的文件夹复制功能。通过使用异步处理和递归方法，可以有效地复制一个目录及其内容，并且在特定阈值下并行复制文件。 在Node.js中，实现文件夹（目录）复制功能时，我们可以采用以下策略： 1. Callback驱动：使用回调函数来处理异步操作，确保在每个步骤完成后才进行下一步，避免阻塞事件循环。 2. 递归遍历所有文件：通过递归方式遍历目标目录中的所有子文件和子目录，以便复制所有内容。 3. 并发复制文件：为了提高性能，可以在满足一定阈值的情况下并发复制多个文件。这可以通过异步任务队列来实现，例如使用`async`库中的函数。 下面是一个示例代码片段，展示了如何使用`async`库和`fs`模块来实现这个功能： ```javascript var async = require("async"); var fs = require("fs"); var path = require("path"); // 递归创建目录 function mkdirs(p, mode, f, made) { if (typeof mode === 'function' || mode === undefined) { f = mode; mode = 0777 & (~process.umask()); } if (!made) made = null; var cb = f || function() {}; if (typeof mode === 'string') mode = parseInt(mode, 8); p = path.resolve(p); fs.mkdir(p, mode, function(er) { if (!er) { made = made || p; return cb(null, made); } switch (er.code) { case 'ENOENT': mkdirs(path.dirname(p), mode, function(er, made) { if (er) { cb(er, made); } else { mkdirs(p, mode, cb, made); } }); break; // 其他错误情况下，检查是否已有目录 default: fs.stat(p, function(er2, stat) { // 如果stat失败，那是非常奇怪的，让原始错误成为失败原因 if (er2 || !stat.isDirectory()) { cb(er, made); } else { cb(null, made); } }); break; } }); } // 实现文件/目录复制 function copyDirectory(src, dest, options, callback) { async.waterfall([ function(callback) { fs.lstat(src, callback); }, function(stat, callback) { if (stat.isDirectory()) { mkdirs(dest, function(err, newDirPath) { if (err) return callback(err); copyDirectoryContents(src, dest, options, callback); }); } else { fs.copyFile(src, dest, options, callback); } } ], callback); } // 复制目录内容 function copyDirectoryContents(src, dest, options, callback) { fs.readdir(src, function(err, files) { if (err) return callback(err); async.eachLimit(files, 5, // 并发限制，例如这里设置为5 function(file, innerCallback) { var srcPath = path.join(src, file); var destPath = path.join(dest, file); copyDirectory(srcPath, destPath, options, innerCallback); }, callback); }); } // 使用示例 copyDirectory('源目录路径', '目标目录路径', {}, function(err) { if (err) console.error('复制过程中出错:', err); else console.log('复制成功'); }); ``` 这段代码首先定义了一个`mkdirs`函数，用于递归创建目录。然后，`copyDirectory`函数负责复制整个目录，它会先检查源路径是文件还是目录，如果是目录则调用`mkdirs`创建目标目录，然后使用`copyDirectoryContents`复制所有文件和子目录。`copyDirectoryContents`通过`fs.readdir`获取源目录中的所有文件，再用`async.eachLimit`并行处理这些文件，限制并发数量以防止过多的系统资源消耗。 最后，我们提供了一个使用示例，调用`copyDirectory`并传入源目录、目标目录路径以及回调函数来处理复制过程的错误或成功结果。 请注意，这个示例没有处理所有可能的异常情况，实际使用时应根据具体需求进行完善，例如添加错误处理、进度报告等。