01
事件驱动架构基础
什么是事件驱动架构、优缺点、量化交易应用场景
架构概念
02
消息队列选型与对比
RabbitMQ / Kafka / Redis Streams / NATS 对比与选型
中间件选型
03
Kafka 核心概念
Topic / Partition / Consumer Group / Offset / Broker
Kafka原理
04
Kafka 环境搭建与配置
单机/集群部署、参数调优、监控运维
部署运维
05
生产者客户端开发
同步/异步发送、回调、分区策略、序列化
Java生产者
06
消费者客户端开发
订阅模式、提交偏移量、再均衡、幂等消费
消费者偏移量
07
事件数据模型设计
通用格式、元数据、版本兼容、Schema Registry
模型Avro
08
实时行情事件流接入
Level-1/2 行情解析、Tick 标准化、延迟优化
行情实时
09
订单事件流处理
订单状态机、成交回报、撤单、异常检测
订单风控
10
风控事件流设计
资金/持仓监控、频率限制、自成交预防
风控安全
11
事件流处理引擎 Flink
Flink 基础、DataStream API、事件时间
Flink流处理
12
Flink CEP 复杂事件处理
模式定义、时间窗口、匹配输出、实战
CEP模式
13
预警规则引擎
规则定义语言、编译执行、热加载、优先级
规则引擎
14
实时计算指标
滑动窗口、衰减平均、EMA、实时波动率
指标计算
15
预警分级与通知策略
P0/P1/P2 分级、短信/邮件/钉钉/企微、告警抑制
通知分级
16
预警存储与回溯
Elasticsearch 存储、Kibana 可视化、历史分析
ES存储
17
监控仪表盘设计
Grafana 数据源、实时面板、阈值可视化
Grafana可视化
18
系统健康监控
消费者 Lag、生产速率、集群状态、自愈
监控自愈
19
事件流测试策略
单元/集成/端到端测试、模拟数据、混沌工程
测试混沌
20
性能压测与优化
吞吐量/延迟测试、背压、资源/JVM 调优
压测调优
21
高可用与容错设计
多副本、故障转移、幂等性、Exactly-Once
高可用容错
22
事件流安全
认证授权、数据加密、审计日志、脱敏
安全加密
23
多数据源接入
多交易所行情、数据源路由、质量监控
数据源路由
24
事件流与数据库同步
CDC (Debezium)、双写一致性、最终一致性
CDC同步
25
实时特征工程
事件特征提取、特征存储 (Redis/Feature Store)
特征ML
26
机器学习模型在线推理
模型服务化 (Triton/MLflow)、特征拼接、回写
推理ML
27
事件流治理
Schema 管理、血缘追踪、数据质量、版本管理
治理元数据
28
实战项目一：股票实时监控预警
架构设计、代码实现、部署运维
实战股票
29
实战项目二：加密货币套利监控
多交易所价差监控、延迟优化、自动交易触发
实战加密货币
30
课程总结与展望
事件驱动未来、Serverless 事件流、AI 智能预警
总结趋势