01
课程导学与量化交易概述
量化交易概念 · Flink在量化中的角色 · 课程目标与学习路径
导学量化基础
02
Flink核心概念与环境搭建
Flink架构 · 数据流与批处理 · 本地与集群环境搭建
环境架构
03
Flink DataStream API基础
Source · Transformation · Sink · WordCount实战
API实战
04
Flink时间语义与Watermark
EventTime · ProcessingTime · IngestionTime · Watermark机制与乱序处理
时间语义乱序
05
Flink窗口计算
滚动窗口 · 滑动窗口 · 会话窗口 · 窗口函数与触发器
窗口触发器
06
Flink状态管理与容灾
Keyed State · Operator State · Checkpoint · Savepoint
状态容错
07
Flink Table & SQL
Table API基础 · 动态表 · 流式SQL查询实战
SQLTable API
08
Flink CEP（复杂事件处理）
Pattern API · 事件序列匹配 · 超时与阈值处理
CEP事件
09
量化交易数据源接入
行情数据(Tick/Bar)模拟生成 · Kafka数据源集成
数据源Kafka
10
实时行情数据处理
数据清洗 · 格式标准化 · 延迟与乱序处理策略
清洗标准化
11
技术指标计算（上）
SMA · EMA · MACD的Flink实现
指标SMA/EMA/MACD
12
技术指标计算（下）
RSI · 布林带 · KDJ的Flink实现
RSI布林带KDJ
13
交易信号生成引擎
基于指标组合的信号逻辑 · 信号强度评分
信号评分
14
策略回测框架搭建
回测数据源 · 模拟撮合 · 资金曲线计算
回测撮合
15
Flink与Kafka深度集成
Exactly-Once语义 · 分区分配 · 背压处理
KafkaExactly-Once
16
Flink与Redis集成
实时数据缓存 · 指标结果存储 · 热数据查询
Redis缓存
17
Flink与MySQL/ClickHouse集成
结果持久化 · OLAP分析查询
MySQLClickHouse
18
风控模块设计
仓位限制 · 最大回撤监控 · 异常交易检测
风控回撤
19
订单管理模块
订单状态机 · 订单簿维护 · 撤单逻辑
订单状态机
20
实时资产与盈亏计算
持仓市值 · 浮动盈亏 · 保证金监控
资产盈亏
21
Flink作业性能优化
并行度调优 · 算子链 · 内存管理
性能调优
22
Flink作业监控与告警
Metrics系统 · 自定义Reporter · Prometheus+Grafana
监控Grafana
23
多策略组合管理
策略注册 · 权重分配 · 资金分配逻辑
多策略组合
24
模拟交易系统搭建
模拟交易所 · 撮合引擎 · 滑点模拟
模拟撮合
25
实盘接口对接（模拟）
REST/WebSocket行情与交易接口封装
接口WebSocket
26
全链路数据一致性保障
端到端Exactly-Once · 幂等性设计
一致性幂等
27
系统高可用与容灾
Flink HA配置 · Kafka MirrorMaker · 多活架构
高可用容灾
28
项目实战：完整量化流水线
从零搭建一个完整的Flink量化交易流水线
实战全流程
29
项目部署与运维
Docker/K8s部署 · 日志收集 · 滚动升级
部署K8s
30
课程总结与进阶方向
Flink 2.0新特性 · AI量化 · 高频交易展望
总结进阶