Tornado 长轮询请求

Question

下面是我的问题最简单的例子：

发出请求时，它将打印Request via GET <__main__.MainHandler object at 0x104041e10>，然后请求将保持打开状态。好的！但是，当您发出另一个请求时，它不会调用 MainHandler.get 方法，直到第一个连接完成。

如何让多个请求进入get 方法，同时让它们保持长轮询。我正在为每个请求传递参数，这些参数将通过 redis 从发布/订阅中获得不同的结果。问题是我一次只能连接一个。怎么了？为什么这会阻止其他请求？

import tornado.ioloop
import tornado.web
import os


class MainHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        print 'Request via GET', self


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

    try:
        application.listen(int(os.environ.get('PORT', 5000)))
        tornado.ioloop.IOLoop.instance().start()
    except KeyboardInterrupt:
        tornado.ioloop.IOLoop.instance().stop()

左图：如上述问题所述。请求未按右图中请求的方式处理。 右图 我需要 RequestHandler 处理请求（a-d），然后等待 pub/sub 公布他们的数据。

A B C D + + + + ++ a b c d | | | | || + + + + | | | | || | | | | | | | | || | | | | | | | | || | | | | | v v v || | | | | +---|------------------+ || +-----|----|---|---|------------------+ | | | || | | | | | | | + 请求处理程序| || | + + + + 请求汉。 | | | | || | | | | | | +---|------------------+ || +-----|----|---|---|------------------+ +---|------------------+ || +-----|----|---|---|------------------+ | | | || | | | | | | | + Sub/Pub Qu | || | v + v v 阙 | | | | || | | | +---|------------------+ || +---------|--------------+ +---|------------------+ || +---------|--------------+ | || | |完成|| |完成的 v || v || || || || || || || ++

如果这可以用另一种编程语言完成，请告诉我。

感谢您的帮助！

Answer 1

来自http://www.tornadoweb.org/en/stable/web.html#tornado.web.asynchronous：

tornado.web.asynchronous(方法)

...

如果给定了这个装饰器，当 方法返回。由请求处理程序调用 self.finish() 完成 HTTP 请求。没有这个装饰器，请求是 get() 或 post() 方法返回时自动完成。

你必须明确地完成get方法：

import tornado.ioloop
import tornado.web
import tornado.options

from tornado.options import define, options
define("port", default=8000, help="run on the given port", type=int)

class MainHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous
    def get(self):
        print 'Request via GET', self
        self.finish()


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

    try:
        application.listen(options.port)
        tornado.ioloop.IOLoop.instance().start()
    except KeyboardInterrupt:
        tornado.ioloop.IOLoop.instance().stop()