RabbitMQ python
时间: 2023-08-31 08:12:25 浏览: 50
RabbitMQ是一个开源的消息队列系统,可以用于实现异步任务、解耦系统之间的通信、消息分发等场景。在Python中使用RabbitMQ需要先安装pika库,可以通过pip工具进行安装:
```
pip install pika
```
下面是一个简单的示例,发送和接收消息:
```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!'")
# 接收消息
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()
# 关闭连接
connection.close()
```
这个示例中,先连接到本地的RabbitMQ服务器,然后创建一个名为“hello”的队列。接着发送一条消息,再通过回调函数接收并输出这条消息。最后关闭连接。