Why producer-consumer is the basic messaging pattern in RabbitMQ - See It in Action

Why producer-consumer is the basic messaging pattern

📖 Scenario: You are learning how messaging works in RabbitMQ, a tool that helps different parts of a system talk to each other without waiting. This is like a kitchen where a chef (producer) prepares dishes and a waiter (consumer) serves them to customers. Understanding this helps you build systems that work smoothly and don't get stuck.

🎯 Goal: Build a simple Python program that shows the producer-consumer pattern using RabbitMQ. You will create a message queue, send messages (producer), and receive messages (consumer) step-by-step.

📋 What You'll Learn

Create a message queue named task_queue

Write a producer that sends exactly three messages: 'Task 1', 'Task 2', and 'Task 3'

Write a consumer that receives messages from task_queue and prints them

Show the output of the consumer printing each received message

💡 Why This Matters

🌍 Real World

Producer-consumer messaging is used in real systems like order processing, notifications, and task scheduling where parts of the system work independently but need to communicate.

💼 Career

Understanding this pattern is essential for DevOps roles that manage message brokers like RabbitMQ, ensuring reliable and scalable communication between services.

1

Setup RabbitMQ connection and declare queue

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

RabbitMQ

import pika

# Connect to RabbitMQ server on localhost
# Create a channel
# Declare a queue named 'task_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

Send messages as the producer

Use the channel.basic_publish method to send three messages: 'Task 1', 'Task 2', and 'Task 3' to the task_queue. Use the exchange parameter as an empty string and routing_key as 'task_queue'.

RabbitMQ

import pika

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

# Send 'Task 1', 'Task 2', and 'Task 3' messages to 'task_queue'
# Your code here

Need a hint?

Call channel.basic_publish three times with the correct exchange, routing_key, and body values.

3

Create a consumer to receive messages

Define a callback function named callback that takes ch, method, properties, and body parameters. Inside it, print Received: {body.decode()}. Then use channel.basic_consume with queue='task_queue', on_message_callback=callback, and auto_ack=True. Finally, start consuming with channel.start_consuming().

RabbitMQ

import pika

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

# Define callback function to print received messages
# Use channel.basic_consume with queue='task_queue', on_message_callback=callback, auto_ack=True
# Start consuming messages
# Your code here

Need a hint?

Define a function callback that prints the message body decoded as a string. Then use basic_consume and start_consuming to receive messages.

4

Run the consumer and observe output

Run the full program. The consumer should print each message it receives from task_queue. Write a print statement that shows the output lines exactly as:
Received: Task 1
Received: Task 2
Received: Task 3

RabbitMQ

import pika

# Run the program and observe the output
# Your code here

Need a hint?

Run the consumer code. It will print each message as it receives it. The output should show three lines, one for each task.