我应该用什么代替 readableStream.push('')

Question

我正在尝试实现._read可读流的功能，在._read调用时出现问题并且没有数据，文档说我可以push('')直到更多数据到来，并且只有return false当流永远不会有更多数据时我才应该。 https://nodejs.org/api/stream.html#stream_readable_read_size_1

但它也说，如果我需要这样做，那么我的设计就会出现严重错误。 https://nodejs.org/api/stream.html#stream_stream_push

但我找不到替代方案。

代码：

    var http = require('http');
    var https = require('https');
    var Readable = require('stream').Readable;
    var router = require('express').Router();
    var buffer = [];

    router.post('/', function(clientRequest, clientResponse) {
        var delayedMSStream = new Readable;
        delayedMSStream._read = function() {
            var a=buffer.shift();
            if(typeof a === 'undefined'){
                this.push('');
                return true;
            }
            else {
                this.push(a);
                if(a===null) {
                    return false;
                }
                return true;
            }
        };
        //I need to get a url from example.com
        https.request({hostname:'example.com'}, function(exampleResponse){
            data='';
            exampleResponse.on('data',function(chunk){data+=chunk});
            exampleResponse.on('end',function(){
                var MSRequestOptions = {hostname: data, method: 'POST'};
                var MSRequest = https.request(MSRequestOptions, function(MSResponse){
                    MSResponse.on('end', function () {
                            console.log("MSResponse.on(end)");//>>>
                    });//end MSResponse.on(end)
                }); //end MSRequest
                delayedMSStream.pipe(MSRequest);
            });
        });

        clientRequest.on('data', function (chunk) {
            buffer.push(chunk);
        });

        clientRequest.on('end', function () {//when done streaming audio
            buffer.push(null);
        }); 
    });//end router.post('/')

解释：客户端向我的服务器发送 POST 请求流式音频，我的服务器从 请求 url example.com，当example.com响应 url 时，我的服务器将音频流式传输到它。

有什么更聪明的方法来做到这一点？

Answer 1

所以如果我正确理解代码，你：

• 收到请求，
• 向远程端点发出您自己的请求并获取 URL
• 向该 URL 发出新请求并将其传送到原始响应。

除了你的方法之外，还有其他方法可以做到这一点，如果你稍微改进一下命名，即使你的方法对我来说也会看起来更干净。此外，将巨大的请求分成几个职责范围较小的功能可能会有所帮助。

我会这样设置端点：

let http = require('http');
let https = require('https');
let Readable = require('stream').Readable;
let router = require('express').Router();
let buffer = [];

/**
 * Gets some data from a remote host. Calls back when done.
 * We cannot pipe this directly into your stream chain as we need the complete data to get the end result.
 */
function getHostname(cb) {

  https.request({

    hostname: 'example.com'
  }, function(response) {

    let data = '';
    response.on('error', err => cb(err)); // shortened for brewity
    response.on('data', function(chunk) {

        data = data + chunk;
    });
    response.on('end', function() {

      // we're done here.
      cb(null, data.toString());
    });
  });
}

router.post('/', function(request, response) {

  // first let's get that url.
  getHostname(function(err, hostname) {

    if (err) { return response.status(500).end(); } 

    // now make that other request which we can stream.
    https.request({

      hostname: hostname,
      method: 'POST'
    }, function(dataStream) {

        dataStream.pipe(response);
    });
  });
});

现在，正如评论中所说，使用streams2，您不必管理您的流。在 0.10 之前的节点版本中，您必须监听“读取”、“数据”等事件，而在较新的节点版本中，它会得到处理。此外，您在这里甚至不需要它，流足够智能，可以自行处理背压。