Request-reply pattern in RabbitMQ - Mini Project: Build & Apply

Request-Reply Pattern with RabbitMQ

📖 Scenario: You are building a simple messaging system where a client sends a request message to a server, and the server sends back a reply message. This is a common pattern called the request-reply pattern used in messaging systems like RabbitMQ.Imagine you want to ask a server for the current time, and the server replies with the time.

🎯 Goal: Build a basic RabbitMQ request-reply system in Python. You will create a client that sends a request message to a queue, and a server that listens to that queue, processes the request, and sends back a reply to the client.

📋 What You'll Learn

Use the pika library to connect to RabbitMQ

Create a request queue named rpc_queue

Client sends a request message with a unique correlation_id and a reply_to queue

Server listens on rpc_queue, processes the request, and sends the reply to the reply_to queue with the same correlation_id

Client waits for the reply message with the matching correlation_id and prints the reply

💡 Why This Matters

🌍 Real World

Request-reply messaging is used in microservices to ask for data or trigger actions and wait for results asynchronously.

💼 Career

Understanding request-reply patterns with RabbitMQ is essential for backend developers and DevOps engineers working with distributed systems and messaging queues.

1

Setup RabbitMQ connection and declare rpc_queue

Write code to connect to RabbitMQ on localhost using pika.BlockingConnection and create a channel. Declare a queue named rpc_queue using channel.queue_declare(queue='rpc_queue').

RabbitMQ

# Connect to RabbitMQ and declare the rpc_queue
# Your code here

Need a hint?

Use pika.BlockingConnection with pika.ConnectionParameters('localhost') to connect. Then use channel.queue_declare to create the queue.

2

Create a unique correlation_id and a reply_to queue for the client

Add code to generate a unique correlation_id string using uuid.uuid4(). Declare a new exclusive callback queue for replies using channel.queue_declare(queue='', exclusive=True). Store the callback queue name in callback_queue.

RabbitMQ

import uuid

# Generate a unique correlation_id
correlation_id = str(uuid.uuid4())

# Declare an exclusive callback queue for replies
callback_queue = channel.queue_declare(queue='', exclusive=True).method.queue
# Your code here

Need a hint?

Use the uuid library to create a unique correlation_id. Declare a queue with an empty name and exclusive=True to get a private callback queue.

3

Send a request message with correlation_id and reply_to, and consume the reply

Publish a message with body 'What is the time?' to the rpc_queue with properties correlation_id=correlation_id and reply_to=callback_queue. Set up a consumer on callback_queue that listens for messages with the matching correlation_id and stores the reply in a variable response. Use channel.start_consuming() to wait for the reply.

RabbitMQ

# Send request message with correlation_id and reply_to
channel.basic_publish(
    exchange='',
    routing_key='rpc_queue',
    properties=pika.BasicProperties(correlation_id=correlation_id, reply_to=callback_queue),
    body='What is the time?'
)

response = None

def on_response(ch, method, props, body):
    global response
    if props.correlation_id == correlation_id:
        response = body.decode()
        ch.stop_consuming()

channel.basic_consume(queue=callback_queue, on_message_callback=on_response, auto_ack=True)
channel.start_consuming()
# Your code here

Need a hint?

Use channel.basic_publish with pika.BasicProperties to set correlation_id and reply_to. Then consume messages on the callback queue and check the correlation_id to find the reply.

4

Print the reply message received from the server

Write a print statement to display the response variable which contains the reply message from the server.

RabbitMQ

# Print the reply message stored in response
# Your code here

Need a hint?

Use print(response) to show the reply message received from the server.