在同一个 fd 上多次 createReadStream

Question

In a previous question 似乎从 node.js 中的文件进行随机访问读取的唯一方法是使用 fs.createReadStream() 及其可选的 fd、start 和 end 字段。

这在我最简单的测试中运行良好。但在我的项目中，我需要反复读取二进制文件的不同偏移量。这以一种奇怪的方式失败了，所以我想出了一个最小的测试用例：

var fs = require('fs');

fs.open('test.txt', 'r', function (err, fd) {
  if (err) {
    console.error('error opening file: ' + err);
  } else {
    fs.createReadStream(null, {fd: fd, start: 2, end: 5}).on('error', function (err) {
        throw e;
      }).on('close', function () {
        console.log('outer close');
      }).on('data', function (data) {
        console.log('outer data', data);
      }).on('end', function () {
        console.log('outer end');

        fs.createReadStream(null, {fd: fd, start: 0, end: 3}).on('error', function (err) {
            throw e;
          }).on('close', function () {
            console.log('inner close');
          }).on('data', function (data) {
            console.log('inner data', data);
          }).on('end', function () {
            console.log('inner end');

            // more code to execute after both reads
          });
      });
  }
});

从未收到内部end 事件。 （外层close接收不一致，但我不需要附加代码。）

我之前在 Perl 中甚至在 JavaScript 中作为 Firefox 扩展实现过这个项目，但在 node.js 下它被证明是困难的。这也是对我是否可以开始using node.js as a general purpose scripting language的测试。

Answer 1

问题是外部ReadStream在使用后会关闭fd，所以在第二个ReadStream上重复使用会失败。最新的 Node 不稳定实际上有 ReadStreams 的 autoClose 选项，但这还不是 stable 的一部分。

真正的答案是您在上一个问题中提供给您的信息不正确。 createReadStream 是使用所有公共 API 实现的，所以没有什么是你不能做的。在这种情况下，您可以只使用 fs.read 及其 position 参数。

var fs = require('fs');                                                         

fs.open('test.txt', 'r', function (err, fd) {                                   
  if (err) {                                                                    
    console.error('error opening file: ' + err);                                
  } else {                                                                      
    fs.read(fd, new Buffer(4), 0, 4, 2, function(err, bytesRead, data){        
      if (err) throw err;                                                       
      console.log('outer data', data);                                          

      fs.read(fd, new Buffer(3), 0, 3, 0, function(err, bytesRead, data2){   
        if (err) throw err;                                                     
        console.log('inner data', data2);                                       
        fs.close(fd);                                                           

        // more code to execute after both reads                                
      });                                                                       
    });                                                                         
  }                                                                             
});