Skip to content

Widhian Bramantya

coding is an art form

Menu
  • About Me
Menu
rabbitmq

High Availability in RabbitMQ: Clustering and Mirrored Queues Explained

Posted on September 13, 2025September 13, 2025 by admin

Introduction

High Availability (HA) means your system can keep working even if some parts fail. In RabbitMQ, HA is very important because if the broker goes down, messages may be lost, or services may stop.

RabbitMQ offers two main features for HA:

  1. Clustering → combine many RabbitMQ nodes into one logical broker.
  2. Mirrored Queues (Classic Queues HA) or Quorum Queues → copy queue data across nodes.

This article explains these features in simple terms.

What is Clustering?

A RabbitMQ cluster is a group of RabbitMQ nodes working together.

  • All nodes share the same users, vhosts, exchanges, bindings, and queues metadata.
  • A producer or consumer can connect to any node.
  • Messages are stored on the node that hosts the queue (unless mirrored).

Benefits of Clustering

  • Load balancing: clients can connect to different nodes.
  • Failover: if one node dies, others are still alive.
  • Scalability: add more nodes to handle more connections.

Limitation

  • By default, queues live only on one node. If that node fails, the queue and its messages are gone.
  • To fix this, use mirrored queues or quorum queues.

Mirrored Queues (Classic Queue HA)

A mirrored queue keeps copies of its data on multiple nodes.

  • One node is the master (leader).
  • Other nodes are mirrors (followers).
  • When the master node goes down, one of the mirrors is promoted to master.
  • Clients can continue without losing messages.

Example Flow

flowchart LR
  P[Producer] --> N1((Node 1: Master Queue))
  N1 --> N2((Node 2: Mirror Queue))
  N1 --> N3((Node 3: Mirror Queue))
  N1 --> C[Consumer]
  • Producer sends message → goes to Master (Node 1).
  • Master replicates the message to Node 2 and Node 3.
  • Consumer reads from the master.
  • If Node 1 dies → Node 2 becomes the new master.
See also  Dead Letter Queues in RabbitMQ: How to Handle Failed Messages

Quorum Queues

RabbitMQ also supports Quorum Queues, a newer, more reliable option than mirrored queues.

  • Based on the Raft consensus algorithm.
  • Messages are replicated across nodes.
  • Provides strong consistency (only committed messages survive).
  • Recommended for new systems instead of mirrored queues.

Example Flow

flowchart LR
  P[Producer] --> QQ1((Quorum Queue Leader))
  QQ1 --> QQ2((Follower))
  QQ1 --> QQ3((Follower))
  QQ1 --> C[Consumer]
Pages: 1 2
Category: RabbitMQ

Leave a Reply Cancel reply

Your email address will not be published. Required fields are marked *

Linkedin

Widhian Bramantya

Recent Posts

  • Log Management at Scale: Integrating Elasticsearch with Beats, Logstash, and Kibana
  • Index Lifecycle Management (ILM) in Elasticsearch: Automatic Data Control Made Simple
  • Blue-Green Deployment in Elasticsearch: Safe Reindexing and Zero-Downtime Upgrades
  • Maintaining Super Large Datasets in Elasticsearch
  • Elasticsearch Best Practices for Beginners
  • Implementing the Outbox Pattern with Debezium
  • Production-Grade Debezium Connector with Kafka (Postgres Outbox Example – E-Commerce Orders)
  • Connecting Debezium with Kafka for Real-Time Streaming
  • Debezium Architecture – How It Works and Core Components
  • What is Debezium? – An Introduction to Change Data Capture
  • Offset Management and Consumer Groups in Kafka
  • Partitions, Replication, and Fault Tolerance in Kafka
  • Delivery Semantics in Kafka: At Most Once, At Least Once, Exactly Once
  • Producers and Consumers: How Data Flows in Kafka
  • Kafka Architecture Explained: Brokers, Topics, Partitions, and Offsets
  • Getting Started with Apache Kafka: Core Concepts and Use Cases
  • Security Best Practices for RabbitMQ in Production
  • Understanding RabbitMQ Virtual Hosts (vhosts) and Their Uses
  • RabbitMQ Performance Tuning: Optimizing Throughput and Latency
  • High Availability in RabbitMQ: Clustering and Mirrored Queues Explained

Recent Comments

  1. Playing with VPC AWS (Part 2) – Widhian's Blog on Playing with VPC AWS (Part 1): VPC, Subnet, Internet Gateway, Route Table, NAT, and Security Group
  2. Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh – Widhian's Blog on Basic Concept of ElasticSearch (Part 1): Introduction
  3. Basic Concept of ElasticSearch (Part 2): Architectural Perspective – Widhian's Blog on Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh
  4. Basic Concept of ElasticSearch (Part 3): Translog, Flush, and Refresh – Widhian's Blog on Basic Concept of ElasticSearch (Part 2): Architectural Perspective
  5. Basic Concept of ElasticSearch (Part 1): Introduction – Widhian's Blog on Basic Concept of ElasticSearch (Part 2): Architectural Perspective

Archives

  • October 2025
  • September 2025
  • August 2025
  • November 2021
  • October 2021
  • August 2021
  • July 2021
  • June 2021
  • March 2021
  • January 2021

Categories

  • Debezium
  • Devops
  • ElasticSearch
  • Golang
  • Kafka
  • Lua
  • NATS
  • Programming
  • RabbitMQ
  • Redis
  • VPC
© 2025 Widhian Bramantya | Powered by Minimalist Blog WordPress Theme