5

我开始学习节点和流似乎是你经常使用的东西，在我读过的大多数文档中，当你处理大型文件时提到了“背压问题”，但我没有找到明确的解释这个问题到底是什么。我也读过使用管道可以帮助解决这个问题，但是管道究竟是如何解决背压问题的？

感谢您提前进行任何解释。

4

1 回答 1

5

背压是当您写入流的速度比其他进程可以处理/使用的速度更快时，您可以控制流、暂停和恢复流；这是在 nodejs 中实现背压的示例

var http = require('http'),
    fs = require('fs');

var server = http.createServer(function(request, response) {
  var file = fs.createWriteStream('upload.jpg'),
      fileBytes = request.headers['content-length'],
      uploadedBytes = 0;

  request.on('data', function(chunk) {
    uploadedBytes += chunk.length;
    var progress = (uploadedBytes / fileBytes) * 100;
    response.write('progress: ' + parseInt(progress, 10) + '%\n');

    var bufferOK = file.write(chunk);

    if (!bufferOK) {
      request.pause();
    }
  });

  file.on('drain', function() {
    request.resume();
  });

  request.on('end', function() {
    response.end('upload complete\n');
  });

});

server.listen(8080);

本福斯特解决方案 - 来源： https ://gist.github.com/benfoster/9543337

于 2018-12-13T16:41:02.770 回答