生成rabbitMQ发消息demo
时间: 2023-10-01 08:09:22 浏览: 87
rabbitMQ 消息队列 Demo
以下是生成RabbitMQ发消息的Demo,使用Python的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!'")
# 关闭连接
connection.close()
```
在这个Demo中,我们首先连接到RabbitMQ服务器,然后声明一个名为“hello”的队列。接着,我们使用`channel.basic_publish()`方法发送消息到队列中,消息的内容为“Hello World!”。最后,我们关闭连接。
阅读全文