01
风控概述
什么是风控、风控的价值、实时风控与离线风控的区别、核心指标
准确率召回率响应时间
02
架构设计
整体架构、分层设计、核心模块拆解
接入层决策层数据层
03
技术选型
Flink计算引擎、Redis/HBase对比、消息队列选型
KafkaRocketMQFlink
04
环境搭建
JDK/Maven/Git、Flink集群、Redis与HBase安装
Standalone配置
05
数据接入层
数据源分类、Kafka Topic设计、数据格式标准化
JSONProtoBuf
06
数据清洗与预处理
脏数据过滤、字段补齐、时间戳对齐、脱敏、Flink DataStream ETL
ETL脱敏
07
特征工程
实时/离线特征、滑动窗口特征、特征存储Redis Hash
计数均值窗口
08
规则引擎设计
规则定义/解析、Rete算法、规则热加载
DSL热加载
09
规则引擎实现
Drools集成、自研轻量级引擎(Aviator/QLExpress)
DroolsAviator
10
名单引擎
黑白名单设计、Redis Set/ZSet、命中与过期策略
黑名单白名单
11
模型引擎
实时模型推理(PMML/ONNX)、TensorFlow Serving、特征对齐
PMMLONNX
12
决策流编排
DAG定义、节点类型、决策流执行引擎
DAG规则节点
13
上下文管理
请求上下文、ThreadLocal/Flink KeyedState、快照与回滚
KeyedState回滚
14
变量计算引擎
变量定义/注册、依赖解析、Groovy/Python脚本
Groovy脚本
15
聚合计算
Flink Window、计数/去重/比率、聚合结果存储回查
窗口去重
16
外部数据源对接
第三方API调用、缓存策略、超时与熔断
HTTP熔断
17
风控策略管理
版本管理、灰度发布、AB测试、生效周期
灰度AB测试
18
事件溯源与审计
Flink Sink采集、Elasticsearch存储、审计回放
Elasticsearch审计
19
实时计算优化
Checkpoint调优、RocksDB状态后端、算子链与并行度
RocksDB并行度
20
缓存策略
多级缓存、LRU/TTL、缓存穿透与雪崩防护
本地缓存分布式
21
降级与熔断
静默降级/快速失败、Hystrix/Resilience4j、降级开关
熔断器降级
22
监控与告警
QPS/延迟/命中率、Prometheus+Grafana、告警规则
PrometheusGrafana
23
压测与性能调优
JMeter/Locust、压测场景、瓶颈定位
JMeter调优
24
高可用部署
多机房、主备切换、最终一致性
多机房主备
25
安全与权限
API鉴权Token/JWT、数据加密AES/RSA、操作审计
JWTAES
26
测试体系
JUnit/Mockito、Testcontainers、回归与自动化
单元测试集成测试
27
CI/CD流水线
GitLab、Maven/Docker、Jenkins/K8s
DockerK8s
28
案例实战
电商刷单、金融欺诈、社交垃圾消息过滤
电商金融社交
29
项目复盘
踩坑记录、数据倾斜、状态膨胀、架构演进
复盘优化
30
未来展望
联邦学习、图计算、因果推断、新一代风控引擎
联邦学习图计算