Node http createServer過程源碼解讀

seal_de 發(fā)布于2019-08-21 15:18 / 2804人閱讀

摘要：在函數(shù)中，觸發(fā)了事件。的來源的來源來自的形參而來自的。在方法中在里調(diào)用中有對(duì)方法的調(diào)用，也就是說，當(dāng)調(diào)用，會(huì)出發(fā)，進(jìn)一步觸發(fā)，發(fā)出和，觸發(fā)也就是傳入的回調(diào)函數(shù)

node的入門就會(huì)寫這樣幾行簡(jiǎn)單的代碼，而createServer的過程究竟發(fā)生什么

const http = require("http");
const server = http.createServer((req, res) => {
  res.statusCode = 200;
  res.setHeader("Content-Type", "text/plain");
  res.end("Hello World
");
});

server.listen(() => {
  console.log(`Server is running `);
});

問題1：request和response是什么

首先在http.js代碼中

const Server = exports.Server = server.Server;

exports.createServer = function(requestListener) {
  return new Server(requestListener);
};

createServer做的事情很簡(jiǎn)單，只是new一個(gè)Server的實(shí)例，傳入回調(diào)函數(shù)，并返回server

const server = require("_http_server");可以看到server來自_http_server

function Server(requestListener) {
  if (!(this instanceof Server)) return new Server(requestListener);
  net.Server.call(this, { allowHalfOpen: true });
  if (requestListener) {
    this.addListener("request", requestListener);
  }
  this.httpAllowHalfOpen = false;
  this.addListener("connection", connectionListener);
  this.timeout = 2 * 60 * 1000;
  this._pendingResponseData = 0;
}
util.inherits(Server, net.Server);

Server.prototype.setTimeout = function(msecs, callback) {
  this.timeout = msecs;
  if (callback)
    this.on("timeout", callback);
  return this;
};

exports.Server = Server;

Server繼承net.Server，且requestListener，作為"request"事件的監(jiān)聽器。

在resOnFinish函數(shù)中，self.emit("request", req, res);觸發(fā)了request事件。

res的來源
var res = new ServerResponse(req);

req的來源

req來自parserOnIncoming的形參；
parser.onIncoming = parserOnIncoming.bind(undefined, this, socket, state);而parser來自_http_common的parsers.alloc()。

在方法parserOnHeadersComplete中skipBody = parser.onIncoming(parser.incoming, shouldKeepAlive);傳入了request，
parser.incoming = new IncomingMessage(parser.socket);說明傳入的request是IncomingMessage的實(shí)例

IncomingMessage = require("_http_incoming").IncomingMessage;
_http_incoming中可以看到util.inherits(IncomingMessage, Stream.Readable)；所以IncomingMessage是繼承自Stream.Readable

問題2:什么時(shí)候執(zhí)行回調(diào)函數(shù)

connectionListener中有parser.onIncoming = parserOnIncoming.bind(undefined, this, socket, state);

在server的初始化時(shí)

this.on("request", requestListener);注冊(cè)request時(shí)加上執(zhí)行回調(diào)操作

this.on("connection", connectionListener);注冊(cè)connection的Listener

parserOnIncoming方法中 server.emit("request", req, res);發(fā)出request；最后在parserOnHeadersComplete方法中調(diào)用onIncoming，也就是server里的parserOnIncoming

那么什么時(shí)候會(huì)發(fā)出connection操作呢？

在net.js中的onconnection方法中self.emit("connection", socket);。

在_listen2方法中this._handle.onconnection = onconnection;

在listen里調(diào)用listen2self._listen2(address, port, addressType, backlog, fd);

Server.prototype.listen = function() 中有對(duì)listen方法的調(diào)用，也就是說，當(dāng)server調(diào)用listen，會(huì)出發(fā)connectionListener，進(jìn)一步觸發(fā)parserOnIncoming，發(fā)出request和response，觸發(fā)requestListener也就是傳入的回調(diào)函數(shù)