往rabbitmq中发送消息代码
时间: 2023-07-02 22:13:45 浏览: 182
【SpringBoot MQ 系列】RabbitMq 消息发送基本使用姿势
以下是使用Python 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!')
# 关闭连接
connection.close()
```
以上代码实现了向名为`hello`的消息队列发送一条消息`Hello World!`。其中,`exchange`参数为空表示使用默认的交换机,`routing_key`参数设置为队列名即可将消息发送到指定队列中。如果队列不存在,会自动创建。在实际应用中,可以根据需求自定义队列名和消息内容。
阅读全文