Сохранение списка подключений к сети в Tornado

Question

Я решил отслеживать несколько подключений к сети. Мне нужно сохранить объекты WebSocket Handler в списке. Но у меня есть несколько обработчиков - по одному для каждого WS URI (конечная точка). Допустим, мой проект имеет три конечные точки - A, B, C

ws://www.example.com/A 
ws://www.example.com/B 
ws://www.example.com/C 

Так обрабатывать соединения для каждого из них, у меня есть три обработчика. Поэтому я озадачен тем, где можно создать список для хранения объектов обработчика, которые будут использоваться позже.

Мой код перед добавлением списка является -

class WSHandlerA(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' 


class WSHandlerB(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' 

class WSHandlerB(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'/A', WSHandlerA), 
    (r'/B', WSHandlerB), 
    (r'/C', WSHandlerC), 
]) 


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

Так где же я создаю этот список и убедитесь, что его видимым для всех созданных объектов? Я тоже новичок в python и поэтому испытываю небольшие проблемы, обворачивая вокруг себя.

Я также понимаю, что я мог бы использовать только один URI (конечная точка) и отправлять несколько команд как часть самого сообщения. Но тогда я не хочу превращать WebSocket в двоичный протокол. Учитывая, что у нас есть URI, я должен их использовать.

Спасибо за любую помощь.

Answer 1

Это зависит от того, что вы хотите сделать с обработчиков, но вы можете легко сделать их доступными в трех списках:

# Global variables. 
a_handlers = [] 
b_handlers = [] 
c_handlers = [] 

WSHandlerA.open() делает a_handlers.append(self) и WSHandlerB.open() делает b_handlers.append(self), и так далее. WSHandlerA.on_close()a_handlers.remove(self).

Если вы хотите сделать что-то со всеми A обработчиками:

for handler in a_handlers: 
    handler.write_message("message on A") 

Чтобы сделать что-то со всеми обработчиками:

for handler in a_handlers + b_handlers + c_handlers: 
    # do something.... 
    pass 

Кстати, если вы используете Python set() вместо списка для каждого набора обработчиков это будет немного лучше. С наборами вместо списков используйте add и discard вместо append и remove.