在以前的文章中我已经介绍过使用源码来安装RabbitMQ(可参考文章https://blog.51cto.com/8355320/2445237 ),安装过程也比较繁琐,今天因环境需求,需搭建RabbitMQ集群,因为业务也都采起docker容器方式部署,所以也研究将RabbitMQ采用docker来部署,本文特将部署步骤记录下来:
备注:docker的安装部署,这里就不在添加部署过程,可参考文章https://blog.51cto.com/8355320/2438741
搭建环境:
操做系统:CentOS7.6
内存大小:8GB
硬盘:200G
一、IP地址规划(将信息配置到/etc/hosts中)
主机名 IP地址
RabbitMQ01 192.168.8.131
RabbitMQ02 192.168.8.132
RabbitMQ03 192.168.8.133
RabbitMQ04 192.168.8.134
二、RabbitMQ集群安装
(1)四个节点同时运行,下载RabbitMQ镜像
[root@RabbitMQ01~]# docker pull rabbitmq:3-management
(2)四个节点分别运行,启动RabbitMQ容器nginx
[root@RabbitMQ01~]# docker run -d --restart=always --hostname rabbit01 --name rabbit-01 -p 25672:25672 -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 --add-host rabbit02:192.168.8.132 --add-host rabbit03:192.168.8.133 --add-host rabbit04:192.168.8.134 -e RABBITMQ_ERLANG_COOKIE='rbmqcookie' rabbitmq:3-management
[root@RabbitMQ02~]# docker run -d --restart=always --hostname rabbit02 --name rabbit-02 -p 25672:25672 -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 --add-host rabbit01:192.168.8.131 --add-host rabbit03:192.168.8.133 --add-host rabbit04:192.168.8.134 -e RABBITMQ_ERLANG_COOKIE='rbmqcookie' rabbitmq:3-management
[root@RabbitMQ03~]# docker run -d --restart=always --hostname rabbit03 --name rabbit-03 -p 25672:25672 -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 --add-host rabbit01:192.168.8.131 --add-host rabbit02:192.168.8.132 --add-host rabbit04:192.168.8.134 -e RABBITMQ_ERLANG_COOKIE='rbmqcookie' rabbitmq:3-management
[root@RabbitMQ04~]# docker run -d --restart=always --hostname rabbit04 --name rabbit-04 -p 25672:25672 -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 --add-host rabbit01:192.168.8.131 --add-host rabbit02:192.168.8.132 --add-host rabbit03:192.168.8.133 -e RABBITMQ_ERLANG_COOKIE='rbmqcookie' rabbitmq:3-management
(3)、将节点添加至集群服务中,咱们将节点03设置为集群的master节点,其余为子节点,注意配置两个节点为ram节点,另两个为disc节点,执行时注意命令的不一样
节点01上执行:web
[root@RabbitMQ01~]# docker exec -it rabbit-01 bash [rabbit@rabbit01]# rabbitmqctl stop_app [rabbit@rabbit01]# rabbitmqctl reset [rabbit@rabbit01]# rabbitmqctl join_cluster --ram rabbit@rabbit03 [rabbit@rabbit01]# rabbitmqctl start_app [rabbit@rabbit01]# exit
节点02上执行:docker
[root@RabbitMQ02~]# docker exec -it rabbit-02 bash [rabbit@rabbit02]# rabbitmqctl stop_app [rabbit@rabbit02]# rabbitmqctl reset [rabbit@rabbit02]# rabbitmqctl join_cluster --ram rabbit@rabbit03 [rabbit@rabbit02]# rabbitmqctl start_app [rabbit@rabbit02]# exit
节点04上执行:bash
[root@RabbitMQ04~]# docker exec -it rabbit-01 bash [rabbit@rabbit04]# rabbitmqctl stop_app [rabbit@rabbit04]# rabbitmqctl reset [rabbit@rabbit04]# rabbitmqctl join_cluster rabbit@rabbit03 [rabbit@rabbit04]# rabbitmqctl start_app [rabbit@rabbit04]# exit
节点03上执行:cookie
[root@RabbitMQ03~]# docker exec -it rabbit-03 bash [rabbit@rabbit03]# rabbitmqctl stop_app [rabbit@rabbit03]# rabbitmqctl reset [rabbit@rabbit03]# rabbitmqctl start_app [rabbit@rabbit03]# exit
三、配置添加ha-mode镜像
Name:HA
Pattern:.
Definition:ha-mode = allapp
集群启动后的访问主界面:ide
三、安装配置nginx,以提供高可用
nginx的安装,这里略过,直接进入配置
[root@nginx~]# cd /usr/local/nginx/conf
[root@nginx~conf]# vi nginx.conf
其余配置略过操作系统
stream{ upstream rabbitmq{ server 192.168.8.131:5672 max_fails=2 fail_timeout=5s weight=2; server 192.168.8.132:5672 max_fails=2 fail_timeout=5s weight=2; server 192.168.8.133:5672 max_fails=2 fail_timeout=5s weight=2; server 192.168.8.134:5672 max_fails=2 fail_timeout=5s weight=2; } server{ listen 5678; proxy_pass rabbitmq; } }
[root@nginx~conf]# vi rabbitmqstream.conf upstream mqweb { ip_hash; server 192.168.8.131:15672; server 192.168.8.132:15672; server 192.168.8.133:15672; server 192.168.8.134:15672; } server { listen 80; server_name localhost; location / { proxy_pass http://rabbitmqstream/; proxy_redirect off; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; client_max_body_size 100m; client_body_buffer_size 256k; proxy_connect_timeout 60; proxy_send_timeout 60; proxy_read_timeout 60; proxy_buffer_size 256k; proxy_buffers 8 256k; proxy_busy_buffers_size 512k; proxy_temp_file_write_size 512k; } }
从新启动nginx容器rest
[root@nginx~conf]# /usr/local/nginx/sbin/nginx -s reload [root@nginx~conf]# /usr/local/nginx/sbin/nginx -s stop [root@nginx~conf]# /usr/local/nginx/sbin/nginx