在 NodeJS 中观看流式 HTTP 响应的进度，表达

Question

我想使用 express@4.8.5 和管道在 NodeJS 0.10.x 中流式传输相当大的文件。目前我是 这样做（在 CoffeeScript 中）：

app.get   '/', ( request, response ) ->
  input = P.create_readstream route
  input
    .pipe P.$split()
    .pipe P.$trim()
    .pipe P.$skip_empty()
    .pipe P.$skip_comments()
    .pipe P.$parse_csv headers: no, delimiter: '\t'
    .pipe response

（P 是 pipedreams。）

我想要的是类似的东西

    .pipe count_bytes       # ???
    .pipe response
    .pipe report_progress response

所以当我查看终端中运行的服务器时，我得到了一些关于已经有多少字节的指示 被客户接受。现在，看到客户端加载很长时间而没有 任何指示传输是在一分钟内还是明天完成。

是否有任何中间件可以做到这一点？我找不到。

哦，我必须在响应完成时调用任何东西吗？看起来它现在正在自动运行。

Answer 1

对于第二个问题，您不必关闭任何内容。 pipe 函数为您处理一切，甚至是流的节流（如果源流的数据由于下载速度差而超出客户端可以处理的范围，它将暂停源流，直到客户端可以再次使用源而不是通过完全阅读源代码使用一堆内存服务器端）。

对于您的第一个问题，要在您的流中拥有一些统计服务器端，您可以使用 Transform 流，例如：

var Transform = require('stream').Transform;
var util = require('util').inherits;

function StatsStream(ip, options) {
    Transform.call(this, options);
    this.ip = ip;
}

inherits(StatsStream, Transform);

StatsStream.prototype._transform = function(chunk, encoding, callback) {
    // here some bytes have been read from the source and are
    // ready to go to the destination, do your logging here
    console.log('flowing ', chunk.length, 'bytes to', this.ip);

    // then tell the tranform stream that the bytes it should
    // send to the destination is the same chunk you received...
    // (and that no error occured)
    callback(null, chunk);
};

然后在您的请求处理程序中，您可以像管道一样（抱歉 javascript）：

input.pipe(new StatsStream(req.ip)).pipe(response)

我是在头顶上做的，所以要小心:)