# python-rabbitmq

**Repository Path**: minXAM/python-rabbitmq

## Basic Information

- **Project Name**: python-rabbitmq
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-12-12
- **Last Updated**: 2025-12-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Python-RabbitMQ 项目说明

这是一个基于 RabbitMQ 的订单处理系统，使用 Python 构建。该项目展示了如何使用 RabbitMQ 进行消息队列处理，并结合 FastAPI 和 WebSocket 实现实时订单状态更新。

## 主要功能

- 使用 RabbitMQ 实现订单消息队列处理
- 通过 FastAPI 提供 RESTful API 接口
- 使用 WebSocket 实现实时订单状态更新推送
- 包含死信队列 (DLX) 处理机制
- 提供订单监控服务

## 项目结构

- `fastapi_app.py` - FastAPI 应用，提供订单创建和状态查询接口
- `flask_app.py` - Flask 应用，提供传统 Web 接口
- `rabbitmq_manage_v23.py` - RabbitMQ 管理模块
- `rabbitmq_consumer.py` - 消息消费者处理模块
- `customer.py` - 客户端示例代码
- `monitor_service.py` - 订单监控服务
- `start_services.py` - 服务启动脚本

## 使用技术

- RabbitMQ 消息队列
- FastAPI WebSocket 实时通信
- 死信队列 (DLX) 机制
- Python 的 pika 库

## 安装与运行

1. 安装依赖:
```bash
pip install -r requirements.txt
```

2. 启动服务:
```bash
python start_services.py
```

3. 访问 API 文档:
打开浏览器访问 http://localhost:8000/docs 查看 API 文档

## 测试

运行集成测试:
```bash
python test_full_integration.py
```

## 注意事项

- 确保 RabbitMQ 服务已安装并运行
- 根据需要调整配置参数，如 RabbitMQ 的主机地址、端口等
- 项目包含多个消费者线程处理订单，可根据需求调整线程池大小

该项目适用于需要实现异步消息处理和实时状态更新的订单处理系统，可作为 RabbitMQ 在实际业务场景中的应用示例。