消息流程
如何根据消费者负载进行消息调度
现在生产者产生任务,我想通过判断消费者所在主机的性能消耗来决策如何分配消息,我现在用的rabbitmq,不知能否实现这样的需求
现在生产者产生任务,我想通过判断消费者所在主机的性能消耗来决策如何分配消息,我现在用的rabbitmq,不知能否实现这样的需求
4 回答891 阅读✓ 已解决
1 回答2.5k 阅读✓ 已解决
1 回答1.1k 阅读✓ 已解决
1 回答922 阅读✓ 已解决
2 回答1.6k 阅读
1 回答685 阅读✓ 已解决
1 回答833 阅读✓ 已解决
你要实现的是消费者的负载均衡,默认来说,RabbitMQ会按顺序得把消息发送给每个消费者(consumer)。平均每个消费者都会收到同等数量得消息。这种发送消息得方式叫做——轮询(round-robin)。试着添加三个或更多得工作者(workers)。当然你可以使用其他的负载均衡策略。
具体可参考:https://blog.csdn.net/u013256...