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