python tornado websocket错误：RuntimeError：线程'Thread-1'中没有当前事件循环

Question

我有以下代码，它在 Tornado = 5 运行它就会失败，

import tornado.httpserver
import tornado.ioloop
import threading
import tornado.web,tornado.websocket

class thr(threading.Thread):
    def __init__(self,handler):
        self.handler=handler
        threading.Thread.__init__(self)
    def run(self):
        self.handler.write_message("test")
class ClientWebSocketConnectionHandler(tornado.websocket.WebSocketHandler):
    def open(self):
            print ("opened")
    def on_message(self, message):
            thr(self).start()    

class MainApplication(tornado.web.Application):
    def __init__(self):
        handlers = [(r'/User', ClientWebSocketConnectionHandler),]
        tornado.web.Application.__init__(self, handlers,)

TheShieldsWebSocket = MainApplication()
server = tornado.httpserver.HTTPServer(TheShieldsWebSocket)
server.listen(8085,'0.0.0.0')
tornado.ioloop.IOLoop.instance().start()

错误说：RuntimeError: There is no current event loop in thread 'Thread-1'

这到底是怎么回事？好像跟线程有关。

Answer 1

假设你想写一个api，这个api可能需要等待一些东西才能渲染到客户端！这是实现这一目标的方法！正如您使用thread 一样，这很好，但不推荐。所以我们在 tornado 中调用了并发，你可以看到细节here。

这里你的代码可以修改如下：

import tornado.httpserver
import tornado.ioloop
import tornado.web,tornado.websocket


class ClientWebSocketConnectionHandler(tornado.websocket.WebSocketHandler):
    def open(self):
            print ("opened")
    def on_message(self, message):
            self.write_message('test')    

class MainApplication(tornado.web.Application):
    def __init__(self):
        handlers = [(r'/User', ClientWebSocketConnectionHandler),]
        tornado.web.Application.__init__(self, handlers,)

TheShieldsWebSocket = MainApplication()
server = tornado.httpserver.HTTPServer(TheShieldsWebSocket)
server.listen(8085,'0.0.0.0')
tornado.ioloop.IOLoop.instance().start()

典型情况下，您会收到403 错误，在这种情况下您可以添加函数名称为check_origin。

    # rest of above code
    def check_origin(self, param):
            return True

    def open(self):
            print ("opened")
    def on_message(self, message):
            self.write_message('test') 

如果你希望你的服务器可以处理多连接，你可以使用 `concurrent 方式来做到这一点，如下所示：

    @gen.coroutine
    def on_message(self, message):
            http_client = AsyncHTTPClient()
            response = yield http_client.fetch("http://example.com")
            do_something_with_response(response)
            self.write_message('test')