python 操作 rabbitmq代码
时间: 2023-07-02 07:15:20 浏览: 106
Python操作rabbitMQ的示例代码
好的,如果你想在 Python 中操作 RabbitMQ,可以使用 Pika 库。Pika 是一个 Python 实现的 RabbitMQ 客户端库,它提供了简单易用的接口来连接、发布和消费消息。以下是一个使用 Pika 库连接 RabbitMQ 并发送消息的示例代码:
```python
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 World!')
print(" [x] Sent 'Hello World!'")
# 关闭连接
connection.close()
```
以上代码会连接到名为 `localhost` 的 RabbitMQ 实例,并声明一个名为 `hello` 的队列。然后,它会将一条消息发送到该队列,并在控制台输出一条消息以确认发送已完成。
阅读全文