Tornado 开源项目教程

项目介绍

Tornado 是一个 Python 网络框架和异步网络库，最初由 FriendFeed 开发。通过使用非阻塞网络 I/O，Tornado 可以扩展到数万个开放连接，使其非常适合长轮询、WebSockets 和其他需要与每个用户保持长时间连接的应用程序。

项目快速启动

安装 Tornado

首先，确保你已经安装了 Python 3.8 或更高版本。然后，使用 pip 安装 Tornado：

pip install tornado

创建一个简单的 Tornado 应用

创建一个名为 app.py 的文件，并添加以下代码：

import tornado.ioloop
import tornado.web

class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.write("Hello, world")

def make_app():
    return tornado.web.Application([
        (r"/", MainHandler),
    ])

if __name__ == "__main__":
    app = make_app()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

运行应用：

python app.py

打开浏览器，访问 http://localhost:8888，你应该会看到 "Hello, world" 的输出。

应用案例和最佳实践

长轮询示例

长轮询是一种实现实时 Web 应用的技术。以下是一个简单的长轮询示例：

import tornado.ioloop
import tornado.web
import time

class LongPollingHandler(tornado.web.RequestHandler):
    async def get(self):
        await tornado.gen.sleep(5)  # 模拟长时间处理
        self.write("Long polling response")

def make_app():
    return tornado.web.Application([
        (r"/longpoll", LongPollingHandler),
    ])

if __name__ == "__main__":
    app = make_app()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

WebSocket 示例

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议。以下是一个简单的 WebSocket 示例：

import tornado.ioloop
import tornado.web
import tornado.websocket

class WebSocketHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        print("WebSocket opened")

    def on_message(self, message):
        self.write_message(u"You said: " + message)

    def on_close(self):
        print("WebSocket closed")

def make_app():
    return tornado.web.Application([
        (r"/websocket", WebSocketHandler),
    ])

if __name__ == "__main__":
    app = make_app()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

典型生态项目

集成其他服务

Tornado 可以与其他服务和框架集成，例如：

• Tornado-Redis: 用于与 Redis 进行异步交互的库。
• Tornado-MySQL: 用于与 MySQL 进行异步交互的库。
• Tornado-Celery: 用于与 Celery 任务队列进行集成的库。

异步 DNS 解析

Tornado 支持使用 pycares 进行异步 DNS 解析，这对于避免线程阻塞非常有用。

import tornado.ioloop
import tornado.platform.caresresolver

tornado.platform.caresresolver.install()

async def resolve():
    resolver = tornado.platform.caresresolver.CaresResolver()
    ips = await resolver.resolve("www.example.com", 80)
    print(ips)

tornado.ioloop.IOLoop.current().run_sync(resolve)

通过这些示例和集成，你可以充分利用 Tornado 的异步特性来构建高性能的 Web 应用。