【Java】spring 消息队列如何根据消费者负载进行消息调度

消息流程

【Java】spring 消息队列如何根据消费者负载进行消息调度

如何根据消费者负载进行消息调度

现在生产者产生任务,我想通过判断消费者所在主机的性能消耗来决策如何分配消息,我现在用的rabbitmq,不知能否实现这样的需求

回答

你要实现的是消费者的负载均衡,默认来说,RabbitMQ会按顺序得把消息发送给每个消费者(consumer)。平均每个消费者都会收到同等数量得消息。这种发送消息得方式叫做——轮询(round-robin)。试着添加三个或更多得工作者(workers)。当然你可以使用其他的负载均衡策略。
具体可参考:https://blog.csdn.net/u013256...

以上是 【Java】spring 消息队列如何根据消费者负载进行消息调度 的全部内容, 来源链接: utcz.com/a/89559.html

回到顶部