RabbitMQ高可用介绍
作者：yuzhen0228
1.全局图
2.首先要先安装RabbitMQ
#rpm -Uvh https://mirrors.tuna.tsinghua.edu.cn/epel/epel-release-latest-7.noarch.rpm
#yum install erlang
#wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm
#yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm
完成后启动服务：
#service rabbitmq-server start
可以查看服务状态：
#service rabbitmq-server status
3.配置rabbitmq cluster
cd /var/lib/rabbitmq
chmod u+w .erlang.cookie
vim /etc/hosts
10.64.16.123 l-rabbitmq1
10.64.17.11 l-rabbitmq2
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@ l-rabbitmq1
rabbitmqctl start_app
rabbitmqctl change_cluster_node_type ram (需要先停掉,才能更改)
4.mirror queue policy设置
rabbitmqctl set_policy ha-all "^ha\." '{"ha-mode":"all","ha-sync-mode":"automatic"}' //意思表示以ha.开头的queue都会复制到各个节点
5.Keepalived
yum -y install keepalived
vim /etc/keepalived/keepalived.conf :
! Configuration File for keepalived
global_defs {
notification_email {
acassen@firewall.loc
failover@firewall.loc
sysadmin@firewall.loc
}
notification_email_from Alexandre.Cassen@firewall.loc
smtp_server 192.168.200.1
smtp_connect_timeout 30
router_id LVS_DEVEL
vrrp_skip_check_adv_addr
#vrrp_strict #要注释掉
vrrp_garp_interval 0
vrrp_gna_interval 0
}
vrrp_script chk_haproxy {
script "service haproxy status" # 服务探测，返回0说明服务是正常的
interval 1 # 每隔1秒探测一次
weight -2 # 不正常时，权重-1，即haproxy上线，权重加2；下线，权重减2
}
vrrp_instance haproxy {
state MASTER # 主机为MASTER，备机为BACKUP
interface eth0 # 监测网络端口，用ifconfig查看
virtual_router_id 108 # 虚拟路由标识，同一个VRRP实例要使用同一个标识，主备机必须相同
priority 100 # 主备机取不同的优先级，确保主节点的优先级高过备用节点
advert_int 1 # VRRP Multicast广播周期秒数 用于设定主备节点间同步检查时间间隔
authentication {
auth_type PASS # VRRP认证方式
auth_pass 1234 # VRRP口令 主备机密码必须相同
}
track_script { # 调用haproxy进程检测脚本，备节点不配置
chk_haproxy
}
virtual_ipaddress {
10.64.16.254 #vip
}
notify_master "/etc/keepalived/notify.sh master" # 当前节点成为master时，通知脚本执行任务，一般用于启动某服务
notify_backup "/etc/keepalived/notify.sh backup" # 当前节点成为backup时，通知脚本执行任务，一般用于关闭某服务
}
! Configuration File for keepalived
global_defs {
notification_email {
acassen@firewall.loc
failover@firewall.loc
sysadmin@firewall.loc
}
notification_email_from Alexandre.Cassen@firewall.loc
smtp_server 192.168.200.1
smtp_connect_timeout 30
router_id LVS_DEVEL
vrrp_skip_check_adv_addr
# vrrp_strict #要注释掉
vrrp_garp_interval 0
vrrp_gna_interval 0
}
vrrp_script chk_haproxy {
script "service haproxy status" # 服务探测，返回0说明服务是正常的
interval 1 # 每隔1秒探测一次
weight -2 # 不正常时，权重-1，即haproxy上线，权重加2；下线，权重减2
}
vrrp_instance haproxy {
state BACKUP # 主机为MASTER，备机为BACKUP
interface eth0 # 监测网络端口，用ifconfig查看
virtual_router_id 108 # 虚拟路由标识，同一个VRRP实例要使用同一个标识，主备机必须相同
priority 99 # 主备机取不同的优先级，确保主节点的优先级高过备用节点
advert_int 1 # VRRP Multicast广播周期秒数 用于设定主备节点间同步检查时间间隔
authentication {
auth_type PASS # VRRP认证方式
auth_pass 1234 # VRRP口令 主备机密码必须相同
}
virtual_ipaddress { # VIP 漂移地址 即集群IP地址
10.64.16.254
}
}
#!/bin/bash
case "$1" in
master)
notify master
service haproxy start
exit 0
;;
backup)
notify backup
service haproxy stop
exit 0
;;
fault)
notify fault
service haproxy stop
exit 0
;;
*)
echo 'Usage: `basename $0` {master|backup|fault}'
exit 1
;;
esac
keepalived service keepalived restartnotify.sh脚本放在/etc/keepalived/目录下，并赋予可执行权限。6.Haproxy负载代理
yum install haproxy
vim /etc/haproxy/haproxy.cfg
#######################HAproxy监控页面#########################
listen http_front
bind 0.0.0.0:1080 #监听端口
stats refresh 30s #统计页面自动刷新时间
stats uri /haproxy?stats #统计页面url
stats realm Haproxy Manager #统计页面密码框上提示文本
stats auth admin:1234 #统计页面用户名和密码设置
#stats hide-version #隐藏统计页面上HAProxy的版本信息
#####################RabbitMQ的管理界面###############################
listen rabbitmq_admin
bind 10.64.16.254:15673
server l-rabbitmq1 10.64.16.123:15672
server l-rabbitmq2 10.64.17.11:15672
#####################RabbitMQ服务代理###########################################
listen rabbitmq_cluster 10.64.16.254:5673
mode tcp
stats enable
balance roundrobin
option tcpka
option tcplog
timeout client 3h
timeout server 3h
timeout connect 3h
#balance url_param userid
#balance url_param session_id check_post 64
#balance hdr(User-Agent)
#balance hdr(host)
#balance hdr(Host) use_domain_only
#balance rdp-cookie
#balance leastconn
#balance source //ip
server l-rabbitmq1 10.64.16.123:5672 check inter 5s rise 2 fall 3 #check inter 2000 是检测心跳频率，rise 2是2次正确认为服务器可用，fall 3是3次失败认为服务器不可用
server l-rabbitmq2 10.64.17.11:5672 check inter 5s rise 2 fall 3
haproxy -f haproxy.cfg启动
service haproxy restart
ip a
http://10.64.16.254:1080/haproxy?stats看一下监控页面，如果显示出正常就表明已经将 HAProxy 负载均衡配置好了。http://10.64.16.254:15673 rabbitmq管理页面
测试
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters('10.64.16.254',5673,virtual_host="/",credentials=pika.PlainCredentials(username="admin",password="1234")) # 默认端口5672，可不写
)
channel = connection.channel()
channel.queue_declare(queue='ha_1')
channel.basic_publish(exchange='',routing_key='ha_1',body='haha Hello World!')
connection.close() # 队列关闭
import pika
import time
connection = pika.BlockingConnection(pika.ConnectionParameters('10.64.16.254',5673,virtual_host="/",credentials=pika.PlainCredentials(username="admin",password="1234")) # 默认端口5672，可不写
)
channel = connection.channel()
channel.queue_declare(queue='ha_1')
def callback(ch, method, properties, body): # 四个参数为标准格式
print(" [x] Received %r" % body)
time.sleep(15)
ch.basic_ack(delivery_tag = method.delivery_tag)
print("done")
channel.basic_consume(callback,queue='ha_1')
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
相关文章