Tengo un problema que estoy tratando de resolver y que parece ser un problema común y, por lo tanto,probablementetiene una solución común en forma de protocolo de red. mi conocimiento deprotocolos de redes algo limitado y no puedo encontrar un protocolo existente para resolver este problema usando la búsqueda de Google si la solución que realmente necesito es usar un protocolo diferente.
Mi configuración
Al utilizar MQTT, tengo un único productor que publica mensajes sobre un tema y potencialmente varios consumidores que se suscriben a ese tema. El productor puede producir mensajes a una velocidad máxima determinada. Cada consumidor quiere procesar mensajes a un ritmo que sea exclusivo de ese consumidor individual. Si un consumidor recibe mensajes a un ritmo más rápido de lo que puede procesar, simplemente puede desechar los mensajes.
Mi preocupación
Por ejemplo, podría tener un productor que pueda enviar imágenes a una velocidad de, digamos, 100 imágenes por segundo, pero mis dos consumidores solo pueden consumirlas a una velocidad de 8 por segundo y 5 por segundo respectivamente. Para conservar los recursos de la red, la velocidad óptima de publicación aquí sería de 8 imágenes por segundo.
Mi pensamiento
Una forma de hacer que esto funcione es hacer que los productores y consumidores se conecten a un servicio común de “negociación de tarifas” cuyo propósito sería alterar la velocidad a la que el editor emite mensajes sobre el tema compartido.
Pregunta
¿Debería considerar el uso de otro protocolo para este propósito o habría algo más en común que debería considerar para ayudarme a abordar esta inquietud y resolver mi problema?