01
风控概述
金融风控的演进 · 高频交易中的风险类型 · 实时风控的必要性
基础认知
02
数据流基础
数据流的概念 · 批处理与流处理的对比 · 事件驱动架构
流式架构
03
消息队列选型
Kafka核心概念 · RabbitMQ对比 · Pulsar特性 · 选型决策矩阵
MQ对比
04
Kafka深度实践
分区机制 · 副本机制 · 生产者与消费者API · Exactly-Once语义
Kafka核心
05
流处理引擎
Flink核心概念 · Spark Streaming对比 · Storm的适用场景
引擎选型
06
Flink实战
DataStream API · 时间语义 · Watermark机制 · 状态后端
Flink实战
07
CEP复杂事件处理
Flink CEP原理 · 模式匹配 · 超时检测 · 实战案例
CEP检测
08
规则引擎
Drools集成 · 规则热更新 · 规则冲突检测 · 性能优化
规则Drools
09
特征工程
实时特征计算 · 滑动窗口特征 · 特征存储（Redis）· 特征回溯
特征Redis
10
模型部署
ONNX模型转换 · Triton推理服务器 · 模型版本管理 · A/B测试
ML推理
11
风控指标体系
交易量监控 · 异常率统计 · 响应延迟P99 · 规则命中率
指标监控
12
实时数仓
Kappa架构 · Lambda架构 · 实时OLAP（ClickHouse）· 数据湖集成
数仓OLAP
13
数据一致性
Exactly-Once保证 · 幂等性设计 · 分布式事务 · 补偿机制
一致性事务
14
延迟优化
反压机制 · 算子链优化 · 异步IO · 资源动态扩缩容
性能调优
15
容错与高可用
Checkpoint机制 · Savepoint机制 · 主备切换 · 多活架构
HA容错
16
安全与合规
数据脱敏 · 加密传输 · 审计日志 · GDPR合规
安全合规
17
监控告警
Prometheus集成 · Grafana看板 · 自定义告警规则 · 链路追踪
监控告警
18
测试策略
单元测试 · 集成测试 · 混沌工程 · 压测方案
测试混沌
19
CI/CD流水线
GitOps实践 · 自动化部署 · 灰度发布 · 回滚策略
DevOpsCI/CD
20
性能调优
JVM调优 · 网络优化 · 序列化选择 · 内存管理
JVM调优
21
实战案例一：支付风控
实时拦截 · 黑白名单 · 额度控制
支付风控
22
实战案例二：信贷风控
反欺诈 · 多头借贷 · 设备指纹
信贷反欺诈
23
实战案例三：交易反洗钱
可疑交易检测 · 团伙识别 · 关联图谱
反洗钱图谱
24
实战案例四：营销风控
薅羊毛识别 · 红包风控 · 邀请奖励防刷
营销防刷
25
实战案例五：内容风控
文本审核 · 图片审核 · 视频审核流水线
内容审核
26
架构演进
单体架构到微服务 · 事件溯源 · CQRS模式 · Serverless风控
架构演进
27
成本控制
资源估算 · Spot实例使用 · 冷热数据分离 · 压缩策略
成本优化
28
团队协作
风控与业务部门协作 · SLA制定 · 故障复盘 · 知识库建设
协作SLA
29
前沿趋势
联邦学习在风控中的应用 · 图神经网络 · 实时决策引擎 · 隐私计算
前沿AI
30
总结与展望
高频风控的未来 · AI驱动的风控 · 全链路智能化 · 职业发展建议
展望职业