问题描述不是很清晰,但我可以提供一个使用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服务正在运行,然后先运行生产者脚本发送消息,接着运行消费者脚本接收并打印消息。