python rabbitmq发消息样例

在Python中，使用RabbitMQ发送消息通常涉及pika库，这是一个AMQP（Advanced Message Queuing Protocol）客户端。下面是一个简单的例子，展示了如何连接到RabbitMQ服务器并发送一条消息：

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()

在这个示例中，首先创建了一个连接并打开一个通道，然后声明了交换机和队列。接着，发布了一条消息到指定的交换机和队列，最后关闭连接。