python的pika怎么用
时间: 2023-07-08 08:17:39 浏览: 200
python中pika模块问题的深入探究
Pika是Python中的一个AMQP客户端库,用于与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()
```
在这个示例中,我们首先建立了与RabbitMQ服务器的连接,然后创建了一个名为“hello”的队列。接下来,我们使用`channel.basic_publish()`方法向队列发送一条消息,并使用`connection.close()`方法关闭连接。
阅读全文