新公司成立如何建设网站,搭建一个商城网站,免费logo设计在线设计,使用WordPress默认主题在《RabbitMQ实践——利用一致性Hash交换器做负载均衡》一文中#xff0c;我们介绍了如何开启一致性hash交换器#xff0c;并实现了消息的负载均衡#xff0c;以达到横向扩展消费者数量的能力。 但是现实中#xff0c;可能存在这样的场景#xff1a;一些队列所在的机器配置…在《RabbitMQ实践——利用一致性Hash交换器做负载均衡》一文中我们介绍了如何开启一致性hash交换器并实现了消息的负载均衡以达到横向扩展消费者数量的能力。 但是现实中可能存在这样的场景一些队列所在的机器配置较好一些队列所在的机器配置较差。这个时候我们希望配置较好的机器可以分发更多的消息而配置较差的队列分发相对较少的消息。这样我们就需要让转换器将消息更多的路由到配置好的机器所在的队列上。 一致性Hash交换器可以使用“权重”来完成这样的设计。 现在我们假设队列named_queue_b所在的机器配置较好希望它承载更多的消息。在《RabbitMQ实践——利用一致性Hash交换器做负载均衡》中实操的基础上我们修改了绑定关系Banding中路由到named_queue_b队列的权重——9。其他队列权重还是1这样理论上这些队列将受到较少的消息。 然后我们再使用代码向x.consistent.hash发送10,0000条消息 我们在队列页面可以看到named_queue_b被路由了80%消息。
