RabbitMQ单机群集

作者

简介

RabbitMQ是一款实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写，而群集和故障转移是构建在开放电信平台框架上的。所有主要的语言均有与代理接口通讯的客户端库。由于文档写了很多，下面就精简一下，把单机群集拿出来讲下。

安装依赖

安装Erlang/OTP和socat，Yum安装方式:

yum install -y epel-release
yum install -y erlang socat

源码安装方式:

yum install -y gcc gcc-c++ libtool ncurses-devel
wget wget http://zlib.net/zlib-1.2.11.tar.xz
tar Jxf zlib-1.2.11.tar.xz -C /usr/local/src/
cd /usr/local/src/zlib-1.2.11/
CFLAGS="-fPIC -O3" ./configure --shared –64
make -j `cat /proc/cpuinfo | grep processor | wc -l`;make install
chcon -R -u system_u /usr/local/lib/libz.so*
echo '/usr/local/lib' > /etc/ld.so.conf.d/complie.conf
cd -
wget https://www.openssl.org/source/openssl-1.0.2l.tar.gz
tar zxf openssl-1.0.2l.tar.gz -C /usr/local/src/
cd /usr/local/src/openssl-1.0.2l/
CFLAGS="-fPIC -O3" ./config --prefix=/usr/local/openssl shared threads zlib
make -j `cat /proc/cpuinfo | grep processor | wc -l`;make install
ln -s /usr/local/openssl/lib/lib*.so* /usr/local/lib/
ln -s /usr/local/openssl/lib/pkgconfig/* /usr/local/lib/pkgconfig/
ln -s /usr/local/openssl/include/* /usr/local/include/
echo 'export PATH=/usr/local/openssl/bin:$PATH' > /etc/profile.d/openssl.sh
source /etc/profile.d/openssl.sh
openssl version
cd –
ldconfig
wget http://erlang.org/download/otp_src_20.0.tar.gz
tar zxf otp_src_20.0.tar.gz -C /usr/local/src/
cd /usr/local/src/otp_src_20.0/
./configure --prefix=/usr/local/erlang --with-ssl=/usr/local/openssl --enable-threads
make -j `cat /proc/cpuinfo | grep processor | wc -l`;make install
echo 'export PATH=$PATH:/usr/local/erlang/bin' > /etc/profile.d/erl.sh
source /etc/profile.d/erl.sh
cd -

wget http://www.dest-unreach.org/socat/download/socat-1.7.3.2.tar.gz
tar zxf socat-1.7.3.2.tar.gz -C /usr/local/src/
cd /usr/local/src/socat-1.7.3.2/
CFLAGS="-fPIC -O3" ./configure
make -j `cat /proc/cpuinfo | grep processor | wc -l`;make install
ldconfig

安装RabbitMQ

RPM方式:

wget https://github.com/rabbitmq/rabbitmq-server/releases/download/rabbitmq_v3_6_11/rabbitmq-server-3.6.11-1.el7.noarch.rpm
rpm -ivh rabbitmq-server-3.6.11-1.el7.noarch.rpm

公用二进制包方式:

wget https://github.com/rabbitmq/rabbitmq-server/releases/download/rabbitmq_v3_6_11/rabbitmq-server-generic-unix-3.6.11.tar.xz
tar Jxf rabbitmq-server-generic-unix-3.6.11.tar.xz -C /usr/local/
mv /usr/local/rabbitmq_server-3.6.11/ /usr/local/rabbitmq_server
echo 'export PATH=$PATH:/usr/local/rabbitmq_server/sbin/' > /etc/profile.d/rabbitmq.sh
source /etc/profile.d/rabbitmq.sh
mkdir -p /data/rabbitmq/data
groupadd -g 33 rabbitmq
useradd -u 33 -g rabbitmq -s /sbin/nologin -d /data/rabbitmq/ -c "RabbitMQ messaging server" -M rabbitmq
chown -R rabbitmq:rabbitmq /data/rabbitmq/
chown -R rabbitmq /usr/local/rabbitmq_server/etc/rabbitmq/

建立服务脚本:

vim /usr/lib/systemd/system/rabbitmq-server.service
[Unit]
Description=RabbitMQ broker
After=syslog.target network.target

[Service]
Type=notify
User=rabbitmq
Group=rabbitmq
WorkingDirectory=/data/rabbitmq/
ExecStart=/usr/local/rabbitmq_server/sbin/rabbitmq-server
ExecStop=/usr/local/rabbitmq_server/sbin/rabbitmqctl stop
ExecStop=/bin/sh -c "while ps -p $MAINPID >/dev/null 2>&1; do sleep 1; done"
NotifyAccess=all
TimeoutStartSec=3600

[Install]
WantedBy=multi-user.target

运行

公用二进制包最好先创建配置文件环境变量；默认其配置文件目录及其它相关目录都是以二进制包为根目录而自动生成的，故若安默认启动需保证二进制包目录需有rabbitmq用户权限。这里设置环境变量配置文件，使其数据及日志目录存放于/data/rabbitmq目录下。

vim /usr/local/rabbitmq/etc/rabbitmq/rabbitmq-env.conf
# RabbitMQ env Config File.
RABBITMQ_MNESIA_BASE=/data/rabbitmq/data
RABBITMQ_LOG_BASE=/data/rabbitmq
RABBITMQ_PLUGINS_DIR=/usr/local/rabbitmq_server/plugins

Tips: PLUGINS目录为二进制包中plugins目录的位置。

由于erl命令没在系统默认PATH中，故需修改自带的启动脚本，在前面添加如下项即可：

vim /usr/local/rabbitmq/sbin/rabbitmq-server
source /etc/profile
vim /usr/local/rabbitmq/sbin/rabbitmqctl
source /etc/profile

启动:

systemctl start rabbitmq-server
systemctl status rabbitmq-server

查看:

netstat -nlput | grep `ps -ef | awk '/rabbitmq_server/ && $0 !~ "awk" {print $2}'`

开启管理网页插件:

echo '[{rabbit, [{loopback_users, []}]}].' > /usr/local/rabbitmq_server/etc/rabbitmq/rabbitmq.config

启用管理页面插件、添加用户:

rabbitmq-plugins enable rabbitmq_management
rabbitmqctl add_user admin admin
rabbitmqctl set_user_tags admin administrator

二进制包需以rabbitmq用户身份运行:

su -s /bin/bash - rabbitmq -c "rabbitmq-plugins enable rabbitmq_management"
su -s /bin/bash - rabbitmq -c "rabbitmqctl add_user admin admin"
su -s /bin/bash - rabbitmq -c "rabbitmqctl set_user_tags admin administrator"

插件启用完毕，即可以看到其会启动新的端口15672:

防火墙开放端口后即可在其它机器上查看：

firewall-cmd --permanent --add-port=5672/tcp
firewall-cmd --permanent --add-port=15672/tcp
firewall-cmd --permanent --add-port=25672/tcp
firewall-cmd --reload

单机群集

某些情况下，在单机上运行一组RabbitMQ节点可能非常有用。这通常用于在台式机或笔记本上进行群集测试而无需为群集启动多个虚拟机。

为了在单机上运行多个RabbitMQ节点，有必要确保节点具有不同的节点名称，数据存储位置，日志文件位置，并绑定到不同的端口，包括插件使用的端口。请参阅配置指南中的RABBITMQ_NODENAME, RABBITMQ_NODE_PORT和RABBITMQ_DIST_PORT，以及文件和目录位置指南中的RABBITMQ_MNESIA_DIR，RABBITMQ_CONFIG_FILE和RABBITMQ_LOG_BASE。

可以通过重复调用rabbitmq-server（Windows上的rabbitmq-server,bat）手动启动同一主机上的多个节点。例如：

vim /etc/host
# RabbitMQ Single Cluster
172.16.220.109  rabbit
172.16.220.109  hare

cd /var/lib/rabbitmq
systemctl stop rabbitmq-server
rm -rf mnesia/
RABBITMQ_NODE_PORT=5672 RABBITMQ_NODENAME=rabbit rabbitmq-server -detached
RABBITMQ_NODE_PORT=5673 RABBITMQ_NODENAME=hare rabbitmq-server -detached

注意，此时第二个节点其实并未成功启动，因为我们开启了管理页面（占用15672端口）:

故当RabbitMQ打开了除AMQP之外的其它端口，你需要配置那些端口以不至于冲突。可以通过如下命令完成启动:

ps -ef | awk '/rabbitmq_server/ && $0 !~ "awk" {print $2}' | xargs kill
RABBITMQ_NODE_PORT=5672 RABBITMQ_SERVER_START_ARGS="-rabbitmq_management listener [{port,15672}]" RABBITMQ_NODENAME=rabbit rabbitmq-server -detached
RABBITMQ_NODE_PORT=5673 RABBITMQ_SERVER_START_ARGS="-rabbitmq_management listener [{port,15673}]" RABBITMQ_NODENAME=hare rabbitmq-server -detached

这时再查看，其已正常启动:

将hare节点加入到群集rabbit中:

rabbitmqctl -n hare stop_app
rabbitmqctl -n hare join_cluster rabbit@rabbit1
rabbitmqctl -n hare start_app

查看群集状态:

rabbitmqctl -n rabbit cluster_status
rabbitmqctl -n hare cluster_status

登陆管理界面亦可查看到集群状态:

打赏微海报分享

发表评论

error: Content is protected !!