docker run -d --name RabbitMQ -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=123456 -p 15672:15672 rabbitmq:4.0-management

[root@tiaoban ~]# wget https://packagecloud.io/rabbitmq/erlang/packages/el/8/erlang-26.2.5.3-1.el8.x86_64.rpm/download.rpm -O ./erlang-26.2.5.3-1.el8.x86_64.rpm
[root@tiaoban ~]# ls
erlang-26.2.5.3-1.el8.x86_64.rpm
# 安裝erlang
[root@tiaoban ~]# rpm -ivh erlang-26.2.5.3-1.el8.x86_64.rpm
警告：erlang-26.2.5.3-1.el8.x86_64.rpm: 頭V4 RSA/SHA256 Signature, 密鑰 ID 6026dfca: NOKEY
Verifying...                          ################################# [100%]
準(zhǔn)備中...                          ################################# [100%]
正在升級/安裝...
   1:erlang-26.2.5.3-1.el8            ################################# [100%]
# 驗證
[root@tiaoban ~]# erl -v
Erlang/OTP 26 [erts-14.2.5.3] [source] [64-bit] [smp:4:4] [ds:4:4:10] [async-threads:1] [jit:ns]

Eshell V14.2.5.3 (press Ctrl+G to abort, type help(). for help)
1>

[root@tiaoban ~]# dnf -y install socat logrotate

[root@tiaoban ~]# wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v4.0.1/rabbitmq-server-4.0.1-1.el8.noarch.rpm
[root@tiaoban ~]# ls
erlang-26.2.5.3-1.el8.x86_64.rpm  k8s  rabbitmq-server-4.0.1-1.el8.noarch.rpm
[root@tiaoban ~]# rpm -ivh rabbitmq-server-4.0.1-1.el8.noarch.rpm
警告：rabbitmq-server-4.0.1-1.el8.noarch.rpm: 頭V4 RSA/SHA512 Signature, 密鑰 ID 6026dfca: NOKEY
Verifying...                          ################################# [100%]
準(zhǔn)備中...                          ################################# [100%]
正在升級/安裝...
   1:rabbitmq-server-4.0.1-1.el8      ################################# [100%]
[/usr/lib/tmpfiles.d/rabbitmq-server.conf:1] Line references path below legacy directory /var/run/, updating /var/run/rabbitmq → /run/rabbitmq; please update the tmpfiles.d/ drop-in file accordingly.

[root@tiaoban ~]# systemctl start rabbitmq-server
[root@tiaoban ~]# systemctl enable rabbitmq-server
Created symlink /etc/systemd/system/multi-user.target.wants/rabbitmq-server.service → /usr/lib/systemd/system/rabbitmq-server.service.
[root@tiaoban ~]# systemctl status rabbitmq-server

[root@tiaoban ~]# rabbitmq-plugins enable rabbitmq_management

[root@mq1 ~]# cat /etc/hosts
192.168.10.93  mq1
192.168.10.94  mq2
192.168.10.95  mq3

[root@mq1 ~]# systemctl enable rabbitmq-server --now

[root@mq1 ~]# ls /var/lib/rabbitmq/.erlang.cookie
/var/lib/rabbitmq/.erlang.cookie
[root@mq1 ~]# scp /var/lib/rabbitmq/.erlang.cookie mq2:/var/lib/rabbitmq/                                                                                                                      100%   20     9.4KB/s   00:00
[root@mq1 ~]# scp /var/lib/rabbitmq/.erlang.cookie mq3:/var/lib/rabbitmq/
# 確保復(fù)制后的文件權(quán)限為400：
[root@mq2 ~]# chmod 400 /var/lib/rabbitmq/.erlang.cookie

[root@mq2 ~]# systemctl restart rabbitmq-server
[root@mq2 ~]# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@mq2 ...
[root@mq2 ~]# rabbitmqctl join_cluster rabbit@mq1
Clustering node rabbit@mq2 with rabbit@mq1
[root@mq2 ~]# rabbitmqctl start_app
Starting node rabbit@mq2 ...

[root@mq3 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq3 ...
Basics

Cluster name: rabbit@mq3
Total CPU cores available cluster-wide: 12

Disk Nodes

rabbit@mq1
rabbit@mq2
rabbit@mq3

Running Nodes

rabbit@mq1
rabbit@mq2
rabbit@mq3

Versions

rabbit@mq3: RabbitMQ 4.0.1 on Erlang 26.2.5.3
rabbit@mq1: RabbitMQ 4.0.1 on Erlang 26.2.5.3
rabbit@mq2: RabbitMQ 4.0.1 on Erlang 26.2.5.3

CPU Cores

Node: rabbit@mq3, available CPU cores: 4
Node: rabbit@mq1, available CPU cores: 4
Node: rabbit@mq2, available CPU cores: 4

Maintenance status

Node: rabbit@mq3, status: not under maintenance
Node: rabbit@mq1, status: not under maintenance
Node: rabbit@mq2, status: not under maintenance

# 所有mq節(jié)點執(zhí)行
[root@mq1 ~]# rabbitmq-plugins enable rabbitmq_management
# 其中一個節(jié)點執(zhí)行
[root@mq1 ~]# rabbitmqctl add_user admin 123.com
Adding user "admin" ...
Done. Dont forget to grant the user permissions to some virtual hosts! See 'rabbitmqctl help set_permissions' to learn more.
[root@mq1 ~]# rabbitmqctl set_user_tags admin administrator
Setting tags for user "admin" to [administrator] ...
[root@mq1 ~]# rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
Setting permissions for user "admin" in vhost "/" ...

[root@hk1 ~]# dnf -y install haproxy

[root@hk1 ~]# cp /etc/haproxy/haproxy.cfg /etc/haproxy/haproxy.cfg.bak
[root@hk1 ~]# vim /etc/haproxy/haproxy.cfg
# 開啟管理員監(jiān)控頁面
listen admin_stats
    bind    *:8080    #監(jiān)聽的ip端口號
    stats   enable
    stats   refresh 30s   #統(tǒng)計頁面自動刷新時間
    stats   uri /admin    #訪問的uri   ip:8080/admin
    stats   realm haproxy
    stats   auth admin:admin  #認(rèn)證用戶名和密碼
    stats   hide-version   #隱藏HAProxy的版本號
    stats   admin if TRUE   #管理界面，如果認(rèn)證成功了，可通過webui管理節(jié)點                       
# 配置前端監(jiān)聽
frontend main
    bind *:5672 # 監(jiān)聽地址
    default_backend  rabbitmq # 匹配后端服務(wù)
# 配置后端代理
backend rabbitmq # 后端服務(wù)名稱
    server  rabbitmq1 192.168.10.93:5672 check
    server  rabbitmq2 192.168.10.94:5672 check
    server  rabbitmq3 192.168.10.95:5672 check

[root@hk1 ~]# systemctl start haproxy.service 
[root@hk1 ~]# systemctl enable haproxy.service 
Created symlink /etc/systemd/system/multi-user.target.wants/haproxy.service → /usr/lib/systemd/system/haproxy.service.
[root@hk1 ~]# ss -tunlp | grep haproxy
udp   UNCONN 0      0            0.0.0.0:59334      0.0.0.0:*    users:(("haproxy",pid=2489,fd=6),("haproxy",pid=2487,fd=6))
tcp   LISTEN 0      2048         0.0.0.0:5672       0.0.0.0:*    users:(("haproxy",pid=2489,fd=7))                          
tcp   LISTEN 0      2048         0.0.0.0:8080       0.0.0.0:*    users:(("haproxy",pid=2489,fd=5))

[root@hk1 ~]# dnf -y install keepalived

[root@hk1 ~]# cp /etc/keepalived/keepalived.conf /etc/keepalived/keepalived.conf.bak
[root@hk1 ~]# vim /etc/keepalived/keepalived.conf
! Configuration File for keepalived

global_defs {
   router_id LVS_DEVEL # vrrp協(xié)議路由標(biāo)識
}

vrrp_instance VI_1 {
    state MASTER # 定義主從類型
    interface ens160 # 網(wǎng)卡名稱
    virtual_router_id 51 # vrrp唯一id號
    priority 100 # 優(yōu)先級主大于備
    advert_int 1 # 心跳檢測時間間隔
    authentication { # 認(rèn)證類型和密碼
        auth_type PASS
        auth_pass 1111
    }
    virtual_ipaddress { # vip配置
        192.168.10.90/24
    }
}

[root@hk1 ~]# systemctl start keepalived.service 
[root@hk1 ~]# systemctl enable keepalived.service 
[root@hk1 ~]# ip a 
1: lo: <LOOPBACK,UP,LOWER_UP> mtu 65536 qdisc noqueue state UNKNOWN group default qlen 1000
    link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
    inet 127.0.0.1/8 scope host lo
       valid_lft forever preferred_lft forever
    inet6 ::1/128 scope host 
       valid_lft forever preferred_lft forever
2: ens160: <BROADCAST,MULTICAST,UP,LOWER_UP> mtu 1500 qdisc mq state UP group default qlen 1000
    link/ether 00:0c:29:2a:b6:b3 brd ff:ff:ff:ff:ff:ff
    altname enp3s0
    inet 192.168.10.91/24 brd 192.168.10.255 scope global noprefixroute ens160
       valid_lft forever preferred_lft forever
    inet 192.168.10.90/24 scope global secondary ens160
       valid_lft forever preferred_lft forever

! Configuration File for keepalived

global_defs {
   router_id LVS_DEVEL
}

vrrp_instance VI_1 {
    state BACKUP # 主備類型
    interface ens160 
    virtual_router_id 51
    priority 99 # 優(yōu)先級低于主
    advert_int 1
    authentication {
        auth_type PASS
        auth_pass 1111
    }
    virtual_ipaddress {
        192.168.10.90/24
    }
}

[root@hk2 ~]# ip a
1: lo: <LOOPBACK,UP,LOWER_UP> mtu 65536 qdisc noqueue state UNKNOWN group default qlen 1000
    link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
    inet 127.0.0.1/8 scope host lo
       valid_lft forever preferred_lft forever
    inet6 ::1/128 scope host 
       valid_lft forever preferred_lft forever
2: ens160: <BROADCAST,MULTICAST,UP,LOWER_UP> mtu 1500 qdisc mq state UP group default qlen 1000
    link/ether 00:0c:29:17:68:2a brd ff:ff:ff:ff:ff:ff
    altname enp3s0
    inet 192.168.10.92/24 brd 192.168.10.255 scope global noprefixroute ens160
       valid_lft forever preferred_lft forever
    inet 192.168.10.90/24 scope global secondary ens160
       valid_lft forever preferred_lft forever

rabbitmqctl stop [{pid_file}]
# 表示stop 在RabbitMQ服務(wù)器上運行的一個Erlang 節(jié)點，可以指定某一個 *pid_file*，表示會等待這個指定的程序結(jié)束

rabbitmqctl shutdown
# 表示終止RabbitMQ 服務(wù)器上的Erlang進(jìn)程，如果終止失敗，會返回非零數(shù)字

rabbitmqctl stop_app
# 表示終止RabbitMQ的應(yīng)用，但是Erlang節(jié)點還在運行。該命令典型的運行在一些需要RabbitMQ應(yīng)用被停止的管理行為之前，例如 reset

rabbitmqctl start_app
# 表示啟動RabbitMQ的應(yīng)用。該命令典型的運行在一些需要RabbitMQ應(yīng)用被停止的管理行為之后，例如 reset

rabbitmqctl wait {pid_file}
# 表示等待RabbitMQ應(yīng)用啟動。該命令會等待指定的pid file被創(chuàng)建，也就是啟動的進(jìn)程對應(yīng)的pid保存在這個文件中，然后RabbitMQ應(yīng)用在這個進(jìn)程中啟動。如果該進(jìn)程終止，沒有啟動RabbitMQ應(yīng)用，就會返回錯誤。
# 合適的pid file是有rabbitmq-server 腳本創(chuàng)建的，默認(rèn)保存在 Mnesia 目錄下，可以通過修改 RABBITMQ_PID_FILE 環(huán)境變量來修改
# 例如 rabbitmqctl wait /var/run/rabbitmq/pid

rabbitmqctl reset
# 表示設(shè)置RabbitMQ節(jié)點為原始狀態(tài)。會從該節(jié)點所屬的cluster中都刪除，從管理數(shù)據(jù)庫中刪除所有數(shù)據(jù)，例如配置的用戶和vhost，還會刪除所有的持久消息。
# 要想reset和force_reset操作執(zhí)行成功，RabbitMQ應(yīng)用需要處于停止?fàn)顟B(tài)，即執(zhí)行過 stop_app

rabbitmqctl force_reset
# 表示強(qiáng)制性地設(shè)置RabbitMQ節(jié)點為原始狀態(tài)。它和reset的區(qū)別在于，可以忽略目前管理數(shù)據(jù)庫的狀態(tài)和cluster的配置，無條件的reset。
# 該方法的使用，應(yīng)當(dāng)用在當(dāng)數(shù)據(jù)庫或者cluster配置損壞的情況下作為最后的方法。

rabbitmqctl rotate_logs {suffix}
# 表示將日志文件的內(nèi)容追加到新的日志文件中去，這個新的日志文件的文件名是原有的日志文件名加上命令中的 suffix，并且恢復(fù)日志到原來位置的新文件中。
# 注意：如果新文件原先不存在，那么會新建一個；如果suffix為空，那么不會發(fā)生日志轉(zhuǎn)移，只是重新打開了一次日志文件而已。

rabbitmqctl hipe_compile {directory}
# 表示在指定的目錄下執(zhí)行HiPE編譯和緩存結(jié)果文件 .beam-files
# 如果需要父目錄會被創(chuàng)建。并且在編譯之前，該目錄下的所有 .beam-files會被自動刪除。
# 使用預(yù)編譯的文件，你應(yīng)該設(shè)置 RABBITMQ_SERVER_CODE_PATH 環(huán)境變量為 hipe_compile 調(diào)用指定的目錄。

rabbitmqctl join_cluster {clusternode} [--ram]
# 表示結(jié)合到指定的集群，如果有參數(shù) --ram 表示作為RAM節(jié)點結(jié)合到該集群中。
# 該命令指令本節(jié)結(jié)合到指定的集群中，在結(jié)合之前，該節(jié)點需要reset，所以在使用時，需要格外注意。為了成功運行本命令，必須要停止RabbitMQ應(yīng)用，例如 stop_app
# 集群節(jié)點有兩種類型: disc 和 RAM。disc類型，復(fù)制數(shù)據(jù)在RAM和disc上，在節(jié)點失效的情況下，提供了冗余保證，也能從一些全局事件中恢復(fù)，例如所有節(jié)點失效。RAM類型，只復(fù)制數(shù)據(jù)在RAM上，主要表現(xiàn)在伸縮性上，特別是在管理資源（例如：增加刪除隊列，交換器，或者綁定）上表現(xiàn)突出。
# 一個集群必須至少含有一個disc節(jié)點，當(dāng)通常都多余一個。通過該命令時，默認(rèn)是設(shè)置為disc節(jié)點，如果需創(chuàng)建RAM節(jié)點，需要指定參數(shù) --ram
# 執(zhí)行此命令之后，在該節(jié)點上啟動的RabbitMQ應(yīng)用，在該節(jié)點掛掉之后，會嘗試連接節(jié)點所在集群中的其他節(jié)點。
# 為了離開集群，可以 reset 該節(jié)點，也可以使用命令 forget_cluster_node 遠(yuǎn)程刪除節(jié)點

rabbitmqctl cluster_status
# 表示顯示通過節(jié)點類型聚合在一起的集群中的所有節(jié)點，還有目前正在運行的節(jié)點

rabbitmqctl change_cluster_node_type {disc|ram}
# 表示改變集群節(jié)點的類型。該操作的正確執(zhí)行，必定會停止該節(jié)點。并且在調(diào)整一個node為ram類型時，該節(jié)點不能為該集群的唯一node

rabbitmqctl forget_cluster_node [--offline]
# 表示遠(yuǎn)程移除一個集群節(jié)點。要刪除的節(jié)點必須脫機(jī)，如果沒有脫機(jī)，需要使用 --offline 參數(shù)。當(dāng)使用 --offline 參數(shù)時，rabbitmqctl不會去連接節(jié)點，而是暫時變成節(jié)點，以便進(jìn)行變更。這在節(jié)點不能正常啟動時非常有用。在這種情況下，節(jié)點會成為集群元數(shù)據(jù)的規(guī)范來源（例如哪些隊列存在）。因此如果可以的話，應(yīng)該使用此命令在最新的節(jié)點上關(guān)閉。
# --offline 參數(shù)使節(jié)點從脫機(jī)節(jié)點上移除。使用場景主要是在所有節(jié)點脫機(jī)，且最后一個節(jié)點無法聯(lián)機(jī)時，從而防止整個集群啟動。在其他情況不應(yīng)該使用，否則會導(dǎo)致不一致。
# 例如 rabbitmqctl -n hare@mcnulty forget_cluster_node  rabbit@stringer
# 上述命令將從節(jié)點 hare@mcnulty 中移除節(jié)點 rabbit@stringer

rabbitmqctl rename_cluster_node {oldnode1} {newnode1} [oldnode2] [newnode2...]
# 表示在本地數(shù)據(jù)庫上修改集群節(jié)點名稱。該命令讓rabbitmqctl暫時成為一個節(jié)點來做出做變更。因此，本地的待修改的集群節(jié)點一定要完全停止，其他節(jié)點可以是online或者offline

rabbitmqctl update_cluster_nodes {clusternode}
# 表示指示已經(jīng)集群的節(jié)點在喚醒時聯(lián)系 {clusternode} 進(jìn)行集群。這與 join_cluster 命令不同，因為它不加入任何集群，它是檢查節(jié)點是否已經(jīng)在具有 {clusternode} 的集群中。
# 該命令的需求，是在當(dāng)一個節(jié)點offline時，修改了集群節(jié)點的情形下。例如：節(jié)點A和B聚群，節(jié)點A offline了，節(jié)點C和B集群，并且B節(jié)點離開了該集群，那么當(dāng)節(jié)點A起來的時候，A會嘗試連接B，但是由于B節(jié)點已經(jīng)不在該集群中，所以會失敗。
# 通過 update_cluster_nodes -n A C 將會解決上述問題。

rabbitmqctl force_boot
# 表示強(qiáng)制確保節(jié)點啟動，即使該節(jié)點并不是最后down的。
# 一般情況下，當(dāng)你同時shut down了RabbitMQ集群時，第一個重啟的節(jié)點應(yīng)該是最后一個down掉的，因為它可能已經(jīng)看到了其他節(jié)點發(fā)生的事情。但是有時候這并不可能：例如當(dāng)整個集群lose power，那么該集群的所有節(jié)點會認(rèn)為他們不是最后一個關(guān)閉的。
# 如果最后down的節(jié)點永久的lost，那么應(yīng)該優(yōu)先使用 rabbitmqctl forget_cluster_node --offline ，因為這將確保在丟失節(jié)點上的鏡像隊列得到優(yōu)先處理。

rabbitmqctl sync_queue [-p vhost] {queue}
# {queue} 表示待同步的隊列名稱
# 指引含有異步slaves的鏡像隊列去同步自身。當(dāng)隊列執(zhí)行同步化時，其將會被鎖定（指所有publishers發(fā)送出去的和consumers獲取到的隊列都會被鎖定）。為了成功執(zhí)行此命令，隊列必須要被鏡像。
# 注意，排除消息的異步隊列將最終被同步化，此命令主要運用于未被排除完全消息的隊列。

rabbitmqctl cancel_sync_queue [-p vhost] {queue}
# 指引一個正在同步的鏡像隊列停止此操作。

rabbitmqctl purge_queue [-p vhost] {queue}
# {queue} 表示待清空消息的隊列名稱
# 該命令表示清空隊列（即刪除隊列中的所有消息）

rabbitmqctl set_cluster_name {name}
# 設(shè)置集群的名稱。在連接中，集群的名稱被聲明在客戶端上，被同盟和插件用來記錄一個消息所在的位置。集群的名稱默認(rèn)來自于集群中第一個節(jié)點的主機(jī)名，但是可以被修改。

# 添加用戶
rabbitmqctl add_user 用戶名 密碼

# 設(shè)置用戶角色,分配操作權(quán)限
rabbitmqctl set_user_tags 用戶名 角色

# 為用戶添加資源權(quán)限(授予訪問虛擬機(jī)根節(jié)點的所有權(quán)限)
rabbitmqctl set_permissions -p / 用戶名 ".*" ".*" ".*"

# 修改密碼
rabbitmqctl change_ password 用戶名 新密碼

# 刪除用戶
rabbitmqctl delete_user 用戶名

# 查看用戶清單
rabbitmqctl list_users

[root@tiaoban ~]# rabbitmqctl add_user admin 123.com
Adding user "admin" ...
Done. Dont forget to grant the user permissions to some virtual hosts! See 'rabbitmqctl help set_permissions' to learn more.
[root@tiaoban ~]# rabbitmqctl set_user_tags admin administrator
Setting tags for user "admin" to [administrator] ...
[root@tiaoban ~]# rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
Setting permissions for user "admin" in vhost "/" ...

rabbitmqctl add_vhost {vhost}
# ｛vhost｝ 表示待創(chuàng)建的虛擬主機(jī)項的名稱

rabbitmqctl delete_vhost {vhost}
# 表示刪除一個vhost。刪除一個vhost將會刪除該vhost的所有exchange、queue、binding、用戶權(quán)限、參數(shù)和策略。

rabbitmqctl list_vhosts {vhostinfoitem ...}
# 表示列出所有的vhost。其中 {vhostinfoitem} 表示要展示的vhost的字段信息，展示的結(jié)果將按照 {vhostinfoitem} 指定的字段順序展示。這些字段包括：name（名稱） 和 tracing （是否為此vhost啟動跟蹤）。
# 如果沒有指定具體的字段項，那么將展示vhost的名稱。

rabbitmqctl set_permissions [-p vhost] {user} {conf} {write} {read}
# 表示設(shè)置用戶權(quán)限。 {vhost} 表示待授權(quán)用戶訪問的vhost名稱，默認(rèn)為 "/"； {user} 表示待授權(quán)反問特定vhost的用戶名稱； {conf}表示待授權(quán)用戶的配置權(quán)限，是一個匹配資源名稱的正則表達(dá)式； {write} 表示待授權(quán)用戶的寫權(quán)限，是一個匹配資源名稱的正則表達(dá)式； {read}表示待授權(quán)用戶的讀權(quán)限，是一個資源名稱的正則表達(dá)式。
# rabbitmqctl set_permissions -p myvhost tonyg "^tonyg-.*" ".*" ".*"
# 例如上面例子，表示授權(quán)給用戶 "tonyg" 在vhost為 `myvhost` 下有資源名稱以 "tonyg-" 開頭的 配置權(quán)限；所有資源的寫權(quán)限和讀權(quán)限。

rabbitmqctl clear_permissions [-p vhost] {username}
# 表示設(shè)置用戶拒絕訪問指定指定的vhost，vhost默認(rèn)值為 "/"

rabbitmqctl list_permissions [-p vhost]
# 表示列出具有權(quán)限訪問指定vhost的所有用戶、對vhost中的資源具有的操作權(quán)限。默認(rèn)vhost為 "/"。
# 注意，空字符串表示沒有任何權(quán)限。

rabbitmqctl list_user_permissions {username}
# 表示列出指定用戶的權(quán)限vhost，和在該vhost上的資源可操作權(quán)限。