Eu tenho um problema que estou tentando resolver, que parece ser um problema comum e, portanto, provavelmente tem uma solução comum na forma de um protocolo de rede. Meu conhecimento de protocolos de rede é um pouco limitado e não consigo encontrar um protocolo existente para resolver esse problema usando a pesquisa do google se usar um protocolo diferente é a solução que realmente preciso.
Minha configuração
Usando o MQTT, tenho um único produtor publicando mensagens para um tópico e potencialmente vários consumidores inscrevendo-se nesse tópico. O produtor pode produzir mensagens a uma determinada taxa máxima. Cada consumidor deseja processar mensagens a uma taxa exclusiva para esse consumidor individual. Se um consumidor receber mensagens a uma taxa mais rápida do que pode processar, ele pode simplesmente jogar fora as mensagens.
Minha preocupação
Por exemplo, posso ter um produtor capaz de enviar imagens a 100 imagens por segundo, mas meus 2 consumidores só podem consumi-las a uma taxa de 8 por segundo e 5 por segundo, respectivamente. Para conservar recursos de rede, a taxa ideal de publicação aqui seria de 8 imagens por segundo.
Meu pensamento
Uma maneira de fazer isso funcionar é fazer com que os produtores e consumidores se conectem a um serviço comum de "negociação de taxa" cuja finalidade seria alterar a taxa na qual o editor está emitindo mensagens para o tópico compartilhado.
Pergunta
Devo considerar a possibilidade de usar outro protocolo para essa finalidade ou haveria algo mais comum que eu devesse considerar para ajudar a resolver essa preocupação e resolver meu problema?