Tornado HTTP服务器的基本流程

def listen(self, port, address=""):    sockets = bind_sockets(port, address=address)    self.add_sockets(sockets)def bind_sockets(port, address=None, family=socket.AF_UNSPEC, backlog=128):    # 省略sockets创建，address，flags处理部分代码    for res in set(socket.getaddrinfo(address, port, family, socket.SOCK_STREAM,                                  0, flags)):        af, socktype, proto, canonname, sockaddr = res        # 创建socket        sock = socket.socket(af, socktype, proto)        # 设置socket属性，代码省略        sock.bind(sockaddr)        sock.listen(backlog)        sockets.append(sock)    return socketsdef add_sockets(self, sockets):    if self.io_loop is None:        self.io_loop = IOLoop.instance()    for sock in sockets:        self._sockets[sock.fileno()] = sock        add_accept_handler(sock, self._handle_connection,                           io_loop=self.io_loop)def add_accept_handler(sock, callback, io_loop=None):    if io_loop is None:        io_loop = IOLoop.instance()    def accept_handler(fd, events):        while True:            try:                connection, address = sock.accept()            except socket.error, e:                if e.args[0] in (errno.EWOULDBLOCK, errno.EAGAIN):                    return                raise            # 当有连接被accepted时callback会被调用            callback(connection, address)    io_loop.add_handler(sock.fileno(), accept_handler, IOLoop.READ)def _handle_connection(self, connection, address):    # SSL部分省略    try:        stream = IOStream(connection, io_loop=self.io_loop)        self.handle_stream(stream, address)    except Exception:        logging.error("Error in connection callback", exc_info=True)

这里分析HTTPServer通过listen函数启动监听，这种方法是单进程模式。另外可以通过先后调用bind和start(num_processes=1)函数启动监听同时创建多进程服务器实例，后文有关于此的详细描述。

bind_sockets在启动监听端口过程中调用，getaddrinfo返回服务器的所有网卡信息, 每块网卡上都要创建监听客户端的请求并返回创建的sockets。创建socket过程中绑定地址和端口，同时设置了fcntl.FD_CLOEXEC（创建子进程时关闭打开的socket）和socket.SO_REUSEADDR（保证某一socket关闭后立即释放端口，实现端口复用）标志位。sock.listen(backlog=128)默认设定等待被处理的连接最大个数为128。

返回的每一个socket都加入到IOLoop中同时添加回调函数_handle_connection，IOLoop添加对相应socket的IOLoop.READ事件监听。_handle_connection在接受客户端的连接处理结束之后会被调用，调用时传入连接和ioloop对象初始化IOStream对象，用于对客户端的异步读写；然后调用handle_stream，传入创建的IOStream对象初始化一个HTTPConnection对象，HTTPConnection封装了IOStream的一些操作，用于处理HTTPRequest并返回。至此HTTP Server的创建、启动、注册回调函数的过程分析结束。

HTTPConnection分析

该类用于处理http请求。在HTTPConnection初始化时对self.request_callback赋值为一个可调用的对象（该对象用于对http请求的具体处理和应答）。该类首先读取http请求中header的结束符b(“\r\n\r\n”)，然后回调self._on_headers函数。request_callback的相关实现在以后的系列中有详细介绍。

def __init__(self, stream, address, request_callback, no_keep_alive=False,                 xheaders=False):    self.request_callback = request_callback    # some configuration code    self._header_callback = stack_context.wrap(self._on_headers)    self.stream.read_until(b("\r\n\r\n"), self._header_callback)def _on_headers(self, data):    # some codes    self.request_callback(self._request)

多进程HTTPServer

Tornado的HTTPServer是单进程单线程模式，同时提供了创建多进程服务器的接口，具体实现是在主进程启动HTTPServer时通过process.fork_processes(num_processes)产生新的服务器子进程，所有进程之间共享端口。fork_process的方法在process.py中实现，十分简洁。对fork_process详细的分析，可以参考 番外篇：Tornado的多进程管理分析。

FriendFeed使用nginx提供负载均衡、反向代理服务并作为静态文件服务器，在后端服务器上可以部署多个Tornado实例。一般可以通过Supervisor控制Tornado app，然后再通过nginx对Tornado的输出进行反向代理。 具体可以参考下这篇文章： Supervisord进程管理工具的安装使用。

原文地址：Tornado HTTP服务器的基本流程, 感谢原作者分享。 发光并非太阳的专利，你也可以发光