1. 课程导论：实时风控背景、规则引擎在风控中的价值、Flink为何适合做规则引擎、课程整体大纲与学习目标

1.1 实时风控背景：为什么我们需要毫秒级决策？

在数字化转型的浪潮中，金融交易、电商支付、账户登录等业务场景正面临日益复杂的欺诈攻击。传统的离线风控（T+1 或分钟级扫描）已无法应对以下挑战：

• 攻击速度升级：自动化脚本、撞库、秒级洗钱等攻击手段要求系统在 100ms 内完成决策。
• 数据量爆炸：头部支付平台日均处理数十亿笔事件，单日日志量可达 PB 级。
• 特征维度复杂：单一规则已失效，需要结合设备指纹、行为序列、社交图谱等多维特征。
• 监管合规压力：反洗钱（AML）、反欺诈（FR）等监管要求实时拦截与上报。

1.2 规则引擎在风控中的价值

规则引擎是风控系统的“大脑”，它将业务策略从代码中解耦，实现策略的灵活编排与热更新。其核心价值体现在：

1.3 Flink 为何适合做规则引擎？

Apache Flink 作为新一代流式计算引擎，天然具备构建实时规则引擎的基因。其核心优势如下：

• 真正的流处理：事件驱动架构，每条数据到达即触发计算，延迟低至亚毫秒级。
• 精确一次语义：结合 Checkpoint 机制，保证风控决策不重不漏。
• 复杂事件处理（CEP）：原生支持时间窗口、模式匹配、序列检测，适合“30 秒内连续失败 3 次”等规则。
• 状态管理：内置 Keyed State 和 Timer，支持用户画像、设备指纹等长周期状态维护。
• 高可用与弹性：支持 Savepoint 升级、动态扩缩容，保障 7x24 小时稳定运行。

1.4 课程整体大纲与学习目标

本课程共 30 章，从基础概念到企业级实战，系统化掌握 Flink 实时风控规则引擎的构建方法。

1.5 学习路径建议

• 初学者：按章节顺序学习，每章完成课后练习，重点掌握第 6-12 章的规则引擎核心。
• 有经验者：可直接从第 6 章开始，结合第 19-25 章的企业案例进行实战。
• 团队学习：建议每周 2-3 章，配合代码仓库进行小组 Code Review。