python3代码测试rabbitMQ连接
时间: 2023-09-20 09:13:27 浏览: 115
以下是一个简单的 Python 3 代码示例,用于测试 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()
```
在此代码中,我们使用 `pika` 库来连接到本地主机上的 RabbitMQ 实例。然后我们声明一个名为 `hello` 的队列,并将一条消息发送到该队列。最后,我们关闭了连接。
请注意,这只是一个基本的示例代码,实际应用程序可能需要更多的错误处理和其他功能。
阅读全文