使用Multer DiskStorage传S3后，无法删除本地uploads文件的问题

错误原因分析 #

出现EPERM: operation not permitted错误，核心原因是本地文件还被系统或进程占用：要么Multer未完全释放文件句柄，要么S3上传操作仍在读写该文件，导致删除时文件被锁定。

具体解决方法 #

• 确保S3上传完成后再执行删除
  必须用await等待所有S3上传的Promise完成，绝对不能用回调模式（否则删除逻辑会提前执行，此时文件还在被上传进程占用）。批量上传时，用Promise.all等待所有上传任务结束后，再统一删除本地文件。

• 避免文件句柄泄漏
  如果代码中手动读取了文件，一定要用Promise版本的方法（比如fs.promises.readFile），或者确保手动关闭文件流，防止句柄未释放导致文件锁定。

• 临时延迟删除（应急方案）
  如果上述方法仍无效，可以给删除操作加个短暂延迟，给系统足够时间释放文件锁：

  setTimeout(async () => {
    await fs.promises.unlink(file.path);
  }, 1000); // 延迟1秒，可根据实际情况调整
  

  注意这只是临时 workaround，优先解决异步顺序的根本问题。

• 检查文件夹权限
  确认uploads文件夹的读写权限：Windows下右键文件夹→属性→安全，确保运行服务器的用户有删除权限；Linux下用chmod 755 uploads调整权限。

• 进阶：自定义Multer存储（最小重构）
  不想完全重构的话，可以自定义Multer存储引擎，在文件写入完成后确保句柄释放，示例如下：

  const customStorage = multer.diskStorage({
    destination: (req, file, cb) => cb(null, 'uploads/'),
    filename: (req, file, cb) => cb(null, uuidv4() + path.extname(file.originalname)),
    onFileUploadComplete: (file) => {
      console.log(`文件 ${file.path} 写入完成`);
    }
  });
  const upload = multer({ storage: customStorage });
  

修正后的控制器代码示例 #

import { S3 } from 'aws-sdk';
import fs from 'fs/promises';
import { Request, Response } from 'express';

const s3 = new S3();

export const createItem = async (req: Request, res: Response) => {
  try {
    // 1. 处理商品基本数据
    const itemData = req.body;

    // 2. 批量上传文件到S3，等待全部完成
    const uploadTasks = (req.files as Express.Multer.File[]).map(async (file) => {
      const s3Params = {
        Bucket: '你的S3桶名',
        Key: `items/${file.filename}`,
        Body: fs.createReadStream(file.path),
        ContentType: file.mimetype
      };
      await s3.upload(s3Params).promise();
      return file.path; // 记录本地文件路径用于删除
    });
    const localFilePaths = await Promise.all(uploadTasks);

    // 3. 批量删除本地文件
    const deleteTasks = localFilePaths.map(async (path) => {
      try {
        await fs.unlink(path);
        console.log(`清理本地文件：${path}`);
      } catch (delErr) {
        console.error(`删除文件失败：${path}`, delErr);
      }
    });
    await Promise.all(deleteTasks);

    // 4. 保存商品数据到数据库并响应
    // const newItem = await Item.create(itemData);
    res.status(201).json({ message: '商品创建成功' });
  } catch (err) {
    // 错误时清理已上传的本地文件
    if (req.files) {
      (req.files as Express.Multer.File[]).forEach(async (file) => {
        try {
          await fs.unlink(file.path);
        } catch (cleanErr) {
          console.error(`清理临时文件失败：${file.path}`, cleanErr);
        }
      });
    }
    res.status(500).json({ error: '商品创建失败' });
  }
};

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