Getting Started with RabbitMQ

0. Offical Doc

https://www.rabbitmq.com/docs

1. Install RabbitMQ with docker

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4-management

2. Using the Pika Python client

send.py

import pika

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

# Declare a queue named 'hello'
channel.queue_declare(queue='hello')

# Publish a message to the 'hello' queue
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')

print(" [x] Sent 'Hello World!'")

connection.close()

import pika

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


def callback(ch, method, properties, body):
    print(f" [x] Received {body}")


channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)
channel.queue_declare(queue='hello')

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()