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

消息流程

clipboard.png

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

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

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

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题