linux 配置mq 双机搭建

# 在两台服务器上安装RabbitMQ
sudo yum install -y erlang rabbitmq-server

sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

sudo rabbitmq-plugins enable rabbitmq_management

# 复制cookie文件到另一台服务器
scp /var/lib/rabbitmq/.erlang.cookie user@backup_server:/var/lib/rabbitmq/

# 在主服务器上执行
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

# 安装Keepalived
sudo yum install -y keepalived

# 配置Keepalived
cat <<EOF > /etc/keepalived/keepalived.conf
vrrp_instance VI_1 {
    state MASTER
    interface eth0
    virtual_router_id 51
    priority 100
    advert_int 1
    authentication {
        auth_type PASS
        auth_pass 1234
    }
    virtual_ipaddress {
        192.168.1.100
    }
}
EOF

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('192.168.1.100'))
channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")

connection.close()