调用 Tornado 服务器时保持 ajax 调用处于活动状态

发布于 2024-11-05 15:14:44 字数 796 浏览 6 评论 0原文

我正在尝试编写我的第一个龙卷风应用程序。
龙卷风的示例示例显示了以下代码，但是似乎一旦“MainHandler”函数返回，客户端与客户端之间的连接就会建立起来。该服务器将丢失。

我希望服务器在数据可用时持续推送数据。
如何保持这一管道畅通？

在客户端，我正在考虑进行 ajax 调用。这行得通吗？
我以为一旦收到数据，ajax调用就结束了。

Facebook确实说客户端使用龙卷风与服务器保持一个线程打开，因此我知道这是可以做到的，我想我在这里正在努力理解一些简单的概念..

import tornado.ioloop  
import tornado.web  
import time

class MainHandler(tornado.web.RequestHandler):  
    def get(self):  
        self.write("What happens after this call ?")  
    # while(True): time.sleep(5) <push more data># This would be ugly.. plus blocking(correct ?) 

application = tornado.web.Application([  
    (r"/", MainHandler),  
])

if __name__ == "__main__":    
    application.listen(8888)  
    tornado.ioloop.IOLoop.instance().start()

我的理解中缺少什么？

原文

I'm trying to write my first tornado application.
The sample example for tornado, shows the below code, however it seems that once the "MainHandler" function returns, the connection between the client & this server will be lost.

I want the server to continuously push data, as and when it becomes available.
How does one keep this pipe open ?

On the client side I'm thinking of doing an ajax call. Will that work ?
I thought once the data is received, the ajax call ends.

Facebook does say that the client keeps a thread open with the server using tornado, hence I know it can be done, I think I'm struggling at some simple concept here..

import tornado.ioloop  
import tornado.web  
import time

class MainHandler(tornado.web.RequestHandler):  
    def get(self):  
        self.write("What happens after this call ?")  
    # while(True): time.sleep(5) <push more data># This would be ugly.. plus blocking(correct ?) 

application = tornado.web.Application([  
    (r"/", MainHandler),  
])

if __name__ == "__main__":    
    application.listen(8888)  
    tornado.ioloop.IOLoop.instance().start()

What is missing in my understanding ?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

我三岁 2024-11-12 15:14:44

如果您想保持连接打开，您可能需要使用 websocket。类似于：

LISTENERS = []

class RealtimeHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        LISTENERS.append(self)

    def on_close(self):
        LISTENERS.remove(self)

application = tornado.web.Application([
    (r'/', RealtimeHandler),
])

You might want to use a websocket if you want to keep the connection open. Something like:

LISTENERS = []

class RealtimeHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        LISTENERS.append(self)

    def on_close(self):
        LISTENERS.remove(self)

application = tornado.web.Application([
    (r'/', RealtimeHandler),
])

回复收藏 0 原文

~没有更多了~