NodeJS, WebSockets, upgrade head



我在玩NodeJS和WebSockets,有一个带有head参数的升级事件,我从这里了解到,它基本上是data that directly trails the headers,但对于我的用例,它总是空的,所以我真的不知道它意味着什么,如果有人能提供一个简单的用例,其中升级事件中的数据参数不是空的,我会很高兴。

查看节点回购中发出升级事件的源,您将看到以下实现:

  function socketOnData(d) {
    assert(!socket._paused);
    debug('SERVER socketOnData %d', d.length);
    var ret = parser.execute(d);
    onParserExecuteCommon(ret, d);
  }
  function onParserExecute(ret, d) {
    debug('SERVER socketOnParserExecute %d', ret);
    onParserExecuteCommon(ret, undefined);
  }
  function onParserExecuteCommon(ret, d) {
    if (ret instanceof Error) {
      debug('parse error');
      socket.destroy(ret);
    } else if (parser.incoming && parser.incoming.upgrade) {
      // Upgrade or CONNECT
      var bytesParsed = ret;
      var req = parser.incoming;
      debug('SERVER upgrade or connect', req.method);
      if (!d)
        d = parser.getCurrentBuffer();
      socket.removeListener('data', socketOnData);
      socket.removeListener('end', socketOnEnd);
      socket.removeListener('close', serverSocketCloseListener);
      unconsume(parser, socket);
      parser.finish();
      freeParser(parser, req, null);
      parser = null;
      var eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
      if (EventEmitter.listenerCount(self, eventName) > 0) {
        debug('SERVER have listener for %s', eventName);
        var bodyHead = d.slice(bytesParsed, d.length);
        // TODO(isaacs): Need a way to reset a stream to fresh state
        // IE, not flowing, and not explicitly paused.
        socket._readableState.flowing = null;
        self.emit(eventName, req, socket, bodyHead);
...

传递的参数bodyHead反映了socketOnData函数上传递参数d的数据,该函数是默认的套接字data事件处理程序。另一方面,如果从onParserExecute调用onParserExecuteCommon,则可能是undefined。我必须更多地查看源代码,以了解哪些情况适用,具体取决于服务器的实现方式。也许您可以启用调试日志来查看正在调用哪些方法。

相关内容

  • 没有找到相关文章

最新更新