rabbitmq python

# 导入pika库，用于与RabbitMQ进行交互
import pika

# 建立与RabbitMQ服务器的连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明一个队列，确保消息可以发送到队列中
channel.queue_declare(queue='hello')

# 定义回调函数，处理接收到的消息
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

# 告诉RabbitMQ使用callback来接收消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

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

# 开始接收消息，并进入阻塞状态
channel.start_consuming()

解释说明：

1. 导入pika库：pika 是一个用于与 RabbitMQ 交互的 Python 库。
2. 建立连接：使用 pika.BlockingConnection 创建一个到 RabbitMQ 服务器的连接。ConnectionParameters('localhost') 指定了 RabbitMQ 服务器的地址为本地主机。
3. 声明队列：通过 channel.queue_declare(queue='hello') 声明一个名为 hello 的队列，确保消息可以发送到该队列中。
4. 定义回调函数：callback 函数用于处理从队列中接收到的消息。它会打印出接收到的消息内容。
5. 消费消息：通过 channel.basic_consume 方法告诉 RabbitMQ 使用 callback 函数来接收来自 hello 队列的消息。auto_ack=True 表示自动确认消息已被接收。
6. 开始接收消息：调用 channel.start_consuming() 进入阻塞状态，等待并处理消息。

这个示例展示了如何使用 Python 和 RabbitMQ 进行简单的消息传递。