百萬架構(gòu)師第三十七課：RabbitMq：高可用集群搭建步驟｜JavaGuide

安裝環(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)建目錄
[root@nogeek ]# mkdir -p /usr/local/tools/rabbitmq
[root@nogeek ]# cd /usr/local/tools/rabbitmq
3、下載安裝包
[root@nogeek ]# wget http://www.rabbitmq.com/releases/erlang/erlang-19.0.4-1.el6.x86_64.rpm
4、安裝
[root@nogeek ]# rpm -ivh erlang-19.0.4-1.el6.x86_64.rpm

二、安裝RabbitMQ

1、rabbitMQ 下載地址

https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/

2、下載安裝包

[root@nogeek ]# wget https://dl.bintray.com/rabbitmq/rabbitmq-server-rpm/rabbitmq-server-3.6.12-1.el6.noarch.rpm
[root@nogeek ]# rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc

3、安裝

[root@nogeek ]#  rpm -ivh rabbitmq-server-3.6.12-1.el6.noarch.rpm

問題解決

1、錯誤：依賴檢測失敗：
socat 被 rabbitmq-server-3.6.12-1.el6.noarch 需要

解決報(bào)錯：
[root@nogeek ]#  wget –no-cache http://www.convirture.com/repos/definitions/rhel/6.x/convirt.repo -O /etc/yum.repos.d/convirt.repo
[root@nogeek ]#  yum makecache -y
[root@nogeek ]#  yum install socat -y
2、如果yum源有問題，無法安裝：將CentOS的yum源更換為國內(nèi)的阿里云源

使用yum時File contains no section headers.解決辦法
http://xiaojingjing.iteye.com/blog/2393165

[root@nogeek ]#  rm -f /etc/yum.repos.d/*
[root@nogeek ]# wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
[root@nogeek ]# yum clean all

三、集群配置

1、hosts配置

三臺機(jī)器的hosts都配置

[root@nogeek ]# 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í)行：

[root@nogeek ]# scp .erlang.cookie root@192.168.8.45:/var/lib/rabbitmq/
[root@nogeek ]# chown rabbitmq:rabbitmq .erlang.cookie

在第三臺機(jī)器8.40執(zhí)行：

[root@nogeek ]# scp .erlang.cookie root@192.168.8.40:/var/lib/rabbitmq/
[root@nogeek ]# chown rabbitmq:rabbitmq .erlang.cookie

重啟服務(wù)

[root@nogeek ]# systemctl stop rabbitmq-server.service
[root@nogeek ]# systemctl start rabbitmq-server.service

或：

[root@nogeek ]# systemctl restart rabbitmq-server.service

查看服務(wù)狀態(tài)：

[root@nogeek ]# systemctl status rabbitmq-server.service

如果啟動報(bào)錯：

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、加入集群
首先開放集群通信端口：

[root@nogeek ]# firewall-cmd --permanent --add-port={5672/tcp,4369/tcp,25672/tcp}
[root@nogeek ]# firewall-cmd --reload
[root@nogeek ]# setsebool -P nis_enabled 1

在第二臺45，第三臺機(jī)，40上執(zhí)行：

[root@nogeek ]# rabbitmqctl stop_app
[root@nogeek ]# rabbitmqctl reset
[root@nogeek ]# rabbitmqctl join_cluster rabbit@rabbit1 --ram

創(chuàng)建用戶：三臺服務(wù)器都執(zhí)行

 [root@nogeek ]# firewall-cmd --permanent --add-port=15672/tcp
 [root@nogeek ]# firewall-cmd –-reload
 [root@nogeek ]# rabbitmqctl add_user admin admin
 [root@nogeek ]# rabbitmqctl set_user_tags admin administrator
 [root@nogeek ]# rabbitmqctl set_permissions -p / admin "." "." ".*"

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

5、HAProxy + Keepalived 高可用方案

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

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

 [root@nogeek ]#  yum install haproxy

2)編輯配置文件

 [root@nogeek ]# 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)計(jì)頁面自動刷新時間
        stats uri /haproxy?stats    #統(tǒng)計(jì)頁面url
        stats realm Haproxy Manager #統(tǒng)計(jì)頁面密碼框上提示文本
        stats auth admin:123456     #統(tǒng)計(jì)頁面用戶名和密碼設(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

 [root@nogeek ]# haproxy -f /etc/haproxy/haproxy.cfg

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

1)安裝Keepalived

 [root@nogeek ]# yum -y install keepalived

2)修改配置文件

 [root@nogeek ]# 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腳本
    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

[root@nogeek ]# keepalived -D

來源于: https://javaguide.net

?著作權(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)容