WebSocket(实时推送)
gRPC(微服务通信)
ZeroMQ(极速RPC)
Redis Cluster(低延迟缓存)
Apache Kafka(高吞吐消息队列)
Redis
⚡ 高速消息总线
gRPC
回测层
• 历史K线• 复权数据• 基础信息
历史数据中心
ZeroMQ
反馈流
Kafka
数据流
• 多因子合成• 信号过滤• 仓位建议• 执行时机
信号生成器
• 均值方差优化• 风险平价• Black-Litterman• 约束条件
组合优化
• LSTM/Transformer• XGBoost/LightGBM• 深度强化学习• 集成学习
机器学习预测
• 量价因子• 动量因子• 情感因子• 另类因子
因子挖掘引擎
策略层
ZeroMQ(低延迟)
• FIX协议• 券商接口• 撮合引擎
交易执行网关
• 资金限额• 持仓限制• 异常检测
实时风控系统
• TWAP/VWAP• 冰山订单• POV/IS
交易所
算法交易引擎
参数调优
• 交易所选择• 最优执行• 冲击成本最小
智能订单路由
策略验证
交易层
REST API
智能投顾量化交易策略系统架构图
数据层
行情数据中心
• 实时Tick数据• K线数据• Level-2深度
舆情数据中心
• 新闻舆情• 社交媒体• 财报公告
宏观数据中心
• GDP/CPI• 利率汇率• 行业指数
FIX/CTP
参数优化
绩效分析
策略评估引擎
历史数据回放
消息总线
回测层 (离线)
图例
