Node.js/читать 100 первых байтов файла

Я пытаюсь прочитать файл по частям: первые 100 байт, а затем.. Я пытаюсь прочитать первые 100 байт файла /npm:

app.post('/random', function(req, res) {
    var start = req.body.start;
    var fileName = './npm';
    var contentLength = req.body.contentlength;
    var file = randomAccessFile(fileName + 'read');
    console.log("Start is: " + start);
    console.log("ContentLength is: " + contentLength);
    fs.open(fileName, 'r', function(status, fd) {
        if (status) {
            console.log(status.message);
            return;
        }
        var buffer = new Buffer(contentLength);
        fs.read(fd, buffer, start, contentLength, 0, function(err, num) {
            console.log(buffer.toString('utf-8', 0, num));
        });
    });

вывод:

Start is: 0
ContentLength is: 100

и следующей ошибки:

fs.js:457
  binding.read(fd, buffer, offset, length, position, wrapper);
          ^
Error: Length extends beyond buffer
    at Object.fs.read (fs.js:457:11)
    at C:\NodeInst\node\FileSys.js:132:12
    at Object.oncomplete (fs.js:107:15)

В чем может быть причина?

Ответ 1

Вы смешиваете аргумент offset и position. Из документы:

offset - это смещение в буфере для начала записи в.

position - целое число, определяющее, с чего начать чтение из файла. Если позиция равна нулю, данные будут считаны из текущей позиции файла.

Вы должны изменить свой код на это:

    fs.read(fd, buffer, 0, contentLength, start, function(err, num) {
        console.log(buffer.toString('utf-8', 0, num));
    });

В основном offset будет индексом, который fs.read будет записывать в буфер. Скажем, у вас есть буфер длиной 10, как это: <Buffer 01 02 03 04 05 06 07 08 09 0a> и вы будете читать от /dev/zero, который в основном только нули, и установите смещение на 3 и установите длину 4, после чего вы получите следующее: <Buffer 01 02 03 00 00 00 00 08 09 0a>.

fs.open('/dev/zero', 'r', function(status, fd) {
    if (status) {
        console.log(status.message);
        return;
    }
    var buffer = new Buffer([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]);
    fs.read(fd, buffer, 3, 4, 0, function(err, num) {
        console.log(buffer);
    });
});

Также, чтобы сделать то, что вы могли бы попытаться использовать fs.createStream:

app.post('/random', function(req, res) {
    var start = req.body.start;
    var fileName = './npm';
    var contentLength = req.body.contentlength;
    fs.createReadStream(fileName, { start : start, end: contentLength - 1 })
        .pipe(res);
});

Ответ 2

Начиная с узла 10, существует экспериментальный Readable[Symbol.asyncIterator] (который больше не является экспериментальным в узле v12).

'use strict';

const fs = require('fs');

async function run() {
  const file = 'hello.csv';
  const stream = fs.createReadStream(file, { encoding: 'utf8', start: 0, end: 100 });
  for await (const chunk of stream) {
    console.log('${file} >>> ${chunk}');
  }

  // or if you don't want the for-await-loop
  const stream = fs.createReadStream(file, { encoding: 'utf8', start: 0, end: 100 });
  const firstByte = await stream[Symbol.asyncIterator]().next();
  console.log('${file} >>> ${firstByte.value}');
}

run();

Распечатает первые укусы