tornado.gen.coroutine-비동기 함수 작성

비동기 함수:
1. Future로 돌아가기
2. 반드시 set_result () 또는 set_exception () 호출.
여기서 비동기적인 socket 읽기 예를 보여 줍니다.
먼저 시간 소모 작업을 시뮬레이션하기 위해 정해진 시간에 되돌아오는 서버를 정의합니다

from tornado.tcpserver import TCPServer
from tornado import ioloop
from tornado import gen 
from tornado.concurrent import Future

def sleep(duration):
    f = Future()
    ioloop.IOLoop.current().call_later(duration, lambda: f.set_result(None))
    return f

def handle_excep(future):
    if future.exception() is not None:
        print future.exc_info()
    

class EchoServer(TCPServer):
    def handle_stream(self, stream, address):
        f = self._handle_stream(stream, address)
        f.add_done_callback(handle_excep)

    @gen.coroutine
    def _handle_stream(self, stream, address):
        yield data = yield stream.read_until('
')        
        yield sleep(2)
        yield stream.write(data)
        stream.close()

server = EchoServer()
server.listen(8888)
ioloop.IOLoop.instance().start()

여기에서sleep () 함수를 사용합니다. 시뮬레이션 소모 작업입니다.
sleep 함수는tornado4.1이gen 모듈에 정의되어 있으며,gen.sleep를 직접 사용할 수 있습니다.
HTTPServer 장애 요청 버전

import tornado.httpserver
import tornado.ioloop
import tornado.web
import base64
import socket


class MainHandler(tornado.web.RequestHandler):

    def get(self):
        s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
        s.connect(('localhost', 8888))
        s.send('hello
')
        data = s.recv(4096)
        self.write(data)
        self.finish()

if __name__ == "__main__":
    app = tornado.web.Application(
        handlers = [ 
            (r"/", MainHandler)
        ]   
    )   

    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(8000)
    tornado.ioloop.IOLoop.instance().start()

여기는 일반적인 socket 요청일 뿐입니다. 차단되어 있습니다.서버가 데이터를 반환하려면 2s를 기다려야 합니다.
HTTPServer 비동기식 요청 버전

import tornado.httpserver
import tornado.web
import socket
from tornado import ioloop
from tornado import gen 
from tornado.concurrent import Future

class MainHandler(tornado.web.RequestHandler):
    
    @gen.coroutine
    def get(self):
        data = yield self.get_data()
        self.write(data)
        self.finish()

    def get_data(self):
        future = Future()
        s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 
        s.connect(('localhost', 8888))
        s.send('hello
')

        def handle_data(sock, event):
            io_loop = ioloop.IOLoop.current()
            io_loop.remove_handler(sock)
            data = sock.recv(1024)
            future.set_result(data)

        io_loop = ioloop.IOLoop.current()
        io_loop.add_handler(s, handle_data, io_loop.READ)

        return future

if __name__ == "__main__":
    app = tornado.web.Application(
        handlers = [
            (r"/", MainHandler)
        ]
    )

    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(8000)
    tornado.ioloop.IOLoop.instance().start()

위의 비동기 함수 get_ 주의데이터에서 socket이 EchoServer를 요청하는 것은 직접recv가 결과를 기다리는 것이 아닙니다.새로운 Future 객체를 인스턴스화하여
그리고 socket 읽을 수 있는 이벤트를 ioloop에 등록합니다.만약 socket에 데이터가 있다면handle_데이터, 여기서future를 호출합니다.set_result () 메서드입니다.
get_데이터는 위의 두 가지 조건을 충족시켰다.

Future 객체로 돌아갑니다

장래에.set_result 방법은 ioloop에 등록되어 결과가 돌아올 때 호출됩니다

마지막으로gen.coroutine 장식기를 주의하십시오. 장식된 함수에 이상이 생기면 던지지 않습니다.되돌아오는future에 접근해야 알 수 있습니다.
예를 들면 다음과 같습니다.

def handle_exce(future):
    if future.exception() is not None:
        print future.exec_info()

def func():
    future = async()
    future.add_done_callback(handle_exce)

@gen.coroutine   
def async():
    raise RuntimeError("async exception")

마지막으로 성능 비교, http_ 사용로드 테스트:
이곳은 200명의 사용자를 시뮬레이션하여 끊임없이 10s에 접근한다.
막힌 판

./http_load -p 200 -s 10  url 
4 fetches, 200 max parallel, 20 bytes, in 10.0013 seconds
5 mean bytes/connection
0.399948 fetches/sec, 1.99974 bytes/sec
msecs/connect: 0.20175 mean, 0.277 max, 0.153 min
msecs/first-response: 5006.22 mean, 8010.14 max, 2002.34 min
HTTP response codes:
  code 200 -- 4

비동기식 버전

./http_load -p 200 -s 10  url 
800 fetches, 200 max parallel, 4000 bytes, in 10.0017 seconds
5 mean bytes/connection
79.9868 fetches/sec, 399.934 bytes/sec
msecs/connect: 20.0608 mean, 997.373 max, 0.03 min
msecs/first-response: 2020.97 mean, 2204.74 max, 2000.99 min
HTTP response codes:
  code 200 -- 800

차단판의 0.399948fetches/sec와 비동기판의 79.9853fetches/sec를 볼 수 있습니다.에서 볼 수 있듯이 막힘은tornado의 성능에 큰 영향을 줄 수 있다.
예를 들어 시간 소모된 데이터베이스 조회, 시간 소모된 연산 등이다.그래서 비동기적인 라이브러리를 사용해야만 토네이도의 고성능을 발휘할 수 있다.
만약 상응하는 비동기 라이브러리가 없다면 스스로 써 볼 수 있다.또는 가장 간단한 것은celery를 비동기 작업 대기열로 사용합니다.celery에는 대응하는 tornado 라이브러리, tornado-celery가 있습니다.