时间:2021-05-22
Tornado
Tornado 是一款非阻塞可扩展的使用Python编写的web服务器和Python Web框架, 可以使用Tornado编写Web程序并不依赖任何web服务器直接提供高效的web服务.所以Tornado不仅仅是一个web框架而且还是一款可以用于生产环境的高效的web服务器
Torando 在Linux和FreeBSD上使用高效的异步I/O模型 epoll 和kqueue来实现高效的web服务器, 所以 tornado在Linux上和FreeBSD系列性能可以达到最高
接口
当然我们可以不仅仅把Tornado看作是一个web框架和web服务器, 我们可以利用Tornado提供的接口进行高效的网络异步编程,
tornado.ioloop.IOLoop 提供了三个接口可以用于网络编程:
add_handler用于添加socket到主循环中, 接受三个参数: fd 是socket的文件描述符 handler 是处理此socket的 callback函数 * events 是此socket注册的事件
update_handler用于更新住循环中已存在的socket响应事件, 接受两个参数: fd 是socket对应的文件描述符 events 是注册的新事件
remove_handler用于移除主循环中已存在的socket
事件
tornado.ioloop.IOLoop同时提供了4种响应事件:
实例
根据上面的接口和事件我们就可以写出一个简单的 echo server
#!/usr/bin/env python# -*- coding:utf-8 -*-## Author : cold# E-mail : wh_linux@126.com# Date : 13/04/15 15:08:51# Desc : Tornado Echo Server# HOME : http://#import Queueimport socketfrom functools import partialfrom tornado.ioloop import IOLoopsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)sock.setblocking(0) # 将socket设置为非阻塞server_address = ("localhost", 10000)sock.bind(server_address)sock.listen(5)fd_map = {} # 文件描述符到socket的映射message_queue_map = {} # socket到消息队列的映射fd = sock.fileno()fd_map[fd] = sockioloop = IOLoop.instance()def handle_client(cli_addr, fd, event): s = fd_map[fd] if event & IOLoop.READ: data = s.recv(1024) if data: print " received '%s' from %s" % (data, cli_addr) # 接收到消息更改事件为写, 用于发送数据到对端 ioloop.update_handler(fd, IOLoop.WRITE) message_queue_map[s].put(data) else: print " closing %s" % cli_addr ioloop.remove_handler(fd) s.close() del message_queue_map[s] if event & IOLoop.WRITE: try: next_msg = message_queue_map[s].get_nowait() except Queue.Empty: print "%s queue empty" % cli_addr ioloop.update_handler(fd, IOLoop.READ) else: print 'sending "%s" to %s' % (next_msg, cli_addr) s.send(next_msg) if event & IOLoop.ERROR: print " exception on %s" % cli_addr ioloop.remove_handler(fd) s.close() del message_queue_map[s]def handle_server(fd, event): s = fd_map[fd] if event & IOLoop.READ: conn, cli_addr = s.accept() print " connection %s" % cli_addr[0] conn.setblocking(0) conn_fd = conn.fileno() fd_map[conn_fd] = conn handle = partial(handle_client, cli_addr[0]) # 将cli_addr作为第一个参数 # 将连接和handle注册为读事件加入到 tornado ioloop ioloop.add_handler(conn_fd, handle, IOLoop.READ) message_queue_map[conn] = Queue.Queue() # 创建对应的消息队列ioloop.add_handler(fd, handle_server, IOLoop.READ)ioloop.start()上面代码就建立了一个非阻塞的高效的异步的echo server
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
我们继续学习Python异步编程,这里将介绍异步Web框架sanic,为什么不是tornado?从框架的易用性来说,Flask要远远比tornado简单,可惜f
Python的Web框架中Tornado以异步非阻塞而闻名。本篇将使用200行代码完成一个微型异步非阻塞Web框架:Snow。一、源码本文基于非阻塞的Socke
tornado即是一个http非阻塞服务器,就要用起来,我们将用到tornado框架,mongodb数据库以及motor(mongodb的异步驱动).来简单实现
安装Tornado省事点可以直接用grequests库,下面用的是tornado的异步client。异步用到了tornado,根据官方文档的例子修改得到一个简单
Tornado是一种Web服务器软件的开源版本。Tornado和主流Web服务器框架(包括大多数Python的框架)有着明显的区别:它是非阻塞式服务器,而且速度