guaiwoluo2020高频交易服务 (HFT Trading Service)
一个为MT5 EA提供支持的高性能交易服务，采用FastAPI框架，集成行情分析、信号生成、策略决策、风险管理等功能。
目录
功能特性
核心功能
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+ (前端开发)
安装依赖
# Python依赖
pip install fastapi uvicorn uvloop pydantic requests aiohttp openai
# 前端依赖
cd frontend
npm install
启动服务
# 启动后端服务 (端口8000)
python3 main.py
# 启动前端开发服务 (端口5173)
cd frontend
npm run dev
# 构建前端生产版本
npm run build
验证服务
# 健康检查
curl http://localhost:8000/health
# 查看API文档
open http://localhost:8000/docs
配置说明
交易配置 (data/trade_config.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)
{
"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或前端设置：
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
请求体示例:
{
"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}
请求体示例:
{
"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/ 目录下创建新的信号生成器：
from market.models import TradingSignal, SignalSource
class MySignalGenerator:
def __call__(self, symbol: str, current_price: float) -> List[TradingSignal]:
# 实现信号生成逻辑
signals = []
# ...
return signals
注册到 SignalService：
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