docker簡易搭建RabbitMQ叢集
阿新 • • 發佈：2018-11-08
寫在前面：rabbitmq叢集與其他叢集有些不同，rabbitmq叢集同步的指是複製佇列，元資料資訊的同步，即同步的是資料儲存資訊；訊息的存放只會儲存在建立該訊息佇列的那個節點上。並非在節點上都儲存一個完整的資料。在通過非資料所在節點獲取資料時，通過元資料資訊，路由轉發到儲存資料節點上，從而得到資料。
一、拉取rabbitmq映象
在centos視窗中，執行如下命令：
docker pull rabbitmq:3.7-management
二、建立對映資料卷目錄，啟動rabbitmq容器
在centos視窗中，執行如下命令建立資料夾：
mkdir rabbitmqcluster
cd 操作日誌如下：
[[email protected] rabbitmqcluster]# pwd /home/soft/ [[email protected] soft]# mkdir rabbitmqcluster [[email protected] soft]# cd rabbitmqcluster/ [r[email protected] rabbitmqcluster]# mkdir rabbitmq01 rabbitmq02 rabbitmq03
注：請讀者自行找尋建立資料對映目錄。
建立完成對映目錄後，在centos視窗中，執行如下命令建立容器：
docker run -d --hostname rabbitmq01 --name rabbitmqCluster01 -v /home/soft/rabbitmqcluster/rabbitmq01:/var/lib/rabbitmq -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie' rabbitmq:3.7-management
docker run -d --hostname rabbitmq02 --name rabbitmqCluster02 -v /home/soft/rabbitmqcluster/rabbitmq02:/var/lib/rabbitmq -p 15673:15672 -p 5673:5672 -e RABBITMQ_ERLANG_COOKIE= 注： --hostname 設定容器的主機名
RABBITMQ_ERLANG_COOKIE 節點認證作用，部署整合時 需要同步該值
啟動容器成功後，讀者可以訪問
http://192.168.9.219:15672/#/
http://192.168.9.219:15673/#/
http://192.168.9.219:15674/#/
檢視是否正常啟動成功。賬號/密碼：guest / guest。
讀者登陸後，檢視overview Tab頁，可看到節點資訊。
三、容器節點加入叢集
首先在centos視窗中，執行如下命令，進入第一個rabbitmq節點容器：
docker exec -it rabbitmqCluster01 bash
進入容器後，操作rabbitmq,執行如下命令：
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
exit
操作日誌資訊如下：
[[email protected] rabbitmq01]# docker exec -it rabbitmqCluster01 bash
[email protected]:/# rabbitmqctl stop_app
Stopping rabbit application on node [email protected] ...
[email protected]:/# rabbitmqctl reset
Resetting node [email protected] ...
[email protected]:/# rabbitmqctl start_app
Starting node [email protected] ...
completed with 3 plugins.
[email protected]:/# exit
exit
接下來，進入第二個rabbitmq節點容器，執行如下命令：
docker exec -it rabbitmqCluster02 bash
rabbitmqctl reset
rabbitmqctl join_cluster --ram [email protected]
rabbitmqctl start_app
exit
操作日誌資訊如下：
[[email protected] rabbitmq01]# docker exec -it rabbitmqCluster02 bash
[email protected]:/# rabbitmqctl stop_app
Stopping rabbit application on node [email protected] ...
[email protected]:/# rabbitmqctl reset
Resetting node [email protected] ...
[email protected]:/# rabbitmqctl join_cluster --ram [email protected]
Clustering node [email protected] with [email protected]
[email protected]:/# rabbitmqctl start_app
Starting node [email protected] ...
completed with 3 plugins.
[email protected]:/# exit
exit
最後，進入第三個rabbitmq節點容器，執行如下命令：
docker exec -it rabbitmqCluster03 bash
rabbitmqctl reset
rabbitmqctl join_cluster --ram [email protected]
rabbitmqctl start_app
exit
操作日誌資訊如下：
[[email protected] rabbitmq01]# docker exec -it rabbitmqCluster03 bash
[email protected]:/# rabbitmqctl stop_app
Stopping rabbit application on node [email protected] ...
[email protected]:/# rabbitmqctl reset
Resetting node [email protected] ...
[email protected]:/# rabbitmqctl join_cluster --ram [email protected]
Clustering node [email protected] with [email protected]
[email protected]:/# rabbitmqctl start_app
Starting node [email protected] ...
completed with 3 plugins.
[email protected]:/# exit
exit
執行上述操作，這時候 再檢視 http://192.168.9.219:15672/#/ 的overview面板中的Nodes資訊，可檢視到節點資訊。
四、負載均衡設定
有了叢集之後 還要設定負載均,為了防止出現對單一節點造成高負載的情況。
本次測試用例 採用nginx中介軟體。讀者可根據自身需要進行選擇。
1.本機上存放著一個nginx配置檔案：/home/soft/nginx/nginx_rabbitmq.conf
nginx_rabbitmq.conf
user nginx;
worker_processes 1;
error_log /var/log/nginx/error.log warn;
pid /var/run/nginx.pid;
events {
worker_connections 1024;
}
http {
include /etc/nginx/mime.types;
default_type application/octet-stream;
log_format main '$remote_addr - $remote_user [$time_local] "$request" '
'$status $body_bytes_sent "$http_referer" '
'"$http_user_agent" "$http_x_forwarded_for"';
access_log /var/log/nginx/access.log main;
sendfile on;
#tcp_nopush on;
keepalive_timeout 65;
#gzip on;
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 10m;
client_body_buffer_size 128k;
proxy_connect_timeout 5s;
proxy_send_timeout 5s;
proxy_read_timeout 5s;
proxy_buffer_size 4k;
proxy_buffers 4 32k;
proxy_busy_buffers_size 64k;
proxy_temp_file_write_size 64k;
#rabbitmq管理介面
upstream rabbitManage {
server 192.168.9.219:15672;
server 192.168.9.219:15673;
server 192.168.9.219:15674;
}
server {
listen 15675;
server_name 192.168.9.219;
location / {
proxy_pass http://rabbitManage;
index index.html index.htm;
}
}
}
# rabbitmq通訊
stream{
upstream rabbitManage{
server 192.168.9.219:5672;
server 192.168.9.219:5673;
server 192.168.9.219:5674;
}
server {
listen 5675;
proxy_pass rabbitTcp;
}
}
注：這裡配置rabbitmq管理介面 以及通訊反向代理
2.啟動nginx容器
在centos視窗中，執行如下命令：
docker run -it -d --name nginxRabbitmq -v /home/soft/nginx/nginx_rabbitmq.conf:/etc/nginx/nginx.conf --privileged --net=host nginx
接著讀者可以通過 http://192.168.9.219:15675 進行管理 以及通過 5675 埠 進行rabbitmq通訊。
附錄：
啟動rabbitmq
rabbitmqctl start_app
停止rabbitmq
rabbitmqctl stop_app
rabbitmq 檢視所有佇列資訊
rabbitmqctl list_queues
還原 rabbitmq 清除所有佇列
rabbitmqctl reset
rabbitmq 檢視使用者
rabbitmqctl list_users
rabbitmq新增使用者
rabbitmqctl add_user root root
rabbitmq設定許可權
rabbitmqctl set_permissions -p / root ".*" ".*" ".*"
rabbitmq檢視叢集狀態資訊
rabbitmqctl cluster_status
移除某個叢集節點：一般情況當節點故障時，在正常的節點中，移除該故障節點
rabbitmqctl -n [email protected] forget_cluster_node [email protected]