rabbitmq使用 python

RabbitMQ 是一个流行的开源消息队列软件，它使用 AMQP（高级消息队列协议）来进行消息传递。在 Python 中使用 RabbitMQ 可以通过 RabbitMQ 的官方 Python 客户端库 pika 来实现。

首先，你需要安装 pika。你可以使用 pip 命令进行安装：

pip install pika

接下来，你可以使用以下代码示例来连接 RabbitMQ，并发送和接收消息：

import pika

# 连接到 RabbitMQ 服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建一个队列
channel.queue_declare(queue='my_queue')

# 发送消息
channel.basic_publish(exchange='', routing_key='my_queue', body='Hello, RabbitMQ!')

print(" [x] Message sent")

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

# 开始监听队列中的消息
channel.basic_consume(queue='my_queue', on_message_callback=callback, auto_ack=True)

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

# 进入一个循环，保持监听状态
channel.start_consuming()

这是一个基本的示例，它演示了如何连接到 RabbitMQ，创建一个队列，并发送和接收消息。你可以根据自己的需求进行更多的定制和扩展。记得在代码中替换 `'localhost'` 为 RabbitMQ 服务器的地址。

希望这能帮助到你开始使用 RabbitMQ。如果你有更多的问题，请随时提问。