在 python 中操作 rabbitmq 最常用的方式是使用 pika 库，它功能稳定且简单易用。1. 安装 pika 使用 pip install pika，并通过 blockingconnection 建立同步连接；2. 声明队列时设置 durable=true 以实现持久化，声明交换机时使用 exchange_declare 方法并指定类型如 fanout；3. 发送消息时通过 basic_publish 方法，设置 delivery_mode=2 保证消息持久化，接收消息时定义 callback 函数并调用 basic_consume 启动消费循环，同时使用 basic_ack 实现手动确认；4. 注意处理连接断开、消息顺序性、死信队列及性能优化等问题，推荐使用确认机制而非事务提交。
在 Python 中操作 RabbitMQ 最常用的方式是使用 pika 这个库。它是一个纯 Python 实现的 AMQP 客户端，功能稳定、简单易用，适合大多数消息队列场景。下面我们就从实际使用的角度出发，介绍几个关键点。
1. 安装与基本连接
首先，你需要安装 pika 库：
pip install pika
连接 RabbitMQ 的第一步是建立一个到 Broker 的通道。通常我们使用 BlockingConnection 来创建同步连接：
立即学习“Python免费学习笔记（深入）”；
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()上面这段代码会连接本地运行的 RabbitMQ 服务，默认用户和端口即可工作。如果 RabbitMQ 部署在远程服务器上，记得修改 'localhost' 为对应的 IP 或域名。
2. 声明队列与交换机
RabbitMQ 是基于队列和交换机（Exchange）模型工作的。最简单的例子是“直接发送到队列”的模式，这时我们可以不指定 Exchange，使用默认的。
声明一个队列：
channel.queue_declare(queue='task_queue', durable=True)
这里有个小细节：durable=True 表示这个队列是持久化的，即使 RabbitMQ 重启也不会丢失。如果你的消息很重要，建议加上这个参数。
如果你要用到发布/订阅或者路由模式，就需要手动声明 Exchange：
channel.exchange_declare(exchange='logs', exchange_type='fanout')
然后就可以通过 basic_publish 发送消息了。
3. 发送与接收消息的基本方法
发送消息：
channel.basic_publish(
exchange='logs',
routing_key='',
body='Hello World!',
properties=pika.BasicProperties(delivery_mode=2) # 消息持久化
)注意：
-
exchange可以留空，表示使用默认交换机。 -
routing_key就是队列名，当使用默认交换机时。 - 如果你希望消息不会因为 RabbitMQ 崩溃而丢失，要设置
delivery_mode=2。
接收消息：
接收端需要定义一个回调函数，并启动消费循环：
def callback(ch, method, properties, body):
print(f"收到消息: {body}")
ch.basic_ack(delivery_tag=method.delivery_tag) # 手动确认
channel.basic_consume(queue='task_queue', on_message_callback=callback)
channel.start_consuming()这里有几个重点：
-
basic_ack是手动确认机制，确保消息处理完后再告诉 RabbitMQ 可以删除了。 - 如果不确认，消息可能会被重复消费。
-
start_consuming()是一个阻塞方法，一旦调用就会一直监听消息。
4. 常见问题与注意事项
-
连接断开处理：生产环境中网络不稳定可能导致连接中断。可以考虑使用重连机制或改用
SelectConnection等异步方式。 - 消息顺序性：RabbitMQ 不保证全局有序，多个消费者并发消费时可能出现乱序。
- 死信队列（DLQ）：对于失败多次的消息，可以通过设置 TTL 和绑定 DLQ 来集中处理。
-
性能优化：
- 使用持久化会降低性能，但更安全。
- 开启确认机制也会增加网络交互次数。
- 可以使用
tx_*方法进行事务提交，但一般推荐使用确认机制。
基本上就这些。pika 虽然简单，但在实际项目中用好也不太容易，尤其是在高并发、异常处理、消息可靠性方面需要多加注意。
