У меня есть проблема, которую я пытаюсь решить, и мне кажется, что это распространенная проблема, и поэтомувероятноимеет общее решение в виде сетевого протокола. Мои знаниясетевые протоколынесколько ограничен, и я не могу найти существующий протокол для решения этой проблемы с помощью поиска Google, если использование другого протокола является тем решением, которое мне действительно нужно.
Моя конфигурация
Используя MQTT, у меня есть один производитель, публикующий сообщения в теме, и потенциально несколько потребителей, подписывающихся на эту тему. Производитель может производить сообщения с определенной максимальной скоростью. Каждый потребитель хочет обрабатывать сообщения с уникальной для этого потребителя скоростью. Если потребитель получает сообщения со скоростью, превышающей его способность обрабатывать, он может просто выбросить сообщения.
Моя забота
Например, у меня может быть производитель, который может выдавать изображения со скоростью, скажем, 100 изображений в секунду, но мои 2 потребителя могут потреблять их только со скоростью 8 в секунду и 5 в секунду соответственно. Для экономии сетевых ресурсов оптимальная скорость публикации здесь будет 8 изображений в секунду.
Моя мысль
Один из способов сделать это — подключить производителей и потребителей к общей службе «согласования ставок», целью которой будет изменение скорости, с которой издатель отправляет сообщения в общую тему.
Вопрос
Стоит ли мне рассмотреть возможность использования другого протокола для этой цели или есть что-то еще распространенное, что мне следует рассмотреть, чтобы помочь мне решить эту проблему?