- 配置hosts(3个节点)
192.168.100.1 VM_100_1_centos
192.168.100.2 VM_100_2_centos
192.168.100.3 VM_100_3_centos
- 安装
下载链接:点击下载
rpm -ivh erlang-19.0.4-1.el7.centos.x86_64.rpm rabbitmq-server-3.6.12-1.el7.noarch.rpm
- 配置启动(3个节点都操作)
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=/var/lib/rabbitmq
ExecStart=/usr/sbin/rabbitmq-server
ExecStop=/usr/sbin/rabbitmqctl stop
ExecStop=/bin/sh -c "while ps -p $MAINPID >/dev/null 2>&1; do sleep 1; done"
NotifyAccess=all
TimeoutStartSec=3600
LimitNOFILE=300000
[Install]
WantedBy=multi-user.target
systemctl daemon-reload
systemctl start rabbitmq-server.service
systemctl status rabbitmq-server.service
- 配置插件(3个节点都操作)
rabbitmq-plugins enable rabbitmq_management
rabbitmq-plugins enable rabbitmq_stomp
rabbitmq-plugins enable rabbitmq_top
- 配置集群
vim /var/lib/rabbitmq/.erlang.cookie
UUPJPTKFQPZPDSORCBMS
#文件内容保持一致组成同一集群,文件权限400,要保证.erlang.cookie文件的所属用户及组都为rabbitmq
scp /var/lib/rabbitmq/.erlang.cookie root@192.168.100.2:/var/lib/rabbitmq/
scp /var/lib/rabbitmq/.erlang.cookie root@192.168.100.3:/var/lib/rabbitmq/
vim /etc/rabbitmq/rabbitmq.config
[{rabbit, [{loopback_users, []},{vm_memory_high_watermark, 0.75},{cluster_partition_handling, pause_minority}]}].
默认情况下,RabbitMQ使用内存超过40%的时候,会发出内存警告,阻塞所有发布消息的连接,一旦警告解除(例如:服务器paging消息到硬盘或者分发消息到消费者并且确认)服务会恢复正常。默认的内存阀值是40%,注意,这并不会阻止RabbitMQ Server使用不到40%,仅仅意味着到达这个点的时候,发布者会被阻塞block,最坏的情况下,Erlang虚拟机会引起双倍的内存使用(RAM的80%),强烈建议开启操作系统的SWAP和Page files.内存达到阀值后,发布者会被阻塞,但是消费者不会被阻塞,消费者继续消费消息,当内存降低到阀值以下后,发布者继续开始发布消息。
- 重启(3个节点都操作)
systemctl restart rabbitmq-server.service
systemctl status rabbitmq-server.service
- 添加组成集群(将1作为主节点,在2,3上分别执行以下命令:)
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@VM_100_1_centos
rabbitmqctl start_app
rabbitmqctl cluster_status
- 访问其中一个节点的管理端口查看集群状态(默认用户名密码都是:guest)
- API接口
curl -u guest:guest http://127.0.0.1:15672/api/overview # 获取概览信息,类似于 rabbitmqctl status
curl -u guest:guest http://127.0.0.1:15672/api/nodes # 获取节点信息,类似于 rabbitmqctl cluster_status
curl -u guest:guest http://127.0.0.1:15672/api/users # 获取用户列表,类似于 rabbitmqctl list_users
curl -u guest:guest http://127.0.0.1:15672/api/queues # 获取队列列表,类似于 rabbitmqctl list_queues
curl -u guest:guest http://127.0.0.1:15672/api/bindings # 获取绑定列表,类似于 rabbitmqctl list_bindings
curl -u guest:guest http://127.0.0.1:15672/api/connections # 获取连接列表,类似于 rabbitmqctl list_connections
