Tornado入门与实践（包含接口小项目）

淩亂°似流年 2022-01-17 05:29 354阅读 0赞

# 使用pip安装：pip install tornado #

验证是否安装成功，输出tornado的版本号  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70]  
克隆Tornado的源代码  
![在这里插入图片描述][2019061220352728.png]

# 先注册一个api的管理工具 #

Api的管理工具：[https://apizza.net/pro/\#/][https_apizza.net_pro]  
注册完然后登陆进去：点击右上角新建项目

# 建议直接下载apizza #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 1]  
Tornado构建RESTful应用  
1什么是RESTful  
全称：Representational State Transfer  
是HTTP协议（1.0和1.1）的主要设计者Roy Thomas Fielding提出  
资源（Resources） 表现层（Representational ）状态转化（State Transfer）  
是实现API的一种风格  
2 RESTful风格  
Resources（资源）：使用URL指向一个实体，例如：网页是资源，媒体也是资源  
Representational （表现层）：资源的表现形式，例如：图片，HTML文本等  
State Transfer（状态转化）：GET, POST, PUT, DELETE HTTP动词操作资源  
例如后端的增删改查，增删改查可以和http请求联系起来

# 3常用HTTP动词 #

RESTful解释：  
GET, POST, PUT, DELETE 分别用来 获取，新建，更新，删除资源  
幂等性：GET, PUT, DELETE  
幂等性是指无论一次还是多次操作都具有一样的副作用  
POST不具有幂等性，因为post每次都创建一个新的，  
对于幂等性操作可以我们可以放心的发多次操作  
对于非幂等性我，我们需要在后台保证发送多次不会创建多次  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 2]  
MVC框架：  
M:model表示操作数据库层  
V:view表示视图层  
C:controller 表示业务逻辑层  
我们省略视图层，来实现微服务，进行用户管理（增删改查）

# 代码实现： #

创建一个空的userapp的文件夹，用于我们的微服务的根目录  
然后里面再创建两个新的文件夹和一个app.py的文件  
![在这里插入图片描述][20190612204039598.png]  
再在models创建两个文件，init文件表示models可以被导入到其他的文件中  
![在这里插入图片描述][20190612204050119.png]  
在mosels中的user.py文件中编写UserModel：

class UserModel(object):
        user={
            1:{"name":"liuzheng00","age":25},
            2:{"name":"liuzheng11","age":24},
            3:{"name":"liuzheng22","age":23},
            4:{"name":"liuzheng33","age":22}
        }
    
        #获取单个用户
        @classmethod
        def get(cls,user_id):
            return cls.user[user_id]
    
        #修改用户信息
        @classmethod
        def update(cls,user_id,age):
            cls.user[user_id]['age']=age
    
        #删除用户信息
        @classmethod
        def delete(cls,user_id):
            if user_id in cls.user:
                return cls.user.pop(user_id)
    
        #获取多个用户
        @classmethod
        def get_all(cls):
            return list(cls.user.values())
    
        #创建一个用户对象
        @classmethod
        def create(cls,name,age):
            user_dict={"name":name,"age":age}
            max_id=max(cls.user.keys())+1#新对象的id在原来的基础上多1  如原来4 个现在5个
            cls.user[max_id]=user_dict

在handlers中的user.py编写代码：

import sys
    sys.path.append('..')#回到上一级   把当前目录回到上一级
    import tornado.web
    from models.user import UserModel
    from tornado.escape import json_encode
    
    #获取单个用户信息类
    class UserHandler(tornado.web.RequestHandler):
        #处理get请求  自动触发
        #获取单个用户
        def get(self,user_id):
            #从模型层获取数据
            user=UserModel.get(int(user_id))
            #返回数据给前端
            self.write(user)
    
        #修改用户信息
        def put(self,user_id):
            #获取修改后的age信息
            age=self.get_argument('age')
            #调用update进行更新操作
            UserModel.update(int(user_id),age)
            #定义返回字典，提示操作成功
            resp={"status":True,"msg":"update success"}
            self.write(json_encode(resp))
    
        #删除用户信息
        def delete(self,user_id):
            #调用delete进行删除
            UserModel.delete(int(user_id))
            #定义返回的字典，提示操作成功
            resp={"status":True,"msg":"delete success"}
            self.write(json_encode(resp))
    
    #获取所有用户信息类
    class UserListHandler(tornado.web.RequestHandler):
        #获取所有用户信息
        def get(self):
            #获取所有用户，返回的是字典
            user=UserModel.get_all()
            #序列化为json字符串
            self.write(json_encode(user))
    
        #创建一个新用户
        def post(self):
            #使用get_argument获取body中的参数
            name=self.get_argument('name')
            age=self.get_argument('age')
            #调用create创建新用户
            UserModel.create(name,age)
            #定义返回的字典，提示操作成功
            resp={"status":True,"msg":"create success"}
            self.write(json_encode(resp))

在app中编写代码：

import tornado.web
    from handlers.user import UserHandler,UserListHandler
    import tornado.ioloop
    import tornado.httpserver
    
    #定义全局的handlers
    HANDLERS=[
        (r'/api/user/(\d+)',UserHandler),
        (r'/api/user',UserListHandler)
    ]
    
    def run():
        #创建app对象
        app=tornado.web.Application(
            HANDLERS,
            debug=True#表示修改后自动重启
        )
    
        #使用tornado专用的非阻塞单线程服务器
        http_server=tornado.httpserver.HTTPServer(app)
    
        port=9000
        http_server.listen(port)
        print('server is start on port:{}'.format(port))
    
        #启动服务
        tornado.ioloop.IOLoop.instance().start()
    
    if __name__ == '__main__':
        run()

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 5]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 7]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70]: /images/20220117/568c445090f64320ada731cc1937ac7f.png
[2019061220352728.png]: /images/20220117/dd431740ce1b4761bc5760c055e3b831.png
[https_apizza.net_pro]: https://apizza.net/pro/#/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 1]: /images/20220117/3c9bec01c1894353b4208114a5ebf9ab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 2]: /images/20220117/6c6ca3f2f9c44d3cb7e366bfa2b86c6f.png
[20190612204039598.png]: /images/20220117/6ec515600eff42d2bd11100aa1a7ff73.png
[20190612204050119.png]: /images/20220117/2d59999757f2485fad471b5491580697.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 3]: /images/20220117/ce5d63f728f1496e8ec2135522dbd75f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 4]: /images/20220117/3c7d1d9bd3ba474fa119370d1e5823c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 5]: /images/20220117/e9d3ffd4919243e7af4dc90a34d77acd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 6]: /images/20220117/9bfa34d09ac54b0b84008f99ef1f67cb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDY3NTM4NA_size_16_color_FFFFFF_t_70 7]: /images/20220117/03f68f839701456faed89124260e40c2.png