Трубопровод ZeroMQ

Question

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

Я заинтересован в реализации этого с использованием шаблона конвейера.

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

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

Answer 1

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

Answer 2

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