管道两次http请求时出现随机错误

Question

我有这个代码：

var file = fs.createWriteStream(_filename, _saveFile);
var request = http.request(options);
var decrypt = Crypto.createDecipheriv('aes-128-cbc', key, iv);

var _saveFile = function(response) {
  res.pipe(decrypt).pipe(file);
  res.on("end", function() {
    file.close();
  });
};

file.on("error", function(err) {
  console.log("Error while writing file", err);
});

它工作正常。但随机我收到此错误：

{ [Error: EBADF, write] errno: 9, code: 'EBADF' }

我读到这是因为文件是在关闭后写入的。所以，我的问题是：我做错了吗？有什么办法可以用decrypt.on("end")代替res.on("end")？

更多信息

在同一个 res.on("end") 我有一个 q.defer().resolve 调用，因为这个方法是下载几个 .ts 文件，然后我需要把它们变成 MP4。

正如@mscdex 所说，没有必要关闭文件，但是，如果在文件实际完成之前解决了承诺，那么我可能正在处理损坏的文件。像这样：

1. 下载1.ts
2. 下载2.ts
3. 下载3.ts
   • 这里所有的承诺都保存在一个数组中，然后我使用q.spread 等待所有承诺
4. 文件 1.ts 写入
5. 文件 1.ts 解决承诺
6. 文件 2.ts 写入
7. 文件 2.ts 解决承诺
8. 文件 3.ts 解决承诺
9. q.spread 知道所有承诺都已解决，因此它开始使用 .ts 文件
10. 已写入文件 3.ts
    • 从现在开始，我将使用错误/不完整的文件。

Answer 1

您不需要显式调用file.close()，因为上游结束时文件流将自动关闭。

如果您需要等到文件完全写入，请在file 上监听finish 事件：

file.on('finish', function() {
  // resolve promise or do whatever
});