Схема трубопровода ZeroMQ

Question

Я реализую систему обмена сообщениями, в которой внешние программы, называемые агентами, могут взаимодействовать через производителей ZeroMq. Таким образом, каждый раз, когда возникает интересное событие, агент отправляет сообщение в ZeroMq.

Я заинтересован в реализации этого, используя шаблон трубопровода.

Я нашел несколько примеров (диспетчер работника-вентилятора), но компонент Ventilator создает конечную точку для приема соединений от рабочего и затем отправляет все сообщения в пакетном режиме.

Мой сценарий совсем другой. «Агент» подключается каждый раз, когда событие требуется для отправки - оно не ждет соединений от рабочих, поэтому мне интересно, возможно ли это? Кроме того, важным фактом является то, что сообщения должны обрабатываться для отправки.

Answer 1

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

Answer 2

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