我有一个基本的龙卷风的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,关键是如何可靠是唯一的。
最简单的方法就是保持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'
如果你想找出连接,例如用户,你可能要送过来的套接字信息。
科尔麦克莱恩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'
如果您的用户具有访问令牌,这可以被添加到您的WebSocket端点,再说了,在初始化它打开,甚至在你的插槽中取出(但请通过SSL工作)。
如果访问令牌不可用,或者是因为用户没有提供一个或他们提供的令牌已过期,用户没有通过认证,你会杀尽早插座。
但是这样做,访问令牌应该被关联到谁将会识别码的用户,然后该标识符可连接到已被打开甚至在插座。 所述标识符可以作为字典的键,它的值是一组套接字绑定到该用户的。
我已经通过检查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