nodejs在数据响应上设置超时

Question

我正在尝试在 readstream.write 之间设置超时，但我不断收到错误：结束后写入。如何在 res.write 之间设置超时。谢谢你。这是我的代码。

app.get('/video', function (req, res) {


  var readStream = fs.createReadStream('video.mjpeg');
  res.writeHead(200, {'Content-Type': 'multipart/x-mixed-  replace;boundary=ThisString'});

  readStream.on("data", (chunk) => {
    res.write(chunk, 'binary');

    setTimeout(function () {
      res.write('ThisString');
    }, 200);
    console.log("Writing to client");
  });

  readStream.on("end", () => {
    readStream.destroy();
    res.end();
    console.log("End of data"); 
  });
});

我正在尝试在客户端显示视频，问题是 mjpeg 被快速读取，因此无法创建视频。任何帮助将不胜感激。

Answer 1

我很快写了几行我理解你需要的代码。 StackOverflow 不是我最喜欢的 IDE，所以不要太用力 ^^ 我真的不知道 readStream 但data 事件被多次调用 write 吗？ 队列正在等待前面的块，并且它的超时已正确完成。 是你需要的吗？

var kue = require('kue'),
    jobs = kue.createQueue();

app.get('/video', function (req, res) {

  var readStream = fs.createReadStream('video.mjpeg');
  res.writeHead(200, {'Content-Type': 'multipart/x-mixed-  replace;boundary=ThisString'});

  jobs.process('write chunck', function (job, done) {
    setTimeout(function() {
      res.write(job.chunck, 'binary');
      done && done();
    }, 200);
  });

  jobs.process('write end', function(job, done) {
    readStream.destroy();
    res.end();
    console.log("End of data");
    done & done();
  });

  readStream.on("data", (chunk) => {
    jobs.create('write chunck', {
      chunk: chunk
    });
  });

  readStream.on("end", () => {
    jobs.create('write end', {});
  });
});