javascript - 使用 NodeJS 正确发送文件

Question

考虑以下相当琐碎的中间件：

(req, res, next) => {
  const stream = fs.createReadStream(req.filePath)

  await new Promise((resolve, reject) => stream    
    .on('error', reject)
    .on('end', resolve)
    .pipe(res, { end: false })
    .on('error', reject)
    // 'close' is emitted if client prematurely disconnects.
    .on('close', resolve)
  res.end()
}

有几个问题我不确定如何处理：

• 如果 res 在此中间件运行之前已经发出“关闭”，它将被卡住。
• 如果 res 发出close或error如何清理源流？autoClose只有在end读取所有数据后才会运行。但是，如果目标失败，它是如何传播到源的？我应该总是调用destroy源流吗？

Answer 1

这似乎可以解决问题：

import onFinished from 'on-finished'

(req, res, next) => {
  const stream = fs.createReadStream(req.filePath)

  onFinished(res, () => stream.destroy && stream.destroy())

  if (onFinished.isFinished(res)) {
    return
  }

  await new Promise((resolve, reject) => stream    
    .on('error', reject)
    .on('end', resolve)
    .pipe(res, { end: false })
    .on('error', reject)
    // 'close' is emitted if client prematurely disconnects.
    .on('close', resolve)
  res.end()
}