使用fs.unlink删除文件成功却报错，async queue的drain回调重复触发

看起来你碰到了两个关联的问题：async queue的drain回调触发两次，以及后续执行fs.unlink时抛出文件不存在的错误。咱们一步步拆解解决：

1. 为什么drain回调会触发两次？ #

这是问题的核心根源——因为回调被触发了两次，第一次已经把目标文件删掉了，第二次执行fs.unlink时自然找不到文件，从而抛出no such file or directory错误。

常见的重复触发原因：

• 重复绑定drain事件：如果你的代码在循环、或者每次添加任务时都调用queue.drain(() => { ... })，每调用一次就会给队列新增一个回调监听。当队列任务全部完成时，所有绑定的回调都会被执行，就会出现日志输出两次的情况。
• 队列被意外重置/重复初始化：如果代码逻辑中多次创建了新的async queue实例，每个实例都绑定了相同的drain回调，也会导致多次触发。

解决办法： #

• 确保drain回调只绑定一次：把回调绑定的代码放在队列初始化的地方，比如：

  const queue = async.queue((task, callback) => {
    // 你的S3上传任务逻辑
    uploadToS3(task.filePath, callback);
  }, concurrency);
  
  // 只在这里绑定一次drain回调
  queue.drain(() => {
    const delta = (Date.now() - startTime) / 1000;
    console.log('Completed upload in', delta, 'seconds');
    // 执行文件删除操作
    handleFileDelete(task.filePath);
  });
  

• 检查代码中是否有重复创建队列的逻辑，确保整个流程只使用同一个队列实例。

2. 如何避免fs.unlink的文件不存在错误？ #

即使解决了drain重复触发的问题，也可能因为其他竞态条件（比如文件被其他进程删除）导致报错。所以最好给fs.unlink加上针对性的错误处理：

异步回调版本（推荐，避免阻塞）： #

function handleFileDelete(filePath) {
  fs.unlink(filePath, (err) => {
    if (err) {
      // 只处理非"文件不存在"的错误，该情况直接忽略
      if (err.code !== 'ENOENT') {
        console.error('Failed to delete file:', err);
      }
      return;
    }
    console.log('File deleted successfully');
  });
}

Promise版本（更贴合现代异步代码风格）： #

import { unlink } from 'fs/promises';

async function handleFileDelete(filePath) {
  try {
    await unlink(filePath);
    console.log('File deleted successfully');
  } catch (err) {
    if (err.code !== 'ENOENT') {
      console.error('Failed to delete file:', err);
    }
  }
}

这样即使文件已经被删除，也只会忽略ENOENT（文件不存在）的错误，不会抛出异常影响正常流程。

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