python rabbitmq发消息样例
时间: 2024-07-27 14:01:41 浏览: 111
在Python中,使用RabbitMQ发送消息通常涉及pika库,这是一个AMQP(Advanced Message Queuing Protocol)客户端。下面是一个简单的例子,展示了如何连接到RabbitMQ服务器并发送一条消息:
```python
import pika
# 创建连接参数
connection_params = pika.ConnectionParameters(
'localhost', # RabbitMQ服务器地址,默认为本机
5672, # 默认端口
'guest', # 默认用户(如果没有修改过)
'guest' # 默认密码
)
# 连接到服务器
connection = pika.BlockingConnection(connection_params)
channel = connection.channel()
# 定义交换机和队列
exchange_name = 'my_exchange'
queue_name = 'my_queue'
# 声明交换机和队列(如果不存在)
channel.exchange_declare(exchange=exchange_name, exchange_type='direct')
channel.queue_declare(queue=queue_name)
# 发送消息
message = "Hello World!"
routing_key = 'key_for_routing' # 根据需要选择路由键
channel.basic_publish(
exchange=exchange_name,
routing_key=routing_key,
body=message,
)
print(f" [x] Sent {message}")
# 关闭连接
connection.close()
```
在这个示例中,首先创建了一个连接并打开一个通道,然后声明了交换机和队列。接着,发布了一条消息到指定的交换机和队列,最后关闭连接。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)