当前位置：首页 > news >正文

Tornado异步框架

news 2025/8/16 21:02:59

简介：

tornado是Python的web框架。
tornado和主流的web服务器框架有明显的区别：
它是非阻塞式服务器，而且速度非常快，得力于其非阻塞的方式和epoll的运用
tornado可以每秒处理数以千计的连接（号称）

基本配置

1. app文件

包含__init__.py文件和视图文件
init文件是为了让文件变成模块导包使用

import tornado.web
from db.models import UserModelimport os
import sys# 模块导包
base_path = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
sys.path.append(base_path)
sys.path.append(os.path.join(base_path, "config"))from config.config import SECRET_KEYdef md5(password):import hashlibmd5 = hashlib.md5()password += SECRET_KEYmd5.update(password.encode("utf-8"))sign = md5.hexdigest()return sign# 视图
# tornado视图以Handler结尾
# 视图继承tornado.web.RequestHandler
class UserHandler(tornado.web.RequestHandler):# 由于是异步框架 方法async开头async def get(self):username = self.get_argument("username", None)  # None非空校验password = self.get_argument("password")print(username, password)if not all([username, password]):return self.finish({"code": 400,"msg": "数据不能为空"})# 重复校验user = UserModel.select().where(UserModel.username == username)if user:return self.finish({"code": 400,"msg": "用户名已注册"})password = md5(password)print(password)UserModel.create(username=username, password=password)return self.finish({"code": 200,"msg": "注册成功"})# 声明tornado实例
app = tornado.web.Application(# handlers路由 列表形式handlers=[# r非转义字符(r"/", UserHandler),],debug=True
)

视图继承tornado.web.RequestHandler
接收前端参数self.get_argument("")
由于是异步框架方法用async开头
返回值self.finish()
声明tornado实例，tornado.web.Application(handlers=[(r"/",视图名)])
debug=True 自动重启

2. config文件

包含init文件和config.py

# 配置文件
MYSQL_HOST = "127.0.0.1"
MYSQL_USER = "root"
MYSQL_PASSWORD = "123456"
MYSQL_PORT = 3306
SECRET_KEY = "njxdsncjnds"

主要是放置一些配置信息

3. db文件

包含init文件、db.py、model.py
db.py主要是连接数据库
model.py写模型类

db.py

# 连接数据库
import peewee_async
import sys
import os# 从上级目录导入
# sys.path.append("..")# 系统化模块导包
base_path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(base_path)
sys.path.append(os.path.join(base_path, "config"))from config import configprint(config.MYSQL_HOST)database = peewee_async.PooledMySQLDatabase(database="videosite",user=config.MYSQL_USER,password=config.MYSQL_PASSWORD,host=config.MYSQL_HOST,port=config.MYSQL_PORT
)

通过python中的ORM包peewee_async来创建连接数据库
peewee_async.PooledMysqlDatabase()连接数据库

model.py

from datetime import datetime
import peewee# 设置模块路径
import os
import sys# 设置根路径
# base_dir1 = os.path.abspath(__file__)  # 执行文件的路径
# base_dir2 = os.path.dirname(os.path.abspath(__file__))  # 执行文件的上一层
base_path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))  # 执行文件的上上一层print(base_path)
sys.path.append(base_path)
sys.path.append(os.path.join(base_path, "db"))from db.db import database# 创建基类数据库
class BaseModel(peewee.Model):__abstract__ = Trueid = peewee.IntegerField(primary_key=True, unique=True, constraints=[peewee.SQL("AUTO_INCREMENT")])create_time = peewee.DateField(default=datetime.now, verbose_name="创建时间")class Meta:database = databaseclass UserModel(BaseModel):username = peewee.CharField(max_length=128, unique=True)password = peewee.CharField(max_length=128)class Meta:database = database  # 指定数据库入口db_table = "user"# if __name__ == '__main__':# 创建表# UserModel.create_table()# UserModel.drop_table(True)# 添加数据库# UserModel.create(username="张三", password="123")

创建表是继承peewee.Model
peewee.Model是父类
BaseModel继承父类是他的子类
UserModel继承BaseModel是他们的超类
创建表：UserModel.create_table(True)
删除表：UserModel.drop_table(True)
添加表：UserModel.create()
必须指定数据库连接入口：database=database

4. .gitignore文件

上传git时不需要上传的文件，保护隐私

5. main.py 入口文件

入口文件整个tornado项目的重点
启动项目就是这个文件

# 单一入口文件
import tornado.web# 服务包
from tornado import httpserver# 模块导包
import os
import sysbase_path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
sys.path.append(base_path)
sys.path.append(os.path.join(base_path, "app"))from app.user import appif __name__ == '__main__':# 建立服务server = httpserver.HTTPServer(app, xheaders=True)# 打印tornado服务，启动不显示print("Tornado后台服务已启动")# 监听端口 服务.listen(端口号) 端口号随便写server.listen(5050)# 启动tornado.ioloop.IOLoop.instance().start()