Python-сообщество

Привет!

сразу перейду к вопросу

у нас есть список с соединениями - waiters (взял из примера чата)
и всё хорошо, мы можем рассылать сообщения или всем или добавить функционал по условям, но это только запущен один инстанс.
а если запущено несколько и перед ними например haproxy то как тогда ?

теоретически понятно что надо иметь общий список всех подключений, доступный всем но как это организовать, что именно сохранить ?


p.s. после гугления выходил на пост http://thomas.pelletier.im/2010/08/websocket-tornado-redis/
но или я не понял или это не совсем то что надо.

не нужен общий список подключений (конект нельзя передать), haproxy должен раскидывать подключения, т.е. не должен его рвать. websocket - создает долгое подключение - клиент будет общаться через него с одним инстансом.
этот пример с редисом должен нормально работать. вместо редиса тут можно zmq заюзать.

да, я как раз и думал что врятли можно както соединение передать, тогда мне вот что интересно:
есть два человекак примеру у них “чатик” и если одного прокси заруливает на первый инстанс а второго на 10й, тогда первый с первого инстанса мы не узнаем о втором человеке и о том что ему надо послать сообщение

> тогда первый с первого инстанса мы не узнаем о втором человеке и о том что ему надо послать сообщение
необязательно знать о втором, все клиенты получат сообщение, т.к. они подписаны на очередь из редиса.

хм… не совсем понял, относительно редиса тут

def redis_listener():
    r = redis.Redis(host='YOURSERVER', db=2)
    r.subscribe('test_realtime')
    for message in r.listen():
        for element in LISTENERS:
            element.write_message(unicode(message['data']))

кстати разработчики торнадо не рекомендуют напрямую взаимодействовать с торнадо из других потоков
вместо прямого “write_message”, нужно добавлять “событие” в ioloop торнадо.

> как redis_listener синхргнизируется с вебсокетным on_message ?
всмысле как сотрудничают однопоточный торнадо и отдельный поток?

да я не совсем понял как в этом в этом примере рассылаются сообщения слушателям по приходу, то есть именно сам момент.

> element.write_message(unicode(message))
element - это RealtimeHandler, в нем есть функция write_message которая отправляет байты клиенту.
LISTENERS - список “клиентов” на каждом инстансе,

когда в редис попадает сообщение, на всех инстансах сработает r.listen(), далее каждый инстанс перебирает всех клиентов и отправляет это сообщение.

да, про element и LISTENERS было понятно … но не хватало последнего момента, то есть на каждом торнадо инстансе будет запущен редис listen()
и тут просто часть функционала получается взял на себя именно редис.

спасибо.

кстати с rmq более “правильный” вариант получится или нет ?

yessi
кстати с rmq более “правильный” вариант получится или нет ?