概述

在windows 10上實現執行rabbitmq cluster，含三個節點，並能同時啟用rabbitmq_management外掛，實現web管理。rabbitmq版本為：rabbitmq-server-windows-3.6.6

修改Hosts

增加

127.0.0.1   node1
127.0.0.1   node2
127.0.0.1   node3

複製檔案

在sbin目錄下複製指令碼檔案

copy rabbitmq-server.bat rabbitmq-server-node1.bat
copy rabbitmq-server.bat rabbitmq-server
 
-node2.bat
copy rabbitmq-server.bat rabbitmq-server-node3.bat

copy rabbitmqctl.bat rabbitmqctl-node1.bat
copy rabbitmqctl.bat rabbitmqctl-node2.bat
copy rabbitmqctl.bat rabbitmqctl-node3.bat

copy rabbitmq-env.bat rabbitmq-env-node1.bat
copy rabbitmq-env.bat rabbitmq-env-node2.bat
copy rabbitmq-env
 
.bat rabbitmq-env-node3.bat

copy rabbitmq-plugins.bat rabbitmq-plugins-node1.bat
copy rabbitmq-plugins.bat rabbitmq-plugins-node2.bat
copy rabbitmq-plugins.bat rabbitmq-plugins-node3.bat

在etc目錄下複製配置檔案

copy rabbitmq.config.example rabbitmq-node1.config
copy rabbitmq.config.example rabbitmq-node2.config
 

copy rabbitmq.config.example rabbitmq-node3.config

修改檔案

以下只展示node1的修改步驟，node2和node3的RABBITMQ_CONFIG_FILE,RABBITMQ_NODENAME, RABBITMQ_NODE_PORT, RABBITMQ_DIST_PORT還有listener port改成不一樣的即可。

修改rabbitmq-env-node1.bat

在開頭大概16行左右新增

REM node1
set RABBITMQ_CONFIG_FILE=!RABBITMQ_HOME!\etc\rabbitmq-node1
set RABBITMQ_BASE=!RABBITMQ_HOME!\sbin\rabbitmq-cluster
set [email protected]
set RABBITMQ_NODE_PORT=9991
set RABBITMQ_DIST_PORT=16671

確保RABBITMQ_HOME已經定義好；RABBITMQ_BASE把rabbit資料等目錄移到sbin目錄下，好方便刪除重建。

修改rabbitmq-server-node1.bat

call "%TDP0%\rabbitmq-env.bat" %~n0 -> call "%TDP0%\rabbitmq-env-node1.bat" %~n0

修改rabbitmq-server-node1.bat

call "%TDP0%\rabbitmq-env.bat" %~n0 -> call "%TDP0%\rabbitmq-env-node1.bat" %~n0

修改rabbitmq-plugins-node1

call "%TDP0%\rabbitmq-env.bat" %~n0 -> call "%TDP0%\rabbitmq-env-node1.bat" %~n0

修改rabbitmq-node1.config

在{rabbitmq_management下找到

   %% {listener, [{port,     12345},
   %%             {ip,       "127.0.0.1"},
   %%             {ssl,      true},
   %%             {ssl_opts, [{cacertfile, "/path/to/cacert.pem"},
   %%                         {certfile,   "/path/to/cert.pem"},
   %%                         {keyfile,    "/path/to/key.pem"}]}]},

改成

   {listener, [{port,     15671},
               {ip,       "127.0.0.1"},
               {ssl,      false}
   ]}

注意括號的閉合問題

啟用外掛

在命令列中sbin目錄下執行
rabbitmq-plugins-node1 enable rabbitmq_management

因為三個節點是共用一個外掛開關配置檔案（!RABBITMQ_HOME!\sbin\rabbitmq-cluster\enabled_plugins)，所以只要執行node1的即可。

啟動Server及新增節點

啟動三個節點

rabbitmq-server-node1.bat
rabbitmq-server-node2.bat
rabbitmq-server-node3.bat

新增node2到node1的cluster中

rabbitmqctl-node2.bat stop_app
rabbitmqctl-node2.bat reset
rabbitmqctl-node2.bat join_cluster [email protected]
rabbitmqctl-node2.bat start_app
rabbitmqctl-node2.bat cluster_status

新增node3到node1的cluster中

rabbitmqctl-node3.bat stop_app
rabbitmqctl-node3.bat reset
rabbitmqctl-node3.bat join_cluster [email protected] --ram 
rabbitmqctl-node3.bat start_app
rabbitmqctl-node3.bat cluster_status

檢視叢集狀態

在命令列中執行rabbitmqctl-node2.bat cluster_status

Cluster status of node rabbit3@node3 ...
[{nodes,[{disc,[rabbit2@node2,rabbit1@node1]},{ram,[rabbit3@node3]}]},
 {running_nodes,[rabbit1@node1,rabbit2@node2,rabbit3@node3]},
 {cluster_name,<<"rabbit1@njun">>},
 {partitions,[]},
 {alarms,[{rabbit1@node1,[]},{rabbit2@node2,[]},{rabbit3@node3,[]}]}]

在Web中檢視

總結

• 因為是在同一機器上，所有不需要同步hosts檔案及cookie
• 啟動資訊可以在rabbitmq-cluster/log目錄下檢視
• 刪除rabbitmq-cluster目錄又可以重建cluster
• 如果不修改rabbitmq_management埠，則有可能導致節點之間埠衝突