CentOS Stream 8
Sponsored Link

RabbitMQ : Configure Cluster2021/06/21

 
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.3 on Erlang 22.3.4.1
rabbit@node02: RabbitMQ 3.8.3 on Erlang 22.3.4.1

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@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

Feature flags

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 possible to see each Node's status like follows.
Matched Content