我在玩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
。我必须更多地查看源代码,以了解哪些情况适用,具体取决于服务器的实现方式。也许您可以启用调试日志来查看正在调用哪些方法。