我有一个问题需要解决,感觉这是一个常见问题,因此大概有一个常见的解决方案,即网络协议。我对网络协议有点有限,如果使用不同的协议是我真正需要的解决方案,我无法使用谷歌搜索找到现有的协议来解决这个问题。
我的配置
使用 MQTT,我有一个生产者向某个主题发布消息,并且可能有多个消费者订阅该主题。生产者可以以一定的最高速率生成消息。每个消费者都希望以特定速率处理消息。如果消费者接收消息的速度快于其处理速度,他们可以直接丢弃消息。
我的顾虑
例如,我可能有一个生产者可以以每秒 100 张的速度推送图像,但我的两个消费者只能分别以每秒 8 张和每秒 5 张的速度使用它们。为了节省网络资源,这里发布的最佳速率是每秒 8 张图像。
我的想法
实现这一目标的一种方法是让生产者和消费者连接到一个共同的“速率协商”服务,其目的是改变发布者向共享主题发送消息的速率。
问题
我是否应该考虑使用其他协议来实现此目的,或者是否有其他常见的协议可以帮助我解决这个问题并解决我的问题?