node.js - HTTP2/SPDY推流验证 : How to Test?

Question

我正在使用 Node 模块实现 HTTP2/SPDY 推送资源 spdy 。我已关注indutny's doc并一直在进行测试运行，将他的示例实现到我的 server.js 中。

问题有两个方面；我在日志中没有收到任何错误，也没有在浏览器中看到警报。我在开发者控制台中也没有看到任何变化。如果我设置了一个虚假的推送 URL，我不会收到任何响应/错误等。我相信理论上，优先级应该从中更改为高(？)。 See Screen shoot.

还有其他方法可以让我测试是否向浏览器推送吗？或者，我的脚本是否有问题(请检查是否有不一致)？另外，要在 stream.on('error', function() {}); 中抛出什么？

在 Chrome(在 ChromeBook 上)、nodejs v5.1.0、npm v3.3.12 中进行测试 - 在 Chrome 中验证了启用 H2。

server.js:

var environment = '../env/' + process.env.NODE_ENV
    // Process User config
  , fS = require('fs')
  , jsonFile = fS.readFileSync(environment + '/config.json')
  , jsonString, hostIp, hostPort, cacheExp, cps;

    try {
      jsonString              = JSON.parse(jsonFile);
      var SERV_HOST           = jsonString['hostIp']
        , SERV_PORT           = jsonString['hostPort']
        , CACHE_EXP           = jsonString['cacheExp']
        , CPS                 = jsonString['cps']
        , xPowerBy            = 'OceanPress'
        , xFrameOptions       = 'DENY'
        , xXSSProtection      = '1; mode=block'
        , xContentTypeOption  = 'nosniff';
    } catch (err) {
      console.log('There is an error parsing the json file : ' + err);
    }

// Load modules
var fs          = require('fs')
  , watch       = require('staticsmith-watch')
  , buffet      = require('buffet')({root: environment + '/_public'})
  , spdy        = require('spdy')
    // spdy options
  , options = {
      key: fs.readFileSync(environment + '/keys/key.pem')
    , cert: fs.readFileSync(environment + '/keys/cert.pem')
    // SPDY-specific options
    , spdy: {
          protocols: [ 'h2','spdy/3.1', 'spdy/3', 'spdy/2','http/1.1', 'http/1.0' ]
        , plain: false
        , maxStreams: 200
        , connection: {
              windowSize: 1024 * 1024
            , autoSpdy31: false
          }
      }
      // Set ip and port
    , host:   SERV_HOST
    , port:   SERV_PORT
  }
    // Security header options
  , security  = [
      { name:   'X-Powered-By',
        option: xPowerBy }
    , { name:   'x-frame-options',
        option: xFrameOptions }
    , { name:   'X-XSS-Protection',
        option: xXSSProtection }
    , { name:   'X-Content-Type-Options',
        option: xContentTypeOption }
    , { name:   'Cache-Control',
        option: CACHE_EXP }
    , { name:   'Content-Security-Policy',
        option: CPS }
    , { name:   'server',
        option: 'Who knows' }
  ];

if (process.env.NODE_ENV == 'production') {

  spdy.createServer(options, function(req, res) {

    // Add Content Security Rules
    for(var i = 0; i < security.length; i++) {
      res.setHeader(security[i].name, security[i].option);
    }

    // @see https://www.npmjs.com/package/buffet
    buffet(req, res, function (err, result) {

      // Push JavaScript asset (main.js) to the client
      var stream = res.push('/js/main.js', {
        req: {'accept': '*/*'},
        res: {'content-type': 'application/javascript'}
      });
      stream.on('acknowledge', function() {
          console.log("Stream ACK");
      });
      stream.on('error', function() {
        console.error("stream ERR");
      });
      stream.end('alert("hello from push stream!");');
      // write main response body and terminate stream
      res.end('<script src="/js/main.js"></script>');

      // There was an error serving the file? Throw it!
      if (err) {
        console.error("Error serving " + req.url + " - " + err.message);
        // Respond to the client
        res.writeHead(err.status, err.headers);
      }
    });
  }).listen(options.port, options.host);

  console.log("serving at https://" + options.host + ":" + options.port);
  console.log("On Node v" + process.versions.node);
  console.log("On npm v" + process.versions.npm);

  watch({
    pattern:    '**/*',
    livereload: true,
  });
}

更新:我还添加了:

  stream.on('acknowledge', function() {
      console.log('stream ACK');
  });

没有写入控制台日志 - 就像该函数已死一样。

带有推送流的开发控制台 (main.js):

Answer 1

这里有一些问题。

1. 仅当请求的 URL 与磁盘上的文件不匹配时，才会调用自助餐回调。就像 Express 中间件一样，它本质上是一个 next 函数。因此，你实际上并没有插入任何事情。

2. res.push 的第一个参数是 URL，而不是文件系统路径。

3. res.push 在 ≤ HTTP/1.1 连接上不会存在；您需要确保它在那里，否则您将抛出未捕获的异常(并崩溃)。

这是一个简化的工作示例。

spdy.createServer({
    key: fs.readFileSync('./s.key'),
    cert: fs.readFileSync('./s.crt')
}, function(req, res) {

    if (req.url == '/') {
        res.writeHead(200, { 'Content-Length': 42 });
        res.end('<h1>Hi</h1><script src="main.js"></script>');

        if (res.push) {

            // Push JavaScript asset (main.js) to the client
            var stream = res.push('/main.js', {
                req: {'accept': '**/*'},
                res: {'content-type': 'application/javascript'}
            });

            stream.on('error', function() {
                console.error(err);
            });
            stream.end('alert("hello from push stream!");');
        }
    } else {
        res.writeHead(404);
        res.end();
    }



}).listen(777);

<小时/>

要在 Chrome 中实际验证内容是否已推送，请打开一个新选项卡并输入 chrome://net-internals/#http2。单击与您的服务器的 HTTP/2 session 的 ID，然后单击左侧 Pane 中的 session 。与初始请求混合，您会看到类似以下内容:

t=  3483 [st=    19]  HTTP2_SESSION_RECV_PUSH_PROMISE
                      --> :method: GET
                          :path: /main.js
                          :scheme: https
                          :authority: localhost:777
                      --> id = 3
                      --> promised_stream_id = 4
t=  3483 [st=    19]  HTTP2_SESSION_RECV_HEADERS
                      --> fin = false
                      --> :status: 200
                      --> stream_id = 4
t=  3483 [st=    19]  HTTP2_SESSION_RECV_DATA
                      --> fin = true
                      --> size = 0
                      --> stream_id = 4
t=  3546 [st=    82]  HTTP2_STREAM_ADOPTED_PUSH_STREAM
                      --> stream_id = 4
                      --> url = "https://localhost:777/main.js"

(我没有在开发工具中看到 main.js 的优先级发生变化——它仍然是中等。)