RabbitMQ : Configure Cluster2020/04/17 |
|
Configure RabbitMQ Cluster.
It shows to configure 2 RabbitMQ Servers on this example. |
|
| [1] |
Install and start RabbitMQ Server on all Nodes, refer to here.
(If Firewalld is running, allow port, too) |
| [2] | If Firewalld is running, allow more ports for clustering. |
|
[root@node01 ~]# firewall-cmd --add-port={4369/tcp,25672/tcp} --permanent success [root@node01 ~]# firewall-cmd --reload success |
| [3] | Configure clustering on a Node. |
|
# put the same cookie on all nodes [root@node02 ~]# ssh node01.srv.world 'cat /var/lib/rabbitmq/.erlang.cookie' > /var/lib/rabbitmq/.erlang.cookie [root@node02 ~]# systemctl restart rabbitmq-server
# stop application and reset [root@node02 ~]# rabbitmqctl stop_app Stopping rabbit application on node rabbit@node02 ... [root@node02 ~]# rabbitmqctl reset Resetting node rabbit@node02 ... # join in cluster (specify only hostname, not with FQDN) [root@node02 ~]# rabbitmqctl join_cluster rabbit@node01 Clustering node rabbit@node02 with rabbit@node01 # start application [root@node02 ~]# rabbitmqctl start_app Starting node rabbit@node02 ... completed with 3 plugins. # show status [root@node02 ~]# rabbitmqctl cluster_status Cluster status of node rabbit@node02 ... Basics Cluster name: rabbit@node02.srv.world Disk Nodes rabbit@node01 rabbit@node02 Running Nodes rabbit@node01 rabbit@node02 Versions rabbit@node01: RabbitMQ 3.8.2 on Erlang 22.2.8 rabbit@node02: RabbitMQ 3.8.2 on Erlang 22.2.8 Alarms (none) Network Partitions (none) Listeners Node: rabbit@node01, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication Node: rabbit@node01, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0 Node: rabbit@node01, interface: [::], port: 15672, protocol: http, purpose: HTTP API Node: rabbit@node02, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication Node: rabbit@node02, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0 Node: rabbit@node02, interface: [::], port: 15672, protocol: http, purpose: HTTP API Feature flags Flag: drop_unroutable_metric, state: disabled Flag: empty_basic_get_metric, state: disabled Flag: implicit_default_bindings, state: enabled Flag: quorum_queue, state: enabled Flag: virtual_host_metadata, state: enabled |
| [4] | Configure Queue sync setting. If [rabbitmqadmin] command is not found, install it, refer to here. This example shows to configure that Queue is synced on all Nodes. There are some modes to sync among Nodes, refer details to official site below. ⇒ https://www.rabbitmq.com/ha.html |
|
# add Queue for sync [root@node01 ~]# rabbitmqadmin declare queue name=shared_queue queue declared # set sync policy # rabbitmqctl set_policy [policy name(any name you like)] [Queue] [Mode] [root@node01 ~]# rabbitmqctl set_policy ha-policy "shared_queue" '{"ha-mode":"all"}' Setting policy "ha-policy" for pattern "shared_queue" to "{"ha-mode":"all"}" with priority "0" for vhost "/" ... # show status [root@node01 ~]# rabbitmqadmin list queues name node policy slave_nodes state synchronised_slave_nodes +--------------+---------------+-----------+---------------+---------+--------------------------+ | name | node | policy | slave_nodes | state | synchronised_slave_nodes | +--------------+---------------+-----------+---------------+---------+--------------------------+ | shared_queue | rabbit@node01 | ha-policy | rabbit@node02 | running | rabbit@node02 | +--------------+---------------+-----------+---------------+---------+--------------------------+ |
| [5] | To Enable management Plugin on all Nodes, it's possbile to see each Node's status like follows. |
|
Matched Content