如何在Multer自定义存储引擎中实现多文件上传流？

这是个很常见的Multer使用误区，核心原因是你误解了_handleFile钩子的工作机制——它是针对单个文件的处理函数，每次调用只负责处理上传队列里的一个文件，此时req.files还处于构建过程中，并不是最终完整的文件数组。

为什么会出现这个问题？ #

Multer处理多文件上传时，会逐个调用_handleFile方法（默认串行，也可配置并行），每次调用时，req.files只会包含已经处理完成或正在处理的文件，而不是所有上传的文件。所以你在_handleFile里看到req.files.length = 1是完全正常的——因为此时只处理到第一个文件。

解决方案 #

根据你的业务需求，分两种场景处理：

1. 仅需在上传完成后获取完整文件列表

如果你的逻辑不需要在单个文件处理时依赖其他文件，只需要在整个上传流程结束后拿到所有文件信息，直接在请求处理控制器里访问req.files即可，这里才是最终完整的文件数组：

// 请求控制器示例
const streamStorage = multer({ storage: new CustomStreamEngine() });

app.post('/upload-files', streamStorage.array('uploaded-files', 10), (req, res) => {
  // 这里的req.files是完整的上传文件数组
  console.log(`成功上传${req.files.length}个文件`);
  res.status(200).json({ total: req.files.length, files: req.files });
});

2. 需要在单个文件处理时跟踪所有文件

如果必须在_handleFile里关联所有上传文件的信息（比如批量同步元数据到S3），可以在自定义存储引擎的构造函数里维护一个内部文件列表，每次处理文件时将其加入列表，最后在_done钩子（所有文件处理完成后触发）里统一处理：

// 自定义流引擎修改版
function CustomStreamEngine(options) {
  this.uploadedFiles = []; // 维护所有上传文件的内部列表
  // 你的其他初始化逻辑，比如S3配置...
}

CustomStreamEngine.prototype._handleFile = function _handleFile(req, file, cb) {
  // 将当前文件加入内部列表
  this.uploadedFiles.push(file);
  console.log(`正在处理第${this.uploadedFiles.length}个文件: ${file.originalname}`);

  // 你的S3流上传逻辑示例
  const s3UploadParams = {
    Bucket: 'your-s3-bucket-name',
    Key: `uploads/${Date.now()}-${file.originalname}`,
    Body: file.stream
  };

  // 发起S3流上传
  const uploadPromise = s3.upload(s3UploadParams).promise();
  
  uploadPromise
    .then(result => {
      // 可以把S3返回的信息附加到file对象，方便后续使用
      file.s3Path = result.Location;
      cb(null, { path: result.Location });
    })
    .catch(err => cb(err));
};

// 所有文件处理完成后触发的钩子
CustomStreamEngine.prototype._done = function _done(req, cb) {
  console.log(`所有文件处理完成，总计${this.uploadedFiles.length}个`);
  // 这里可以做批量操作，比如同步元数据到数据库等
  // 清空内部列表，避免重复使用时的污染
  this.uploadedFiles = [];
  cb();
};

关键提醒 #

• 永远不要在_handleFile里依赖req.files的完整性，它的内容会随着文件处理进度动态变化。
• 如果需要并行处理文件，可以在Multer配置里调整limits: { files: 5 }，但_handleFile仍然是逐个调用的，内部文件列表可以帮你跟踪整体进度。

内容的提问来源于stack exchange，提问作者Baroque Code