Day03 tornado的同步与异步

一、同步与异步

并发：同一个世界，但CPU只执行一个任务

并行：多CPU同时执行不同任务

同步：对请求结果来说，上一步的操作必须执行完毕，下一步才能执行

异步：下一步的操作不需要等待上一步的完成

阻塞和非阻塞针对线程的状态而言的：

阻塞：线程没有资源，因此挂起并不执行

非阻塞：线程有资源，一直运行

tornado是异步非阻塞框架

tornado的异步代码

注意：以下代码使用的tornado的版本是4.5的，高版本不兼容。

import tornado.web
import tornado.ioloop
import tornado.httpclient

class IndexHandler(tornado.web.RequestHandler):
    def get(self):
        # 在路由中传递的参数，/index/?q=python
        q = self.get_argument('q')
        # 向地址发送请求：https://cn.bing.com/search?q=
        client = tornado.httpclient.HTTPClient()
        response = client.fetch('https://cn.bing.com/search?q=%s' % q)
        print(response)
        self.write('同步测试')

def make_app():
    return tornado.web.Application(handlers=[
        (r'/index/', IndexHandler),
    ])


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

tornado 异步代码

import tornado.web
import tornado.ioloop
import tornado.httpclient

class IndexHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        q = self.get_argument('q')
        client = tornado.httpclient.AsyncHTTPClient()
        client.fetch('https://cn.bing.com/search?q=%s' % q, callback=self.on_response)
        self.write('异步测试')

    def on_response(self, response):
        # 回调,当页面响应，则调用回调函数on_response
        print(response)
        self.write('回调执行')
        self.finish()


def make_app():
    return tornado.web.Application(handlers=[
        (r'/index/', IndexHandler),
    ])


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

tornado 异步代码优化


import tornado.web
import tornado.ioloop
import tornado.httpclient


class IndexHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    @tornado.web.gen.coroutine
    def get(self):
        q = self.get_argument('q')
        client = tornado.httpclient.AsyncHTTPClient()
        response = yield client.fetch('https://cn.bing.com/search?q=%s' % q)
        print(response)
        self.write('异步测试')


def make_app():
    return tornado.web.Application(handlers=[
        (r'/index/', IndexHandler),
    ])

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

二、测压

工具：apache

网站性能压力测试是服务器网站性能调优过程中必不可缺少的一环。只有让服务器处在高压情况下，才能真正体现出软件、硬件等各种设置不当所暴露出的问题。

ab是apache自带的压力测试工具。

1、原理

ab是apachebench命令的缩写。

ab的原理：ab命令会创建多个并发访问线程，模拟多个访问者同时对某一URL地址进行访问。

ab工具的使用.jpg

2、名词说明

名称	英语	说明
吞吐率	Requests per second	服务器并发处理能力的量化描述，单位是reqs/s
并发连接数	The number of concurrent connections	某个时刻服务器所接受的请求数目，简单的讲，就是一个会话
并发用户数	The number of concurrent users，Concurrency Level	一个用户可能同时会产生多个会话，也即连接数
用户平均请求等待时间	Time per request	处理完成所有请求数所花费的时间/ （总请求数 / 并发用户数）
服务器平均请求等待时间	Time per request: across all concurrent requests	处理完成所有请求数所花费的时间 / 总请求数

3、ab工具的使用

打开cmd
打开你安装的apache的位置：找到 bin文件夹下面的ab.exe
输入 ab.exe -help，查看命令帮助信息。

测试命令格式：ab [options] [http://]hostname[:port]/path

例如：测试本地代码

ab -c 3 -n 10 http://127.0.0.1:80/index

ab测试结果.jpg

三、聊天室

manage.py

import os

import tornado.web
import tornado.ioloop
from tornado.options import define, options, parse_command_line

from app.views import LoginHandler, ChatHandler

define('port', default=80, type=int)


def make_app():
    return tornado.web.Application(handlers=[
        (r'/login/', LoginHandler),
        (r'/chat/', ChatHandler)
        ],
        template_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'templates'),
        static_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'static'),
        cookie_secret = 'w3rwefsaf'
    )


if __name__ == '__main__':
    parse_command_line()
    app=make_app()
    app.listen(80)
    tornado.ioloop.IOLoop.current().start()

app/views.py

from datetime import datetime

import tornado.web
import tornado.websocket


class LoginHandler(tornado.web.RequestHandler):
    def get(self):
        error = None
        self.render('login.html', error=error)

    def post(self):
        username = self.get_argument('username')
        password = self.get_argument('password')
        # self.get_body_argument()
        # 模拟登录,校验功能
        if username in ['ququ','coco']  and password == '123':
            self.set_secure_cookie('username', username)
            self.render('chat.html', username=username)
        else:
            error = '账号或密码错误!'
            self.render('login.html', error=error)


class ChatHandler(tornado.websocket.WebSocketHandler):

    # 用于存放连接的对象
    user_online = []
    def open(self):
        self.user_online.append(self)
        for user in self.user_online:
            # 当进入chat.html页面是，会主动触发改函数
            username = self.get_secure_cookie('username').decode('utf-8')
            user.write_message('系统提示:[%s 已上线！]'% username)

    def on_message(self, message):
        # 接收前端返回额数据
        username = self.get_secure_cookie('username').decode('utf-8')
        for user in self.user_online:
            str_time = (datetime.now()).strftime("%H:%M")
            user.write_message('[%s]<br>%s:%s'% (str_time, username, message))

    def on_close(self):
        # 移除连接对象
        self.user_online.remove(self)
        for user in self.user_online:
            username =self.get_secure_cookie('username').decode('utf-8')
            user.write_message('系统提示:[%s已下线！]'% username)

在chat.html中添加

<script src="https://code.jquery.com/jquery-3.1.1.min.js"></script>
  <script>

  // 建立连接
  var websocket = new WebSocket('ws://127.0.0.1/chat/')
  // 获取后端返回的数据
  websocket.onmessage = function(e){
    console.log(e.data)
    $('#chat').append('<br>')
    $('#chat').append(e.data)
  }
  $('#btn').click(function(){
    // 向后端发送数据
    var content = $('#content').val()
    websocket.send(content)
  });
</script>