python tornado是什么?怎么用?

Tornado是Python的异步Web框架,适合高并发场景。它基于非阻塞I/O和事件循环,支持WebSocket、实时推送和大量并发连接。使用pip install tornado安装,通过tornado.web.Application定义路由,支持路径参数与多HTTP方法。推荐用async/await语法实现异步处理,避免阻塞主线程。可配置template_path和static_path以使用模板和静态文件,通过render()渲染页面。原生支持WebSocket,适用于实时通信应用。生产环境建议结合Nginx反向代理,使用supervisord管理进程,并通过bind()+start(n)启动多进程提升性能。核心要点是避免同步阻塞代码,正确启动IOLoop,充分发挥其异步优势。

Tornado 是一个基于 Python 的开源 Web 框架和异步网络库,最初由 FriendFeed 开发。它最大的特点是使用非阻塞 I/O 实现高性能,特别适合长连接、实时服务(如 WebSocket)和需要处理大量并发连接的场景。

与 Django 或 Flask 这类同步框架不同,Tornado 能通过单线程处理成千上万的并发连接,这得益于它的事件循环机制。因此,如果你要做聊天应用、实时推送系统或高并发 API 服务,Tornado 是个不错的选择。

基本安装

使用 pip 安装 Tornado:

pip install tornado

写一个简单的 Web 应用

下面是一个最基础的 “Hello, World” 示例:

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) print("Server starting on https://www./link/4f10ac32425eaa39b2f93cd9c67ff456") tornado.ioloop.IOLoop.current().start()

运行后访问 https://www./link/4f10ac32425eaa39b2f93cd9c67ff456 就能看到返回内容。

路由与请求处理

Tornado 使用元组列表定义 URL 路由,格式为 (路径, 处理类)。你可以提取路径参数:

class UserHandler(tornado.web.RequestHandler):
    def get(self, user_id):
        self.write(f"User ID: {user_id}")

路由

(r"/user/(\d+)", UserHandler)

支持的方法包括 get()、post()、put()、delete() 等,按需实现即可。

异步处理(关键优势)

使用 @tornado.web.asynchronous 或更推荐的 async/await 语法来写异步接口:

import tornado.gen
import tornado.web
import tornado.httpclient
import asyncio

class AsyncHandler(tornado.web.RequestHandler): async def get(self): http_client = tornado.httpclient.AsyncHTTPClient() try: response = await http_client.fetch("https://www./link/4d2fe2e8601f7a8018594d98f28706f2") self.write(response.body) except Exception as e: self.set_status(500) self.write(f"Error: {e}")

这样不会阻塞主线程,能同时处理多个请求。

使用模板和静态文件

项目结构建议:

project/
├── app.py
├── templates/
│   └── index.html
└── static/
    └── style.css

配置模板和静态文件目录:

app = tornado.web.Application(
    handlers=[
        (r"/", MainHandler),
    ],
    template_path="templates",
    static_path="static"
)

在 RequestHandler 中使用 render() 方法渲染模板:

class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.render("index.html", message="Hello from Tornado")

WebSocket 支持

Tornado 原生支持 WebSocket,适合做实时通信:

class EchoWebSocket(tornado.websocket.WebSocketHandler):
    def open(self):
        print("WebSocket opened")
def on_message(self, message):
    self.write_message(f"You said: {message}")

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

路由

(r"/ws", EchoWebSocket)

部署建议

开发阶段可以直接运行脚本。生产环境建议:

  • 使用 Nginx 做反向代理
  • 启动多个 Tornado 实例绑定不同端口
  • 用 supervisord 管理进程
  • 开启多进程模式(.bind() + .start(n))

示例:

if __name__ == "__main__":
    app = make_app()
    app.bind(8888)
    app.start(4)  # 启动 4 个进程
    tornado.ioloop.IOLoop.current().start()

基本上就这些。Tornado 不复杂但容易忽略细节,比如别忘了启动 IOLoop,也别在 handler 里写阻塞代码。掌握好异步编程模型,就能发挥它的真正性能优势。