龙卷风:确定的WebSockets的/跟踪连接?(Tornado: Identify / track

2019-06-26 14:11发布

我有一个基本的龙卷风的WebSocket测试:

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

class WSHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        print 'new connection'
        self.write_message("Hello World")

    def on_message(self, message):
        print 'message received %s' % message

    def on_close(self):
      print 'connection closed'


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


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

我希望能够处理多个连接(这似乎已经这样做了),但也能引用其他连接。 我不明白的方式来识别和跟踪单个连接的,只是为了能够处理的连接打开,收到的消息,和连接关闭事件。

[编辑]
想创建一个字典,其中的关键是二段的WebSocket键和和值是WSHandler对象...想法? 我不知道二段的WebSocket,关键是如何可靠是唯一的。

Answer 1:

最简单的方法就是保持WSHandler实例的列表或字典:

class WSHandler(tornado.websocket.WebSocketHandler):
    clients = []

    def open(self):
        self.clients.append(self)
        print 'new connection'
        self.write_message("Hello World")

    def on_message(self, message):
        print 'message received %s' % message

    def on_close(self):
        self.clients.remove(self)
        print 'closed connection'

如果你想找出连接,例如用户,你可能要送过来的套接字信息。



Answer 2:

科尔麦克莱恩asnwer是好的,简单的解决方案,当你只需要所有连接的列表。 不过,如果你想更复杂的东西,可以外面被监测WSHandler实例-勇敢做这样的:

class WSHandler(tornado.websocket.WebSocketHandler):

    def open(self):
        self.id = uuid.uuid4()
        external_storage[self.id] = {'id':self.id}
        print 'new connection'
        self.write_message("Hello World")

    def on_message(self, message):
        #Some message parsing here
        if message.type == 'set_group':
           external_storage[self.id]['group'] = message.group
        print 'message received %s' % message

    def on_close(self):
        external_storage.remove(self.id)
        print 'closed connection'


Answer 3:

如果您的用户具有访问令牌,这可以被添加到您的WebSocket端点,再说了,在初始化它打开,甚至在你的插槽中取出(但请通过SSL工作)。

如果访问令牌不可用,或者是因为用户没有提供一个或他们提供的令牌已过期,用户没有通过认证,你会杀尽早插座。

但是这样做,访问令牌应该被关联到谁将会识别码的用户,然后该标识符可连接到已被打开甚至在插座。 所述标识符可以作为字典的键,它的值是一组套接字绑定到该用户的。



Answer 4:

我已经通过检查conexion的起源地解决了这个问题。 所以,overrriding方法def check_origin(self, origin)可能会有帮助。 例如:

clients = {}

class WSHandler(tornado.websocket.WebSocketHandler):


    def check_origin(self, origin): 

        clients[origin] = self
        print(clients)
        return True


文章来源: Tornado: Identify / track connections of websockets?