Message queue use cases in RabbitMQ - Mini Project: Build & Apply

Message Queue Use Cases with RabbitMQ

📖 Scenario: You are building a simple system where different parts of an application communicate by sending messages through a queue. This helps the parts work independently and handle tasks smoothly.

🎯 Goal: Learn how to set up a message queue using RabbitMQ in Python, send messages, and receive them. Understand the basic use case of message queues for decoupling parts of an application.

📋 What You'll Learn

Install pika Python library for RabbitMQ communication

Create a connection to RabbitMQ server

Declare a queue named task_queue

Send messages to the queue

Receive messages from the queue

💡 Why This Matters

🌍 Real World

Message queues like RabbitMQ are used in real applications to let different parts work independently. For example, a web server can send tasks to a queue, and workers can process them later without slowing down the user.

💼 Career

Understanding message queues is important for DevOps and backend roles. It helps you build scalable, reliable systems that handle many tasks smoothly.

1

Setup RabbitMQ Connection and Declare Queue

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

RabbitMQ

# Your code here to import pika, connect to localhost, create channel, and declare queue 'task_queue'

Need a hint?

Use pika.BlockingConnection with pika.ConnectionParameters('localhost'). Then call channel.queue_declare with the queue name.

2

Send a Message to the Queue

Use the channel to send a message with the body 'Hello RabbitMQ' to the queue named task_queue.

RabbitMQ

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='task_queue')
# Your code here to send 'Hello RabbitMQ' message to 'task_queue'

Need a hint?

Use channel.basic_publish with exchange='', routing_key='task_queue', and body='Hello RabbitMQ'.

3

Receive a Message from the Queue

Define a callback function named callback that prints the received message body. Use channel.basic_consume with the queue task_queue and the callback function. Start consuming messages with channel.start_consuming().

RabbitMQ

import pika

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

channel.basic_publish(exchange='', routing_key='task_queue', body='Hello RabbitMQ')

# Your code here to define callback, consume from 'task_queue', and start consuming

Need a hint?

Define callback with parameters ch, method, properties, body. Use print(f"Received message: {body.decode()}"). Then call channel.basic_consume with queue='task_queue' and on_message_callback=callback. Finally, call channel.start_consuming().

4

Print the Received Message Output

Run the program and observe the printed output from the callback function showing the received message.

RabbitMQ

import pika

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

channel.basic_publish(exchange='', routing_key='task_queue', body='Hello RabbitMQ')

def callback(ch, method, properties, body):
    print(f"Received message: {body.decode()}")

channel.basic_consume(queue='task_queue', on_message_callback=callback, auto_ack=true)

channel.start_consuming()

# Run the program and see the output below

Need a hint?

When you run the program, it should print exactly: Received message: Hello RabbitMQ.