Fanout exchange (broadcast) in RabbitMQ - Mini Project: Build & Apply

Fanout Exchange (Broadcast) with RabbitMQ

📖 Scenario: You are setting up a messaging system where one message needs to be sent to multiple services at the same time. This is like announcing a message to everyone in a room.

🎯 Goal: Build a RabbitMQ setup using a fanout exchange that broadcasts messages to multiple queues.

📋 What You'll Learn

Create a fanout exchange named logs

Create two queues named queue1 and queue2

Bind both queues to the logs exchange

Publish a message to the logs exchange

Consume messages from both queues to verify broadcast

💡 Why This Matters

🌍 Real World

Fanout exchanges are used when you want to send the same message to multiple services, like sending notifications or logs to many consumers at once.

💼 Career

Understanding fanout exchanges is important for building scalable messaging systems and event-driven architectures in many DevOps and backend roles.

1

Create the fanout exchange and queues

Create a fanout exchange called logs. Then create two queues called queue1 and queue2.

RabbitMQ

# Your code here to declare exchange 'logs' and queues 'queue1' and 'queue2'

Need a hint?

Use channel.exchange_declare with exchange_type='fanout' to create the exchange. Use channel.queue_declare to create queues.

2

Bind the queues to the fanout exchange

Bind the queues queue1 and queue2 to the logs exchange using channel.queue_bind.

RabbitMQ

channel.exchange_declare(exchange='logs', exchange_type='fanout')
channel.queue_declare(queue='queue1')
channel.queue_declare(queue='queue2')
# Your code here to bind 'queue1' and 'queue2' to 'logs'

Need a hint?

Use channel.queue_bind with the exchange name and queue name to connect them.

3

Publish a message to the fanout exchange

Publish the message 'Hello World!' to the logs exchange using channel.basic_publish. Use an empty routing key ''.

RabbitMQ

channel.exchange_declare(exchange='logs', exchange_type='fanout')
channel.queue_declare(queue='queue1')
channel.queue_declare(queue='queue2')
channel.queue_bind(exchange='logs', queue='queue1')
channel.queue_bind(exchange='logs', queue='queue2')
# Your code here to publish 'Hello World!' to 'logs' exchange

Need a hint?

Use channel.basic_publish with exchange='logs', routing_key='', and the message body.

4

Consume messages from both queues

Consume one message from queue1 and one message from queue2 using channel.basic_get. Print both messages.

RabbitMQ

channel.exchange_declare(exchange='logs', exchange_type='fanout')
channel.queue_declare(queue='queue1')
channel.queue_declare(queue='queue2')
channel.queue_bind(exchange='logs', queue='queue1')
channel.queue_bind(exchange='logs', queue='queue2')
channel.basic_publish(exchange='logs', routing_key='', body='Hello World!')
# Your code here to get and print messages from 'queue1' and 'queue2'

Need a hint?

Use channel.basic_get(queue='queue1') and channel.basic_get(queue='queue2') to get messages. Decode the message body before printing.