RabbitMQ 基础篇

问题描述不是很清晰，但我可以提供一个使用RabbitMQ的基本Python示例。这个示例展示了如何创建一个生产者（发送消息）和一个消费者（接收消息并打印）。

首先，确保已经安装了pika库，这是一个用于与RabbitMQ交互的Python库。如果没有安装，可以通过以下命令安装：

pip install pika

生产者代码（发送消息）:

import pika
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
channel.queue_declare(queue='hello')
 
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")
 
connection.close()

消费者代码（接收消息并打印）:

import pika
 
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
 
channel.queue_declare(queue='hello')
 
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
 
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
 
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

确保RabbitMQ服务正在运行，然后先运行生产者脚本发送消息，接着运行消费者脚本接收并打印消息。