Tornado - 按需向客户发送消息

Question

我正在使用 Tornado 提供一个 html 文件，同时，我希望我的 Python 程序通过 websockets 动态更改同一页面中的值。目的是可以看到值的变化，而不需要在客户端刷新。

在这种情况下，我想发送一条消息，其中的变量每 4 秒从“1234”变为“4321”。 我有一个线程进行值切换，我希望同一个线程将该值发送到 websocket，所以我可以使用客户端的 onmessage 函数通过脚本处理它。

以下代码会给我以下错误：'Application' object has no attribute 'write_message'

import tornado.ioloop
import tornado.web
import tornado.websocket
import threading
import time

flag = True

class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.render("mypage.html")

class wshandler(tornado.websocket.WebSocketHandler):
    def open(self):
        self.write_message('connected')
            print "WebSocket opened"
    def on_message(self, message):
            self.write_message("You have sent: " + message)
    def on_close(self):
            print "WebSocket closed"
    def write_message(self, message):
        print ("writing message", message)
        self.write_message(message)

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

def toggle():
    global flag
    while True:
        if flag==True:
            print 'now on 1234'
            flag = False
            application.write_message('1234')
            time.sleep(4)

        elif flag==False:
            flag = True
            application.write_message('4321')
            print 'Now on 4321'
            time.sleep(4)

def main():
    global response
    valueThread=threading.Thread(target=toggle, name="Toggle Value Thread")
    valueThread.setDaemon(True)
    valueThread.start() 
    application.listen(8888)
    tornado.ioloop.IOLoop.instance().start()




if __name__ == "__main__":
    main()

我的问题是，我看到的关于 Tornado 的每一个教程/指南都只使用 websocket 类中的 open 和 onmessage 函数中的 write_message 函数。所以我真的不明白为什么这不起作用。

Answer 1

您应该只在 websocket 类的 open 和 onmessage 函数中使用 write_message 函数。您正在使用application，即tornado.web.Application。肯定不会有tornado.websocket.WebSocketHandler的方法。他们不是同一个班级。因此出现错误。

我会这样做：

class wshandler(tornado.websocket.WebSocketHandler):

    def toggle(self):
        flag = True
        while True:
            if flag==True:
                print 'now on 1234'
                flag = False
                self.write_message('1234')
                time.sleep(4)

            elif flag==False:
                flag = True
                self.write_message('4321')
                print 'Now on 4321'
                time.sleep(4)

    def on_message(self, message):
        if message == 'toggle':
            self.toggle()