Можете ли вы создать централизованную тему в ZeroMQ?

Question

Я бы очень хотел попробовать ZeroMQ, и мне интересно, можно ли решить мою проблему с помощью этого.

ПРОБЛЕМА: У меня есть несколько подписчиков и несколько издателей. В централизованной архитектуре брокер издатели опубликуют сообщение на тему (вроде как многоадресный адрес), и подписчики получат сообщения из темы и действуют на сообщения. Я не могу использовать Multicast, потому что наша топология сети имеет несколько подсетей, и ИТ-ребята не будут перенаправлять мои многоадресные пакеты во все подсетей.

Поскольку нет централизованного брокера, как решить эту проблему в ZeroMQ? (пример кода будет отличным на любом языке)

Answer 1

Выполнял немного чтения. И это возможно в ZeroMQ в конце концов. Вы бы использовать «ЭКСПЕДИТОР» устройство как:

import zmq 

def main(): 

    try: 
     context = zmq.Context(1) 
     # Socket facing clients 
     frontend = context.socket(zmq.SUB) 
     frontend.bind("tcp://*:5559") 

     frontend.setsockopt(zmq.SUBSCRIBE, "") 

     # Socket facing services 
     backend = context.socket(zmq.PUB) 
     backend.bind("tcp://*:5560") 

     zmq.device(zmq.FORWARDER, frontend, backend) 
    except Exception, e: 
     print e 
     print "bringing down zmq device" 
    finally: 
     pass 
     frontend.close() 
     backend.close() 
     context.term() 

if __name__ == "__main__": 
    main() 

Answer 2

Это очень простой вопрос, но я попытаюсь дать вам несколько советов ... просто поймите, что вы не описали фактическую проблему, просто используйте -case, который имеет несколько потенциальных решений в зависимости от ваших конкретных потребностей.

На базовом уровне вы можете просто обслуживать каждого абонента список каждого издателя и подписываться на каждый из них напрямую. Это все очень грубая сила и руководство, но это первый шаг к достижению того, чего вы хотите.

Если вы поддерживаете этот список, это становится проблемой для каждого узла, вы создаете новый узел для управления списком подписчиков для вас. Когда издатель закручивается, он уведомляет о себе узел менеджера, который информирует подписчиков о необходимости подписки на него.

Если мы говорим о действительно большом количестве издателей и подписчиков, и полная сетевая топология просит вопросов, вы можете написать свой собственный брокер, чтобы подписаться на каждого издателя, а затем переиздавать для всех подписчиков.

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