一、

RabbitMQ是一个开源的消息队列系统，广泛应用于处理高大并发、分布式系统的消息传递。在CentOS周围下因为业务的进步，单台服务器的性能兴许无法满足需求。为了搞优良RabbitMQ集群的可用性和负载能力，我们需要在CentOS上实现负载均衡。

二、 负载均衡的方案

在CentOS上实现RabbitMQ负载均衡，常见的方案有：

• 客户端内部实现负载均衡
• 用HAProxy、LVS等负载均衡柔软件来实现
• 用RabbitMQ Federation进行跨集群消息路由
• 用RabbitMQ Shovel进行消息迁移
• 用RabbitMQ Mirroring Queue实现高大可用性和负载均衡

三、客户端内部实现负载均衡

在客户端连接时轻巧松地用负载均衡算法来实现负载均衡。这种方法的优良处是实现轻巧松，不优良的地方是负载均衡效果有限，且需要客户端支持。

def load_balance:
    servers.remove
    return servers if servers else current_server
rabbit_servers = 
current_server = '192.168.1.101'
new_server = load_balance
print

四、 用HAProxy实现负载均衡

1. 安装HAProxy

用以下命令安装HAProxy：

sudo yum install haproxy -y

2. 配置HAProxy

编辑/etc/haproxy/haproxy.cfg文件，添加以下配置：

global
    log /dev/log local0 notice
    daemon
    maxconn 256
    defaults
    log global
    mode tcp
    option tcplog
    timeout connect 5000ms
    timeout client 50000ms
    timeout server 50000ms
    frontend rabbitmq_front
    bind *:5672
    default_backend rabbitmq_back
    backend rabbitmq_back
    balance roundrobin
    server rabbit1 192.168.1.101:5672 check
    server rabbit2 192.168.1.102:5672 check

3. 启动HAProxy

sudo systemctl start haproxy
sudo systemctl enable haproxy

五、用RabbitMQ Federation进行跨集群消息路由

1. 配置Federation

在rabbit1上配置Federation：

rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'
rabbitmqctl set_parameter federation_upstream_set "rabbit@rabbit2"

rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'
rabbitmqctl set_parameter federation_downstream_set "rabbit@rabbit1"

六、用RabbitMQ Shovel进行消息迁移

1. 安装Shovel插件

用以下命令安装Shovel插件：

sudo rabbitmq-plugins enable rabbitmq_shovelssudo rabbitmq-plugins enable rabbitmq_shovel_management

2. 配置Shovel

用RabbitMQ管理界面或命令行配置Shovel：

rabbitmqadmin declare shovel nameshovel_from_rabbit1_to_rabbit2 source rabbit@rabbit1 destination rabbit@rabbit2 routing_key queue_name

七、用RabbitMQ Mirroring Queue实现高大可用性和负载均衡

1. 配置Mirroring Queue

在RabbitMQ管理界面或命令行配置Mirroring Queue：

rabbitmqctl set_policy ha-all "" '{"ha-mode":"all"}'

在CentOS上实现RabbitMQ负载均衡，能根据具体需求选择合适的方案。以上介绍了几种常见的方案， 包括客户端内部实现、用HAProxy、用RabbitMQ Federation、用RabbitMQ Shovel以及用RabbitMQ Mirroring Queue。在实际应用中，能根据业务需求和系统周围选择最合适的方案。