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  RabbitMQ vs Kafka: Choosing the Right Messaging System for Your Project

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]

Related posts:

Understanding RabbitMQ Virtual Hosts (vhosts) and Their Uses

Dead Letter Queues in RabbitMQ: How to Handle Failed Messages

Reliable Messaging with RabbitMQ: Acknowledgments, Durability, and Persistence

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

  • Smart Automation in PostgreSQL: Managing Time-Based Data with pg_partman and pg_cron
  • Understanding PostgreSQL WAL, Slot, Publication, LSN, and Replication Lag
  • PostgreSQL Write-Ahead Log (WAL): Durability, Performance Tuning, and Recovery Explained
  • PostgreSQL Replication Deep Dive: From High Availability to Multi-Master Clusters
  • Finding Nearby Merchants in a Ride-Hailing App Using Elasticsearch Polygon Search
  • Advanced Text Search in Elasticsearch: N-Gram, Reverse, Fuzzy, and Search-as-you-type
  • Understanding and Customizing Analyzers in Elasticsearch
  • 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

Recent Comments

No comments to show.

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
  • PostgreSQL
  • Programming
  • RabbitMQ
  • Redis
  • VPC
© 2026 Widhian Bramantya | Powered by Minimalist Blog WordPress Theme