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