当数据可用时如何完成 Tornado 长轮询请求

Question

我有很长的编程背景，但对 Python 很陌生，并且正在使用 Tornado 来制作某个长轮询服务的原型。

我想要实现的是用户连接到 example.com/get/1234，这是长轮询部分。 1234 是用户 ID。目前，它只是挂起并等待内容。然后用户使用新选项卡/其他浏览器/其他计算机/等并转到 example.com/set/1234?data=abcd 等 url，其中 1234 是用户 ID，data 是内容为“abcd”的变量。现在，当发生这种情况时，第一个 get 请求应该打印出数据“abcd”并完成请求。用户ID显然是为了允许多个用户同时使用该服务。简而言之：

1）转到 example.com/get/1234 ->等待 2) 在另一个选项卡中，打开 example.com/set/1234?data=abcd 3）在此请求之后，第一个请求打印出 abcd 并完成

下面是我一直在尝试的事情，但我并没有真正推进这一点，也找不到合适的谷歌关键字来解决这个问题。

class GetHandler(tornado.web.RequestHandler):
    @tornado.web.asynchronous

    # Getting user ID is working
    def get(self, user_id):

        # This is something I'm not sure is right, but found it in an 
        # example. I haven't created the code_received function yet, 
        # nor know if it should be here? Should the code_received
        # and connection finishing be called from the /set part?

        cursor = self.get_argument("cursor", None)
        self.wait_for_code(self.code_received, cursor=cursor)

    def code_received(self, data)
        self.write(data)
        self.finish()

非常感谢所有帮助。提前致谢！

Answer 1

我实际上设法解决了这个问题，找到了解决方案。

回顾一下，以防其他人正在研究这一点：我将侦听器保存到带有 user_id 的字典中，当调用 /set 时，我向侦听器发送了消息相同的user_id。如果有人感兴趣，我可以分享更多代码。

Answer 2

一个简单的解决方法是添加超时回调

class GetHandler(tornado.web.RequestHandler):

    @tornado.web.asynchronous
    def get(self, user_id):    

        def check():
            # here you must implement something to discover if the result exists
            # for example, you can keep a dictionary with id : result 
            # so initially 1234 : None
            # after setting 1234 : someVal (this happens from the SetHandler)
            # then if below succeeds
            if there_is_a_result:
                self.write(result) 
                self.finish()
            else:   # result not ready, add another timeout callback
                tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(0.00001), check)

        tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(0.00001), check)

编辑：更好的解决方法是使用 websockets + redis + pubsub。我自己没有使用过这个，但是有一个例子这里< /a>.