建站
咨詢
售后
建站咨詢
新聞中心
RabbitMQ是目前非常熱門(mén)的一款消息中間件，不管是互聯(lián)網(wǎng)大廠還是中小企業(yè)都在大量使用。作為一名合格的開(kāi)發(fā)者，有必要對(duì)RabbitMQ有所了解，本篇文章重點(diǎn)為大家講解一下配置高可用RabbitMQ集群具體方法。
創(chuàng)新互聯(lián)網(wǎng)站建設(shè)由有經(jīng)驗(yàn)的網(wǎng)站設(shè)計(jì)師、開(kāi)發(fā)人員和項(xiàng)目經(jīng)理組成的專業(yè)建站團(tuán)隊(duì)，負(fù)責(zé)網(wǎng)站視覺(jué)設(shè)計(jì)、用戶體驗(yàn)優(yōu)化、交互設(shè)計(jì)和前端開(kāi)發(fā)等方面的工作，以確保網(wǎng)站外觀精美、做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)易于使用并且具有良好的響應(yīng)性。
概述
運(yùn)行模式大概有3種：
單一模式：非集群模式，單臺(tái)。
普通模式：RabbitMQ默認(rèn)的集群模式。
對(duì)于Queue來(lái)說(shuō)，消息實(shí)體只存在于其中一個(gè)節(jié)點(diǎn)，A、B兩個(gè)節(jié)點(diǎn)僅有相同的元數(shù)據(jù)，即隊(duì)列結(jié)構(gòu)。當(dāng)消息進(jìn)入A節(jié)點(diǎn)的Queue中后，consumer從B節(jié)點(diǎn)拉取時(shí)，RabbitMQ會(huì)臨時(shí)在A、B間進(jìn)行消息傳輸，把A中的消息實(shí)體取出并經(jīng)過(guò)B發(fā)送給consumer。
所以consumer應(yīng)盡量連接每一個(gè)節(jié)點(diǎn)，從中取消息。即對(duì)于同一個(gè)邏輯隊(duì)列，要在多個(gè)節(jié)點(diǎn)建立物理Queue。否則無(wú)論consumer連A或B，出口總在A，會(huì)產(chǎn)生瓶頸。
該模式存在一個(gè)問(wèn)題就是當(dāng)A節(jié)點(diǎn)故障后，B節(jié)點(diǎn)無(wú)法取到A節(jié)點(diǎn)中還未消費(fèi)的消息實(shí)體。
如果做了消息持久化，那么得等A節(jié)點(diǎn)恢復(fù)，然后才可被消費(fèi)；如果沒(méi)有持久化會(huì)丟失消息。
鏡像模式：Queue同時(shí)存在多個(gè)節(jié)點(diǎn)，可通過(guò)改模式實(shí)現(xiàn)HA高可用 該模式解決了上述問(wèn)題，其實(shí)質(zhì)和普通模式不同之處在于，消息實(shí)體會(huì)主動(dòng)在鏡像節(jié)點(diǎn)間同步，而不是在consumer取數(shù)據(jù)時(shí)臨時(shí)拉取。
該模式帶來(lái)的副作用也很明顯，除了降低系統(tǒng)性能外，如果鏡像隊(duì)列數(shù)量過(guò)多，加之大量的消息進(jìn)入，集群內(nèi)部的網(wǎng)絡(luò)帶寬將會(huì)被這種同步通訊大大消耗掉。
下面來(lái)通過(guò)配置RabbitMQ鏡像模式來(lái)熟悉這3種運(yùn)行模式
1. 環(huán)境說(shuō)明
RabbitMQ集群安裝在3個(gè)節(jié)點(diǎn)上：10.0.0.1、10.0.0.2、10.0.0.3
HAProxy安裝在10.0.0.4上，用于對(duì)外提供RabbitMQ均衡
3個(gè)節(jié)點(diǎn)在/etc/hosts文件中分別添加如下內(nèi)容：
10.0.0.1 rabbit1
10.0.0.2 rabbit2
10.0.0.3 rabbit3
2. 安裝erlang、rabbitmq
cd oneinstack/src
wget http://erlang.org/download/otp_src_18.3.tar.gz
tar xzf otp_src_18.3.tar.gz
cd otp_src_18.3
./configure --prefix=/usr/local/erlang --enable-shared-zlib --with-ssl --enable-threads --enable-smp-support --enable-kernel-poll --enable-hipe --without-javac
make && make install
cd ..
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.7/rabbitmq-server-generic-unix-3.5.7.tar.gz
tar xzf rabbitmq-server-generic-unix-3.5.4.tar.gz
mv rabbitmq_server-3.5.4 rabbitmq
sed -i 's@^ERL_DIR=.*@ERL_DIR=/usr/local/erlang/bin/@' /usr/local/rabbitmq/sbin/rabbitmq-defaults
sed -i 's@^LOG_BASE=.*@LOG_BASE=/usr/local/rabbitmq/var/log/rabbitmq@' /usr/local/rabbitmq/sbin/rabbitmq-defaults #日志目錄
mkdir -p /usr/local/rabbitmq/var/{lib,log}/rabbitmq
3. 一般用戶（rabbitmq）運(yùn)行RabbitMQ
useradd rabbitmq
wget http://pkgs.fedoraproject.org/cgit/rpms/rabbitmq-server.git/plain/rabbitmq-script-wrapper
sed -i 's@cd /var/lib/rabbitmq@cd /usr/local/rabbitmq/var/lib/rabbitmq@g' rabbitmq-script-wrapper #更改rabbitmq數(shù)據(jù)存儲(chǔ)目錄
sed -i 's@/usr/lib/rabbitmq/bin/@/usr/local/rabbitmq/sbin/@g' rabbitmq-script-wrapper
chmod +x rabbitmq-script-wrapper
cp rabbitmq-script-wrapper /usr/sbin/rabbitmqctl
cp rabbitmq-script-wrapper /usr/sbin/rabbitmq-server
cp rabbitmq-script-wrapper /usr/sbin/rabbitmq-plugins
chown -R rabbitmq.rabbitmq /usr/local/rabbitmq/var
4. 日志割接
cat >> /etc/logrotate.d/rabbitmq-server local/rabbitmq/var/log/rabbitmq/*.log {
weekly
missingok
rotate 20
compress
delaycompress
notifempty
sharedscripts
postrotate
/sbin/service rabbitmq-server rotate-logs > /dev/null
endscript
}
EOF
5. 啟動(dòng)腳本
參考： 《RabbitMQ啟動(dòng)腳本》
6. 設(shè)置Erlang Cookie
Erlang Cookie文件：/home/rabbitmq/.erlang.cookie。這里將rabbit1的該文件復(fù)制到rabbit2、rabbit3，并設(shè)置400權(quán)限
chmod 400 /home/rabbitmq/.erlang.cookie
chown rabbitmq.rabbitmq /home/rabbitmq/.erlang.cookie
7. 修改配置文件
密碼和集群配置：
cat > /usr/local/rabbitmq/etc/rabbitmq/rabbitmq.config 'rabbit@rabbit1','rabbit@rabbit2', 'rabbit@rabbit3'], disc}},
{tcp_listeners,[{"0.0.0.0",5672}]},
{default_vhost, "/">>},
{default_user, "linuxeye">>},
{default_pass, "linuxeye@123">>},
{loopback_users, ["linuxeye"]},
{default_permissions, [".*">>, ".*">>, ".*">>]}
]}
].
EOF
啟用rabbitmq_management
cat > /usr/local/rabbitmq/etc/rabbitmq/enabled_plugins 8. 分別啟動(dòng)3個(gè)節(jié)點(diǎn)rabbitmq
使用rabbitmqctl cluster_status命令表示集群搭建成功
[root@rabbit2 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@rabbit2 ...
[{nodes,[{disc,[rabbit@rabbit1,rabbit@rabbit2,rabbit@rabbit3]}]},
{running_nodes,[rabbit@rabbit3,rabbit@rabbit1,rabbit@rabbit2]},
{cluster_name,"rabbit@rabbit2">>},
{partitions,[]}]
9. 設(shè)置鏡像隊(duì)列策略
在任意一個(gè)節(jié)點(diǎn)上執(zhí)行：
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
10. 配置HAProxy
配置好HAProxy后，瀏覽器訪問(wèn)http://10.0.0.4:15672, 看到如下證明rabbitmq鏡像模式搭建成功
RabbitMQ集群和高可用配置的技巧RabbitMQ集群和高可用配置的技巧
文章名稱：配置高可用RabbitMQ集群
URL地址：http://www.5511xx.com/article/copdshj.html
