智析股AI量化分析系统

基于 Spring AI + Flink + ClickHouse 的智能化股票量化投研平台
MCP微服务架构 · 实时计算引擎 · AI智能决策

核心特性

融合前沿AI技术与金融量化分析,打造智能投资决策引擎

🤖

AI智能决策

基于 Spring AI + Ollama 私有化大模型,实现自动化股票分析与交易决策, 支持多轮推理与工具调用

实时计算引擎

采用 Flink 1.20.3 流式计算框架,支持毫秒级行情处理、 K线聚合与技术指标实时计算

🔧

MCP微服务架构

创新MCP架构替代传统函数调用,实现工具微服务化、 Nacos自动发现、集群部署与动态扩容

💾

高性能数据存储

PostgreSQL + ClickHouse 双数据源架构, 亿级K线数据查询延迟 < 50ms

📊

量化策略引擎

内置持股线策略、1小时新低风控、突破策略等, 支持自定义策略扩展与回测

🔍

RAG知识检索

集成 Milvus 向量数据库,支持股票资讯、 研报文档的智能检索与语义分析

技术架构

企业级技术栈,保障系统高可用与可扩展性

Spring Boot
v3.5.13
现代化Java应用框架,提供完整的微服务基础设施
Spring AI
v1.1.4
AI应用开发框架,集成Ollama本地大模型与向量存储
Apache Flink
v1.20.3
分布式流处理引擎,支持实时行情计算与复杂事件处理
ClickHouse
v0.9.8
列式时序数据库,亿级数据秒级查询性能
MyBatis-Plus
v3.5.16
增强型ORM框架,简化数据访问层开发
Nacos
Service Discovery
服务注册与配置中心,实现MCP工具动态发现
Redis
Cache & Session
分布式缓存与会话管理,提升系统响应速度
Milvus
Vector Database
云原生向量数据库,支持RAG语义检索
Kafka
Message Queue
高吞吐消息队列,实现行情数据实时分发
LiteFlow
v2.15.3
轻量级规则引擎,支持策略流程编排
TA4J
v0.22.6
技术分析库,提供丰富的技术指标计算
Vue 3 + Element Plus
Frontend UI
现代化前端框架,构建响应式用户界面

功能模块

全方位覆盖股票分析与决策场景

1

AI智能选股

基于多维度数据分析(基本面、技术面、资金面、舆情面),AI自动筛选潜力股票, 生成结构化分析报告与投资建议。支持自定义选股条件与策略回测。

2

持股线策略

60分钟K线涨幅触发持股线更新机制,以上一个持股线为支撑位。跌破持股线自动发出卖出信号, 结合1小时新低风控机制,实现严格的止盈止损控制。

3

实时行情监控

Flink实时处理Tick数据,聚合生成1分钟/5分钟/60分钟K线, 计算MACD、KDJ、MA等技术指标,WebSocket推送实时行情变化。

4

MCP工具市场

微服务化工具集合:股票基础信息查询、价格趋势分析、技术指标计算、 基本面风险评估、资金流向监测等,支持动态扩展与热插拔。

5

RAG智能问答

基于Milvus向量数据库,支持股票研报、新闻资讯、公告文档的语义检索。 AI结合检索结果回答用户问题,提供有据可依的投资建议。

6

风险预警推送

实时监控持仓股票风险指标(跌破持股线、1小时新低、异常波动等), 通过微信/短信/邮件多渠道推送预警信息,及时规避投资风险。

开启智能投资新时代

让AI成为您的量化投资助手,数据驱动决策,科技创造价值

立即登录系统