3

在前面的问题中，似乎从 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 下它被证明是困难的。这也是对我是否可以开始使用 node.js 作为通用脚本语言的测试。

4

1 回答 1

3

问题是外部ReadStream将在fd使用后关闭它，因此在第二个重复使用它ReadStream会失败。最新的 Node 不稳定实际上有一个autoClose选项，ReadStreams但这还不是 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                                
      });                                                                       
    });                                                                         
  }                                                                             
});
于 2012-12-24T04:49:00.957 回答