guaiwoluo2020
538 lines
14 KiB
Markdown
538 lines
14 KiB
Markdown
# 高频交易服务 (HFT Trading Service)
|
||
|
||
一个为MT5 EA提供支持的高性能交易服务，采用FastAPI框架，集成行情分析、信号生成、策略决策、风险管理等功能。
|
||
|
||
## 目录
|
||
|
||
- [功能特性](#功能特性)
|
||
- [系统架构](#系统架构)
|
||
- [快速开始](#快速开始)
|
||
- [配置说明](#配置说明)
|
||
- [API文档](#api文档)
|
||
- [前端界面](#前端界面)
|
||
- [开发指南](#开发指南)
|
||
|
||
---
|
||
|
||
## 功能特性
|
||
|
||
### 核心功能
|
||
|
||
#### 1. K线数据管理
|
||
- 支持多周期K线数据接收 (H4/H1/M15/M5/M1)
|
||
- 增量/全量数据校验与存储
|
||
- 数据时效性检查（自动识别休市状态）
|
||
|
||
#### 2. 转折点检测
|
||
- 基于分型识别算法自动检测高低点
|
||
- 多周期转折点联动分析
|
||
- 接近阈值提醒（可配置各周期阈值）
|
||
|
||
#### 3. 信号系统
|
||
- **Pivot信号**: 转折点触发信号（支持M1/M5/M15/H1/H4周期）
|
||
- **KeyLevel信号**: 关键点位触发信号
|
||
- **AI Entry信号**: LLM分析入场信号
|
||
- 支持周期级别启用/禁用和权重配置
|
||
|
||
#### 4. 策略决策
|
||
- 多信号综合分析
|
||
- 周期级别权重配置
|
||
- 一致性要求设置（任一/多数/全部）
|
||
- 自动止损止盈计算
|
||
- 风险回报比验证
|
||
|
||
#### 5. 风险管理
|
||
- 账户风险百分比控制
|
||
- 最大持仓数量限制
|
||
- 同向持仓限制
|
||
- 动态止损范围验证
|
||
|
||
#### 6. LLM分析
|
||
- OpenAI兼容API支持
|
||
- 多周期趋势分析
|
||
- 关键支撑/阻力位识别
|
||
- 交易建议生成
|
||
|
||
#### 7. 新闻与事件
|
||
- 金十数据快讯抓取
|
||
- 财经日历事件
|
||
- 市场事件监控
|
||
|
||
---
|
||
|
||
## 系统架构
|
||
|
||
```
|
||
┌─────────────────────────────────────────────────────────────────┐
|
||
│ 前端 (Vue.js + Vuetify) │
|
||
│ ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌────────┐ │
|
||
│ │ Market │ │Settings │ │Positions │ │ News │ │ Log │ │
|
||
│ └────┬─────┘ └────┬─────┘ └────┬─────┘ └────┬─────┘ └───┬────┘ │
|
||
└───────┼────────────┼────────────┼────────────┼────────────┼──────┘
|
||
│ │ │ │ │
|
||
└────────────┴────────────┴─────┬──────┴────────────┘
|
||
│
|
||
┌────────▼────────┐
|
||
│ FastAPI 服务 │
|
||
│ (Port 8000) │
|
||
└────────┬────────┘
|
||
│
|
||
┌──────────────────────────────┼──────────────────────────────┐
|
||
│ │ │
|
||
▼ ▼ ▼
|
||
┌───────────────┐ ┌───────────────┐ ┌───────────────┐
|
||
│ 行情模块 │ │ 信号/策略 │ │ 新闻模块 │
|
||
│ │ │ │ │ │
|
||
│ • KlineStore │ │ • SignalService│ │ • FlashNews │
|
||
│ • KlineService│ │ • StrategySvc │ │ • Calendar │
|
||
│ • PivotService│ │ • RiskManager │ │ • NewsCrawler │
|
||
│ • TechService │ │ • PendingOrder│ │ │
|
||
└───────┬───────┘ └───────┬───────┘ └───────────────┘
|
||
│ │
|
||
│ ┌───────┴───────┐
|
||
│ │ │
|
||
▼ ▼ ▼
|
||
┌───────────────┐ ┌───────────────┐ ┌───────────────┐
|
||
│ LLM分析 │ │ 信号生成器 │ │ 存储层 │
|
||
│ │ │ │ │ │
|
||
│ • LLMService │ │ • PivotSignal │ │ • JSON文件 │
|
||
│ • LLMAnalyzer │ │ • KeyLevel │ │ • 内存缓存 │
|
||
│ │ │ • AI Entry │ │ │
|
||
└───────────────┘ └───────────────┘ └───────────────┘
|
||
│
|
||
▼
|
||
┌───────────────┐
|
||
│ MT5 EA │
|
||
│ │
|
||
│ • K线推送 │
|
||
│ • 统计上报 │
|
||
│ • 获取指令 │
|
||
│ • 执行交易 │
|
||
└───────────────┘
|
||
```
|
||
|
||
### 模块结构
|
||
|
||
```
|
||
.
|
||
├── main.py # 服务入口
|
||
├── server.py # TradingServer 核心类
|
||
├── routes_*.py # API路由模块
|
||
│ ├── routes_ea.py # EA接口
|
||
│ ├── routes_market.py # 行情/策略接口
|
||
│ ├── routes_position.py # 持仓接口
|
||
│ ├── routes_news.py # 新闻接口
|
||
│ ├── routes_trader.py # 交易员接口
|
||
│ └── routes_system.py # 系统接口
|
||
├── market/ # 核心模块
|
||
│ ├── models/ # 数据模型
|
||
│ │ ├── kline.py # K线模型
|
||
│ │ ├── pivot.py # 转折点模型
|
||
│ │ ├── trading_signal.py # 信号模型
|
||
│ │ ├── trading_strategy.py # 策略模型
|
||
│ │ ├── pending_order.py # 待确认订单
|
||
│ │ └── ...
|
||
│ ├── services/ # 业务服务
|
||
│ │ ├── kline_service.py # K线服务
|
||
│ │ ├── pivot_service.py # 转折点服务
|
||
│ │ ├── signal/ # 信号生成器
|
||
│ │ │ ├── signal_service.py
|
||
│ │ │ ├── pivot_signal.py
|
||
│ │ │ ├── key_level_signal.py
|
||
│ │ │ └── ai_entry_signal.py
|
||
│ │ ├── strategy/ # 策略服务
|
||
│ │ │ ├── strategy_service.py
|
||
│ │ │ └── risk_manager.py
|
||
│ │ └── llm_service.py # LLM分析服务
|
||
│ ├── store/ # 数据存储
|
||
│ │ ├── kline_store.py
|
||
│ │ ├── pivot_store.py
|
||
│ │ ├── signal_store.py
|
||
│ │ ├── strategy_store.py
|
||
│ │ └── ...
|
||
│ ├── llm_analyzer.py # LLM分析调度器
|
||
│ ├── market_event_monitor.py # 市场事件监控
|
||
│ ├── trade_config.py # 交易配置
|
||
│ └── system_log.py # 系统日志
|
||
├── data/ # 数据文件目录
|
||
│ ├── strategy_config.json
|
||
│ ├── trade_config.json
|
||
│ └── ...
|
||
└── frontend/ # Vue.js前端
|
||
└── src/
|
||
├── views/ # 页面组件
|
||
│ ├── Market.vue # 行情分析
|
||
│ ├── Settings.vue # 系统设置
|
||
│ ├── Positions.vue # 持仓管理
|
||
│ ├── News.vue # 新闻资讯
|
||
│ └── SystemLog.vue # 系统日志
|
||
└── api/ # API封装
|
||
└── market.js
|
||
```
|
||
|
||
---
|
||
|
||
## 快速开始
|
||
|
||
### 环境要求
|
||
|
||
- Python 3.9+
|
||
- Node.js 18+ (前端开发)
|
||
|
||
### 安装依赖
|
||
|
||
```bash
|
||
# Python依赖
|
||
pip install fastapi uvicorn uvloop pydantic requests aiohttp openai
|
||
|
||
# 前端依赖
|
||
cd frontend
|
||
npm install
|
||
```
|
||
|
||
### 启动服务
|
||
|
||
```bash
|
||
# 启动后端服务 (端口8000)
|
||
python3 main.py
|
||
|
||
# 启动前端开发服务 (端口5173)
|
||
cd frontend
|
||
npm run dev
|
||
|
||
# 构建前端生产版本
|
||
npm run build
|
||
```
|
||
|
||
### 验证服务
|
||
|
||
```bash
|
||
# 健康检查
|
||
curl http://localhost:8000/health
|
||
|
||
# 查看API文档
|
||
open http://localhost:8000/docs
|
||
```
|
||
|
||
---
|
||
|
||
## 配置说明
|
||
|
||
### 交易配置 (data/trade_config.json)
|
||
|
||
```json
|
||
{
|
||
"enabled": true,
|
||
"default_volume": 0.01,
|
||
"default_sl_offset": 0.05,
|
||
"mt5_timezone_offset": -6.0,
|
||
"symbol_config": {
|
||
"GOLD#": {
|
||
"volume": 0.01,
|
||
"sl_offset": 3,
|
||
"key_levels": "5000,5100,5200",
|
||
"key_level_threshold": 0.0008
|
||
}
|
||
}
|
||
}
|
||
```
|
||
|
||
### 策略配置 (data/strategy_config.json)
|
||
|
||
```json
|
||
{
|
||
"strategies": {
|
||
"GOLD#": {
|
||
"enabled": true,
|
||
"signal_config": {
|
||
"pivot": {
|
||
"enabled": true,
|
||
"periods": {
|
||
"M1": {"enabled": true, "weight": 15},
|
||
"M5": {"enabled": true, "weight": 20},
|
||
"M15": {"enabled": false, "weight": 25},
|
||
"H1": {"enabled": false, "weight": 20},
|
||
"H4": {"enabled": false, "weight": 20}
|
||
}
|
||
},
|
||
"key_level": {
|
||
"enabled": true,
|
||
"weight": 40
|
||
},
|
||
"ai_entry": {
|
||
"enabled": true,
|
||
"periods": {
|
||
"M5": {"enabled": true, "weight": 20},
|
||
"M15": {"enabled": true, "weight": 30},
|
||
"H1": {"enabled": true, "weight": 25}
|
||
}
|
||
}
|
||
},
|
||
"min_confidence": 50,
|
||
"consistency_requirement": "majority",
|
||
"min_risk_reward": 1.0,
|
||
"max_positions": 3,
|
||
"max_same_direction": 2
|
||
}
|
||
}
|
||
}
|
||
```
|
||
|
||
### LLM配置
|
||
|
||
通过API或前端设置：
|
||
|
||
```bash
|
||
curl -X POST http://localhost:8000/llm/configure \
|
||
-H "Content-Type: application/json" \
|
||
-d '{
|
||
"api_key": "your-api-key",
|
||
"api_base": "https://api.openai.com/v1",
|
||
"model": "gpt-4o-mini"
|
||
}'
|
||
```
|
||
|
||
---
|
||
|
||
## API文档
|
||
|
||
### EA接口
|
||
|
||
#### 获取交易指令
|
||
```
|
||
GET /get_trades?symbol=GOLD#&price=4850.00
|
||
```
|
||
|
||
返回该品种待执行的交易指令列表。
|
||
|
||
#### 推送K线数据
|
||
```
|
||
POST /ea/kline/{period}
|
||
POST /ea/kline_batch
|
||
```
|
||
|
||
**请求体示例**:
|
||
```json
|
||
{
|
||
"symbol": "GOLD#",
|
||
"is_full": false,
|
||
"klines": [
|
||
{
|
||
"time": "2026-03-19 10:00:00",
|
||
"open": 4850.00,
|
||
"high": 4855.00,
|
||
"low": 4848.00,
|
||
"close": 4852.00,
|
||
"volume": 1000
|
||
}
|
||
]
|
||
}
|
||
```
|
||
|
||
**返回码说明**:
|
||
- `200`: 成功
|
||
- `400 (code: 8888)`: 需要全量数据（数据不连续或未初始化）
|
||
|
||
#### 发送统计数据
|
||
```
|
||
POST /send_statistics
|
||
```
|
||
|
||
### 行情接口
|
||
|
||
#### 查询K线数据
|
||
```
|
||
GET /market/kline/{symbol}?period=M5&count=100
|
||
```
|
||
|
||
#### 查询转折点
|
||
```
|
||
GET /market/pivots/{symbol}?period=M5&direction=high&count=50
|
||
```
|
||
|
||
#### 获取行情状态
|
||
```
|
||
GET /market/status
|
||
GET /market/configured_symbols
|
||
```
|
||
|
||
### 策略接口
|
||
|
||
#### 获取策略配置
|
||
```
|
||
GET /strategy
|
||
GET /strategy/{symbol}
|
||
```
|
||
|
||
#### 更新策略配置
|
||
```
|
||
POST /strategy/{symbol}
|
||
```
|
||
|
||
**请求体示例**:
|
||
```json
|
||
{
|
||
"enabled": true,
|
||
"signal_config": {
|
||
"pivot": {
|
||
"enabled": true,
|
||
"periods": {
|
||
"M5": {"enabled": true, "weight": 25}
|
||
}
|
||
}
|
||
},
|
||
"min_confidence": 60
|
||
}
|
||
```
|
||
|
||
#### 获取决策历史
|
||
```
|
||
GET /strategy/decisions?symbol=GOLD#&count=20
|
||
```
|
||
|
||
#### 手动触发决策
|
||
```
|
||
POST /strategy/trigger/{symbol}
|
||
```
|
||
|
||
### 持仓接口
|
||
|
||
```
|
||
GET /positions
|
||
GET /positions/summary
|
||
POST /close_position
|
||
```
|
||
|
||
### 新闻接口
|
||
|
||
```
|
||
GET /api/news/flash?count=10
|
||
GET /api/news/calendar?date=2026-03-19
|
||
```
|
||
|
||
### WebSocket接口
|
||
|
||
#### 转折点提醒
|
||
```
|
||
ws://localhost:8000/ws/market
|
||
```
|
||
|
||
#### 新闻推送
|
||
```
|
||
ws://localhost:8000/api/news/ws
|
||
```
|
||
|
||
---
|
||
|
||
## 前端界面
|
||
|
||
### 行情分析 (Market)
|
||
- 多周期K线展示
|
||
- 转折点标注
|
||
- AI趋势分析
|
||
- 交易决策提醒
|
||
- 待确认订单操作
|
||
|
||
### 系统设置 (Settings)
|
||
- 自动交易开关
|
||
- 品种配置管理
|
||
- 策略配置（信号权重、仓位管理、止损止盈）
|
||
- LLM配置
|
||
- 品种数据状态
|
||
|
||
### 持仓管理 (Positions)
|
||
- 实时持仓列表
|
||
- 盈亏统计
|
||
- 一键平仓
|
||
|
||
### 新闻资讯 (News)
|
||
- 快讯列表
|
||
- 财经日历
|
||
- 事件提醒
|
||
|
||
### 系统日志 (SystemLog)
|
||
- 操作日志
|
||
- 事件筛选
|
||
- 日志清空
|
||
|
||
---
|
||
|
||
## 开发指南
|
||
|
||
### 信号生成器扩展
|
||
|
||
在 `market/services/signal/` 目录下创建新的信号生成器：
|
||
|
||
```python
|
||
from market.models import TradingSignal, SignalSource
|
||
|
||
class MySignalGenerator:
|
||
def __call__(self, symbol: str, current_price: float) -> List[TradingSignal]:
|
||
# 实现信号生成逻辑
|
||
signals = []
|
||
# ...
|
||
return signals
|
||
```
|
||
|
||
注册到 SignalService：
|
||
|
||
```python
|
||
signal_service.register_generator("my_signal", MySignalGenerator())
|
||
```
|
||
|
||
### 策略参数说明
|
||
|
||
| 参数 | 类型 | 说明 |
|
||
|------|------|------|
|
||
| enabled | bool | 是否启用策略 |
|
||
| signal_config | dict | 信号源周期级别配置 |
|
||
| min_confidence | int | 最低置信度阈值 (0-100) |
|
||
| consistency_requirement | str | 一致性要求 (any/majority/all) |
|
||
| min_risk_reward | float | 最小风险回报比 |
|
||
| max_positions | int | 最大持仓数量 |
|
||
| max_same_direction | int | 同向最大持仓 |
|
||
| fixed_volume | float | 固定手数 |
|
||
| risk_percent | float | 账户风险百分比 |
|
||
|
||
### 数据存储
|
||
|
||
所有配置和数据存储在 `data/` 目录：
|
||
- `strategy_config.json` - 策略配置
|
||
- `trade_config.json` - 交易配置
|
||
- `kline_*.json` - K线缓存
|
||
- `pivot_*.json` - 转折点缓存
|
||
- `llm_*.json` - LLM分析结果
|
||
|
||
---
|
||
|
||
## 性能特性
|
||
|
||
- **FastAPI框架**: 高性能异步框架
|
||
- **UVloop**: 使用高性能事件循环
|
||
- **线程安全**: 核心数据使用锁保护
|
||
- **内存缓存**: 热数据内存缓存
|
||
- **增量更新**: K线支持增量推送
|
||
|
||
---
|
||
|
||
## 常见问题
|
||
|
||
### Q: 为什么某个品种没有AI趋势分析？
|
||
A: AI分析只处理有K线数据的活跃品种。检查EA是否正确推送该品种的K线数据。
|
||
|
||
### Q: 返回码8888是什么意思？
|
||
A: 表示服务端需要全量K线数据，通常是因为：
|
||
- 首次连接，没有历史数据
|
||
- 增量数据不连续，存在缺失
|
||
|
||
### Q: 如何调试信号生成？
|
||
A: 查看服务日志，信号生成器会打印详细信息：
|
||
```
|
||
[PivotSignalGenerator] 生成信号: buy @ 4850.00, SL=4840.00, TP=4870.00
|
||
```
|
||
|
||
---
|
||
|
||
## 许可证
|
||
|
||
MIT License |