RabbitMq 高可用集群搭建

安裝環(huán)境
Centos-7

三臺虛擬機(jī)
192.168.8.150(磁盤節(jié)點(diǎn))
192.168.8.45 (內(nèi)存節(jié)點(diǎn))
192.168.8.40 (內(nèi)存節(jié)點(diǎn))

一、安裝Erlang
1、erlang 下載地址:
http://www.rabbitmq.com/releases/erlang/

2、創(chuàng)建目錄
mkdir -p /usr/local/tools/rabbitmq
cd /usr/local/tools/rabbitmq

3、下載安裝包
wget http://www.rabbitmq.com/releases/erlang/erlang-19.0.4-1.el6.x86_64.rpm

4、安裝
rpm -ivh erlang-19.0.4-1.el6.x86_64.rpm

二、安裝RabbitMQ
1、rabbitMQ 下載地址
https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/

2、下載安裝包
wget https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/rabbitmq-server-3.6.12-1.el6.noarch.rpm
rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc

3、安裝
rpm -ivh rabbitmq-server-3.6.12-1.el6.noarch.rpm

問題解決
1、錯誤:依賴檢測失?。?br> socat 被 rabbitmq-server-3.6.12-1.el6.noarch 需要
解決報錯:
wget –no-cache http://www.convirture.com/repos/definitions/rhel/6.x/convirt.repo -O /etc/yum.repos.d/convirt.repo
yum makecache -y
yum install socat -y

2、如果yum源有問題,無法安裝:將CentOS的yum源更換為國內(nèi)的阿里云源
使用yum時File contains no section headers.解決辦法
http://xiaojingjing.iteye.com/blog/2393165
rm -f /etc/yum.repos.d/*
wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
yum clean all

三、集群配置
1、hosts配置
三臺機(jī)器的hosts都配置
vim /etc/hosts
192.168.8.150 rabbit1 (磁盤節(jié)點(diǎn))
192.168.8.45 rabbit2(內(nèi)存節(jié)點(diǎn))
192.168.8.40 rabbit3(內(nèi)存節(jié)點(diǎn))

2、同步.erlang.cookie
保持三臺機(jī)器的.erlang.cookie同步
/var/lib/rabbitmq/.erlang.cookie

在第二臺機(jī)器8.45執(zhí)行:
scp .erlang.cookie root@192.168.8.45:/var/lib/rabbitmq/
chown rabbitmq:rabbitmq .erlang.cookie

在第三臺機(jī)器8.40執(zhí)行:
scp .erlang.cookie root@192.168.8.40:/var/lib/rabbitmq/
chown rabbitmq:rabbitmq .erlang.cookie

重啟服務(wù)
systemctl stop rabbitmq-server.service
systemctl start rabbitmq-server.service

或:systemctl restart rabbitmq-server.service
查看服務(wù)狀態(tài):systemctl status rabbitmq-server.service

如果啟動報錯:
Job for rabbitmq-server.service failed because the control process exited with error code. See "systemctl status rabbitmq-server.service" and "journalctl -xe" for details.

如果是因?yàn)榉?wù)停不掉,就要kill 端口。

3、加入集群
首先開放集群通信端口:

firewall-cmd --permanent --add-port={5672/tcp,4369/tcp,25672/tcp}

firewall-cmd --reload

setsebool -P nis_enabled 1

在第二臺45,第三臺機(jī),40上執(zhí)行:
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@rabbit1 --ram

創(chuàng)建用戶:三臺服務(wù)器都執(zhí)行
firewall-cmd --permanent --add-port=15672/tcp
firewall-cmd –-reload
rabbitmqctl add_user admin admin
rabbitmqctl set_user_tags admin administrator
rabbitmqctl set_permissions -p / admin "." "." ".*"

4、
RabbitMQ鏡像隊列
可以參考:
https://www.cnblogs.com/saneri/p/7798251.html

5、HAProxy + Keepalived 高可用方案

一、HAProxy
將5672端口映射為5673端口,15672端口映射為15673端口。

1)在兩個內(nèi)存節(jié)點(diǎn)上安裝HAProxy
yum install haproxy

2)編輯配置文件
vim /etc/haproxy/haproxy.cfg

內(nèi)容修改為:
global
log 127.0.0.1 local2
chroot /var/lib/haproxy
pidfile /var/run/haproxy.pid
maxconn 4000
user haproxy
group haproxy
daemon
stats socket /var/lib/haproxy/stats

defaults
log global
option dontlognull
option redispatch
retries 3
timeout connect 10s
timeout client 1m
timeout server 1m
maxconn 3000

listen http_front
mode http
bind 0.0.0.0:1080 #監(jiān)聽端口
stats refresh 30s #統(tǒng)計頁面自動刷新時間
stats uri /haproxy?stats #統(tǒng)計頁面url
stats realm Haproxy Manager #統(tǒng)計頁面密碼框上提示文本
stats auth admin:123456 #統(tǒng)計頁面用戶名和密碼設(shè)置

listen rabbitmq_admin
bind 0.0.0.0:15673
server node1 192.168.8.40:15672
server node2 192.168.8.45:15672

listen rabbitmq_cluster 0.0.0.0:5673
mode tcp
balance roundrobin
timeout client 3h
timeout server 3h
timeout connect 3h
server node1 192.168.8.40:5672 check inter 5s rise 2 fall 3
server node2 192.168.8.45:5672 check inter 5s rise 2 fall 3

3)啟動HAProxy
haproxy -f /etc/haproxy/haproxy.cfg

二、在兩個內(nèi)存節(jié)點(diǎn)上安裝Keepalived
VIP 為 192.168.8.201

1)安裝Keepalived
yum -y install keepalived

2)修改配置文件
vim /etc/keepalived/keepalived.conf

內(nèi)容改成(物理網(wǎng)卡和當(dāng)前主機(jī)IP要修改):
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 # 注釋掉,不然訪問不到VIP

vrrp_garp_interval 0
vrrp_gna_interval 0
}
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 # 注釋掉,不然訪問不到VIP

vrrp_garp_interval 0
vrrp_gna_interval 0
}

檢測任務(wù)

vrrp_script check_haproxy {
# 檢測HAProxy監(jiān)本
script "/etc/keepalived/script/check_haproxy.sh"
# 每隔兩秒檢測
interval 2
# 權(quán)重
weight 2
}

虛擬組

vrrp_instance haproxy {
state MASTER # 此處為,備機(jī)是 BACKUP【此處要修改】
interface ens33 # 物理網(wǎng)卡,根據(jù)情況而定 【此處要修改】
mcast_src_ip 192.168.8.40 # 當(dāng)前主機(jī)ip 【此處要修改】
virtual_router_id 51 # 虛擬路由id,同一個組內(nèi)需要相同
priority 100 # 主機(jī)的優(yōu)先權(quán)要比備機(jī)高
advert_int 1 # 心跳檢查頻率,單位:秒
authentication { # 認(rèn)證,組內(nèi)的要相同
auth_type PASS
auth_pass 1111
}
# 調(diào)用腳本
track_script {
check_haproxy
}
# 虛擬ip,多個換行
virtual_ipaddress {
192.168.8.201
}
}

3)啟動keepalived
keepalived -D

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容