Direct exchange in RabbitMQ - Mini Project: Build & Apply

Direct Exchange in RabbitMQ

📖 Scenario: You are setting up a messaging system using RabbitMQ. You want to send messages to specific queues based on exact routing keys using a direct exchange.

🎯 Goal: Build a RabbitMQ setup with a direct exchange, bind queues with specific routing keys, and send messages that are routed correctly.

📋 What You'll Learn

Create a direct exchange named direct_logs

Create two queues named info_queue and error_queue

Bind info_queue to direct_logs with routing key info

Bind error_queue to direct_logs with routing key error

Publish messages with routing keys info and error to the exchange

Consume messages from both queues and print them

💡 Why This Matters

🌍 Real World

Direct exchanges are used in messaging systems where messages must be routed exactly to queues based on routing keys, such as logging systems or task dispatchers.

💼 Career

Understanding direct exchanges is essential for roles involving message brokers, microservices communication, and event-driven architectures.

1

Create the direct exchange and queues

Create a direct exchange called direct_logs. Create two queues called info_queue and error_queue.

RabbitMQ

# Your code here to declare exchange and queues

Need a hint?

Use exchange_declare with exchange_type='direct' and queue_declare for queues.

2

Bind queues to the direct exchange with routing keys

Bind the queue info_queue to the exchange direct_logs with routing key info. Bind the queue error_queue to the exchange direct_logs with routing key error.

RabbitMQ

import pika

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

channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
channel.queue_declare(queue='info_queue')
channel.queue_declare(queue='error_queue')

# Bind info_queue with routing key 'info'
# Bind error_queue with routing key 'error'
# Your code here

Need a hint?

Use queue_bind with the correct exchange, queue, and routing_key.

3

Publish messages with routing keys

Publish a message 'Info message' with routing key info to the exchange direct_logs. Publish a message 'Error message' with routing key error to the same exchange.

RabbitMQ

import pika

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

channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
channel.queue_declare(queue='info_queue')
channel.queue_declare(queue='error_queue')

channel.queue_bind(exchange='direct_logs', queue='info_queue', routing_key='info')
channel.queue_bind(exchange='direct_logs', queue='error_queue', routing_key='error')

# Publish 'Info message' with routing key 'info'
# Publish 'Error message' with routing key 'error'
# Your code here

Need a hint?

Use basic_publish with the correct exchange, routing_key, and body.

4

Consume and print messages from both queues

Consume one message from info_queue and print it. Then consume one message from error_queue and print it.

RabbitMQ

import pika

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

channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
channel.queue_declare(queue='info_queue')
channel.queue_declare(queue='error_queue')

channel.queue_bind(exchange='direct_logs', queue='info_queue', routing_key='info')
channel.queue_bind(exchange='direct_logs', queue='error_queue', routing_key='error')

channel.basic_publish(exchange='direct_logs', routing_key='info', body='Info message')
channel.basic_publish(exchange='direct_logs', routing_key='error', body='Error message')

# Consume one message from info_queue and print it
# Consume one message from error_queue and print it
# Your code here

Need a hint?

Use basic_get to get messages from queues and print the decoded body.