Publish-subscribe for broadcasting in RabbitMQ - Mini Project: Build & Apply

Publish-subscribe for broadcasting

📖 Scenario: You are setting up a simple messaging system where one sender can broadcast messages to multiple receivers. This is useful in real life when you want to send announcements or updates to many users at once.

🎯 Goal: Build a RabbitMQ publish-subscribe system using a fanout exchange to broadcast messages from one publisher to multiple subscribers.

📋 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 'Hello Subscribers!' to the logs exchange

Consume and print messages from both queues

💡 Why This Matters

🌍 Real World

Broadcasting messages is common in chat apps, live notifications, and event systems where many users need the same information at once.

💼 Career

Understanding publish-subscribe patterns and RabbitMQ is valuable for roles in DevOps, backend development, and system integration.

1

Setup the fanout exchange and queues

Create a fanout exchange called logs and two queues called queue1 and queue2 using the RabbitMQ Python client. Declare the exchange and queues so they exist on the server.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Declare a fanout exchange named 'logs' and two queues named 'queue1' and 'queue2'
# Your code here

Need a hint?

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

2

Bind the queues to the exchange

Bind the queues queue1 and queue2 to the logs exchange so they receive all messages published to it.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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

Need a hint?

Use channel.queue_bind to connect each queue to the exchange.

3

Publish a message to the exchange

Publish the message 'Hello Subscribers!' to the logs exchange. Use an empty routing key since fanout exchanges ignore it.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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')
# Publish 'Hello Subscribers!' to the 'logs' exchange
# Your code here

Need a hint?

Use channel.basic_publish with exchange='logs' and routing_key='' to send the message.

4

Consume and print messages from both queues

Consume one message from queue1 and one message from queue2. Print the message body from each queue to show that both received the broadcast.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

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 Subscribers!')
# Consume one message from 'queue1' and 'queue2' and print their bodies
# Your code here

Need a hint?

Use channel.basic_get with auto_ack=True to get one message from each queue. Decode the message body from bytes to string before printing.