python 操作rabbitmq

你可以使用 Python 来操作 RabbitMQ 消息队列。首先，你需要安装 pika 库，它是 RabbitMQ 的 Python 客户端库。你可以使用 pip 命令来安装：

pip install pika

接下来，你可以使用以下代码示例来连接 RabbitMQ 服务器、声明队列、发送消息和接收消息：

import pika

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

# 声明队列
channel.queue_declare(queue='hello')

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

print(" [x] Sent 'Hello, RabbitMQ!'")

# 定义回调函数来处理接收到的消息
def callback(ch, method, properties, body):
    print(" [x] Received %r" % 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 服务器，然后声明一个名为 "hello" 的队列。然后它发送一条消息到队列中，并打印出发送的消息。接下来，它定义了一个回调函数来处理接收到的消息，并使用 `basic_consume` 方法开始接收消息。最后，它进入一个无限循环，等待并处理接收到的消息。

注意：在实际使用中，你可能需要根据你的 RabbitMQ 服务器配置进行适当的修改。