Why message queues decouple services in RabbitMQ - See It in Action

Why Message Queues Decouple Services with RabbitMQ

📖 Scenario: Imagine you run an online store where orders come in fast. You want to make sure your order processing system can handle many orders without slowing down the website. Using a message queue helps by letting your website quickly send order details to a queue, and a separate service processes them one by one.

🎯 Goal: Build a simple Python program that sends order messages to a RabbitMQ queue and another program that receives and processes these messages. This shows how message queues help separate (decouple) the website and order processing services.

📋 What You'll Learn

Create a list of order messages with exact order IDs and items

Set up a RabbitMQ queue named order_queue

Write code to send each order message to the order_queue

Write code to receive messages from order_queue and print order details

💡 Why This Matters

🌍 Real World

Message queues like RabbitMQ are used in real online stores, banking systems, and many apps to handle tasks smoothly and avoid delays.

💼 Career

Understanding message queues is important for DevOps and backend roles to build scalable, reliable systems that handle many users and tasks.

1

Create a list of order messages

Create a list called orders with these exact dictionaries: {'order_id': 101, 'item': 'Book'}, {'order_id': 102, 'item': 'Pen'}, and {'order_id': 103, 'item': 'Notebook'}.

RabbitMQ

# Create the list of orders
# Your code here

Need a hint?

Use a list with three dictionaries exactly as shown.

2

Set up RabbitMQ connection and queue

Import pika and create a connection to RabbitMQ on localhost. Then create a channel and declare a queue named order_queue.

RabbitMQ

orders = [
    {'order_id': 101, 'item': 'Book'},
    {'order_id': 102, 'item': 'Pen'},
    {'order_id': 103, 'item': 'Notebook'}
]

# Import pika and set up connection and queue
# Your code here

Need a hint?

Use pika.BlockingConnection with localhost and declare the queue order_queue.

3

Send order messages to the queue

Use a for loop with variable order to send each order from orders to the order_queue. Convert each order dictionary to a string using str(order) before sending.

RabbitMQ

import pika

orders = [
    {'order_id': 101, 'item': 'Book'},
    {'order_id': 102, 'item': 'Pen'},
    {'order_id': 103, 'item': 'Notebook'}
]

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='order_queue')

# Send each order to the queue
# Your code here

Need a hint?

Loop over orders and use channel.basic_publish with exchange='' and routing_key='order_queue'.

4

Receive and print order messages from the queue

Write code to connect to RabbitMQ, declare the order_queue, and consume messages. For each message, print Received order: followed by the message body decoded as UTF-8. Stop after receiving all three messages.

RabbitMQ

import pika

# Receive and print messages from order_queue
# Your code here

Need a hint?

Use a while loop with channel.basic_get(queue='order_queue', no_ack=False) to receive messages. Print each message body decoded as UTF-8. Acknowledge each message and stop after 3 messages.