HTTP/2: stream.end using For-Loop

Question

如何在for-loop中关闭流

我正在通过读取.json配置文件，尝试在循环中使用HTTP/2资源push-stream。如果resurce.file,type中只有一个资源，则推送成功。如果配置中有多个资源，则只推送列出的第一个资源，而不推送其余资源&客户端永远不会接收到剩余的文件，也不会完成解析。

我认为只有第一个资源流结束，其余的开放流没有关闭。

我认为代码应该正常工作，我认为这是最好的：

// Verify if client can be pushed to:
if (res.push) {
  // Read what resources should be pushed via config.json5:
  for(var i = 0; i < confg.resource.length; i++) {
    // Compare what URL requested the resources & pass the relevant files:
    if (req.url == confg.resource[i].url) {
      // Request the resource(s) to stream:
      var ps  = fs.readFileSync('../build' + confg.resource[i].file)
          // Push the relevant resource stream(s):
        , stream = res.push(confg.resource[i].file
        , { // ..and set the content type;
            res: {'content-type': confg.resource[i].type},
          });
      // Close the resource stream(s):
      stream.end(ps, function() {
        // TODO(CelticParser): Remove for production ->v
        console.log("Pushed Sream");
      });
    }
  }
}

.config.json5:

resource: [ // HTTP/2 Push-Streams
  { file: '/js/theme.min.js',
     type: 'script'
  },
  { file: '/css/theme.min.css',
    type: 'style',
    url:  '/'
  }
]

使用上面的示例

如果配置中/js/theme.min.js列在第一位，/css/theme.min.css列在第二位，则浏览器将加载/js/theme.min.js，其他文件将不会加载，客户端将挂起（不会继续解析）。如果资源的列表顺序被交换，同样的事情也会发生。如果配置中只列出了一个文件，那么一切都会按预期进行。

任何帮助都将不胜感激。

Answer 1

问题出现在config.json5中。在将文件传递到此处之前，您正在检查请求的url：

// Compare what URL requested the resources & pass the relevant files:
if (req.url == confg.resource[i].url) {
   ...
}

但在json中，只有一个项目可以通过测试，另一个项目缺少url属性。将您的配置更改为此（将url: '/'添加到第一项），它将起作用：

{
   resource : [
      { 
         file : '/js/theme.min.js',
         type : 'script',
         url  :  '/'
      },
      { 
         file : '/css/theme.min.css',
         type : 'style',
         url  :  '/'
      }
   ]
}

按照http2服务器示例，使用这个小型应用程序进行了测试，还使用了您的服务器代码。

server.js

var fs      = require("fs");
var path    = require("path");
var http2   = require("http2");
var config  = require("./config.json");
var options = {
    key  : fs.readFileSync("./localhost.key"),
    cert : fs.readFileSync("./localhost.crt")
};
//----------------------------------------------------
http2.createServer(options, function(req, res) {
    if (res.push) {
        config.resource.forEach(function(resource){
            if (req.url === resource.url) {
                var push = res.push(resource.file, { res: {"content-type": resource.type } });
                push.writeHead(200);
                fs.createReadStream(path.join("../build", resource.file)).pipe(push);
            }
        });
    }
    res.writeHead(200);
    res.end();
}).listen(8080);

config.json文件包含上述已更正的配置。

输出：

Receiving pushed resource: ./js/bootstrap.min.js -> /Developer/so/tests/push-0
Receiving pushed resource: ./css/bootstrap.min.css -> /Developer/so/tests/push-1