RabbitMQ 消息确认机制详解

1. 生产者确认机制

当生产者发送消息到交换机时，可通过开启 Publisher Confirm 模式确保消息成功投递...

原文出处：docs/AMQP/AMQP_0-9-1_Model_Explained.md

### 核心功能实战：构建电商订单消息处理系统

📊 **场景案例：** 某电商平台订单处理流程

1. **架构设计**
- 订单服务（生产者）：用户下单后发送订单消息到 "order.exchange" 交换机
- 库存服务（消费者）：监听 "order.stock" 队列，处理库存扣减
- 物流服务（消费者）：监听 "order.logistics" 队列，生成物流单

2. **关键代码实现**
```python
# 生产者示例（订单服务）
import pika

# 建立连接
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明交换机和队列
channel.exchange_declare(exchange='order.exchange', exchange_type='direct', durable=True)
channel.queue_declare(queue='order.stock', durable=True)
channel.queue_bind(exchange='order.exchange', queue='order.stock', routing_key='stock')

# 发送订单消息
order_data = {
    "order_id": "ORD20230518001",
    "user_id": "USR10086",
    "items": [{"product_id": "PID9527", "quantity": 2}]
}
channel.basic_publish(
    exchange='order.exchange',
    routing_key='stock',
    body=str(order_data),
    properties=pika.BasicProperties(delivery_mode=2)  # 消息持久化
)

connection.close()

---

技术生态：RabbitMQ 周边工具与集成方案

1. 客户端生态

• Python 生态：Pika（官方推荐客户端）、Celery（分布式任务队列，基于 RabbitMQ 实现）
• Java 生态：Spring AMQP（Spring 框架集成模块）、RabbitTemplate（简化消息操作）
• Go 生态：amqp（Go 语言 AMQP 客户端实现）

2. 监控与运维工具

• RabbitMQ Management：Web 管理界面，提供队列监控、用户管理等功能
• Prometheus + Grafana：通过 rabbitmq_exporter 收集指标，构建可视化监控面板
• ELK Stack：集成日志收集，分析消息流转过程中的异常日志

---

常见问题排查：解决 RabbitMQ 实战中的典型难题

问题 1：消息堆积导致消费者处理延迟

现象：监控面板显示队列消息数量持续增长，消费者消费速度远低于生产速度

解决方案：

1. 检查消费者是否存在性能瓶颈，优化消费逻辑
2. 增加消费者实例数量，提高并行处理能力
3. 调整预取计数（prefetch_count），避免单个消费者占用过多未确认消息

# 通过命令行调整队列预取数
rabbitmqctl set_policy prefetch ".*" '{"prefetch_count": 10}' --apply-to queues