Node.js流处理时调用unlink删除文件报EPERM错误如何解决？

• 核心原因是Transform流抛出错误时，你通过pipe串联的写入流仍然处于打开状态，持有目标输出文件的操作系统句柄/文件锁，此时直接调用删除接口会被操作系统拦截，抛出EPERM权限错误，该问题在Windows系统上尤为常见。
• 默认的pipe方法不会在中间流报错时自动销毁上下游的所有流，因此读流、写入流的资源都没有被释放，文件一直处于被占用状态。

方案1：手动释放流资源后删除文件 #

捕获到Transform流错误后，先主动销毁所有关联的流，等待写入流完全关闭、文件句柄释放后再执行删除操作：

MyTransform.on('error', (err) => {
    if (err.code === 'LIMIT_EXCEEDED') {
        // 销毁所有关联流，释放文件资源
        stream.destroy()
        MyTransform.destroy()
        writeStream.destroy()
        // 监听写入流关闭事件，确认资源释放后再删除文件
        writeStream.once('close', () => {
            try {
                fs.unlinkSync(outPath)
            } catch (unlinkErr) {
                // 极端场景下可增加延迟重试兜底
                setTimeout(() => fs.unlinkSync(outPath), 100)
            }
        })
        return
    }
})

方案2：使用stream.pipeline替代手动pipe（更推荐） #

Node.js官方提供的stream.pipeline工具会自动处理流错误、销毁所有串联流，无需手动管理资源，错误触发时所有流资源已经被释放，可以直接删除文件：

// 引入pipeline，也可以使用回调版本require('stream').pipeline
const { pipeline } = require('stream/promises')

const TestStream = async () => {
    const readStream = fs.createReadStream(__filename, {
        highWaterMark: 40,
        encoding: 'utf-8'
    });
    const outPath = __filename + '.out';
    const writeStream = fs.createWriteStream(outPath)
    const MyTransform = new myTransform()

    try {
        await pipeline(readStream, MyTransform, writeStream)
    } catch (err) {
        if (err.code === 'LIMIT_EXCEEDED') {
            // 此时所有流已自动销毁，可直接删除文件
            fs.unlinkSync(outPath)
        }
    }
}

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