Так что я реализую расширенный PUB/SUB
топология в ZeroMQ с C ++.
У меня есть 2 издателя, 1 посредник (экспедитор / прокси) и 2 подписчика.
Я называю sleep(1)
метод перед вызовом send()
в издательствах.
Но, согласно документации, это не элегантный способ синхронизации издателей с подписчиками. Документация предоставляет решение, в котором мы создаем REQ
а также REP
гнездо в SUB
и PUB
соответственно. Но это сложно, если есть несколько издателей и подписчиков.
Подскажите пожалуйста, как предотвратить потерю сообщений в расширенном PUB-SUB
топология.
это означает, что эту часть можно игнорировать, поскольку она является основной особенностью конструкции системы.
да,
REQ/REP
или другой, более сложныйдополненная«-произведение тривиальных примитивных встроенных шаблонных шаблонов формальных коммуникаций может помочь справиться со встроенными свойствами проекта, но все эти этапы, в основном, являются обязанностью разработчика приложений определять, анализировать и реализовывать. Не ждите никакой волшебной палочки, все же это общий аспект находить много примеров обсуждается здесь уже.
Других решений пока нет …