分布式风控系统一致性保障实战
📚 共计 30 章节
01
分布式风控概述
为什么需要分布式风控、核心挑战（一致性、延迟、可用性）、CAP理论在风控中的体现。
CAP
核心挑战
02
一致性基础
强一致性、弱一致性、最终一致性、因果一致性，以及风控场景下的选择。
最终一致性
因果
03
分布式事务（上）
XA协议、2PC（两阶段提交）的原理、在风控扣款场景中的实践与痛点。
2PC
XA
04
分布式事务（下）
TCC（Try-Confirm-Cancel）模式、Saga模式、本地消息表，风控中的选型对比。
TCC
Saga
05
共识算法入门
Paxos算法核心思想、Raft算法（Leader选举、日志复制），为什么风控系统很少直接用。
Raft
Paxos
06
分布式锁
基于Redis的Redlock、基于ZooKeeper的锁、数据库乐观锁，在风控规则引擎中的防重入。
Redlock
ZK
07
幂等性设计
接口幂等性原理、唯一键约束、状态机幂等，风控订单处理的防重复扣款。
幂等
状态机
08
版本控制与乐观锁
MVCC思想、CAS操作、版本号机制，在风控配置中心的热更新中的应用。
MVCC
CAS
09
分布式ID生成
雪花算法、Leaf方案、美团Leaf，风控事件ID的全局唯一性保障。
雪花
Leaf
10
消息队列与异步一致性
Kafka/RocketMQ的事务消息、半消息机制，风控事件流的可靠投递。
事务消息
半消息
11
事件溯源（Event Sourcing）
事件存储、事件回放，在风控审计与反欺诈中的实践。
Event Sourcing
审计
12
CQRS模式
命令查询职责分离，读写分离在风控实时计算与离线分析中的应用。
CQRS
读写分离
13
分布式缓存一致性
Redis缓存与数据库的双写一致性、Cache Aside模式、延迟双删，风控黑白名单的更新。
Cache Aside
延迟双删
14
配置中心一致性
Apollo/Nacos的配置一致性保障，长轮询与Watch机制，风控规则的热加载。
Apollo
Nacos
15
服务注册与发现一致性
Eureka的自我保护、Consul的Raft共识，风控微服务的高可用注册。
Eureka
Consul
16
分布式调度一致性
Elastic-Job的分片一致性、Quartz的集群锁，风控定时任务的防重复执行。
Elastic-Job
Quartz
17
数据复制与同步
主从复制、多主复制、Quorum机制，风控数据库的读写分离与数据一致性。
主从复制
Quorum
18
分布式快照与检查点
Chandy-Lamport算法、Flink的Checkpoint，风控流处理的状态一致性。
Checkpoint
Chandy-Lamport
19
分布式追踪与一致性校验
OpenTelemetry、TraceId传递，风控调用链的完整性验证。
OpenTelemetry
TraceId
20
一致性哈希
虚拟节点、数据倾斜处理，风控规则引擎的分片路由。
虚拟节点
分片
21
分布式计数与限流
Redis原子计数、令牌桶的分布式实现，风控接口的全局限流一致性。
令牌桶
原子计数
22
分布式决策树与规则同步
规则引擎的版本一致性、增量同步，风控模型的灰度发布。
灰度发布
增量同步
23
跨机房/异地多活一致性
两地三中心、单元化架构，风控系统在异地部署下的数据同步。
两地三中心
单元化
24
一致性测试与混沌工程
Jepsen测试、Chaos Monkey，风控系统的一致性验证方法论。
Jepsen
Chaos Monkey
25
监控与告警
一致性指标（延迟、冲突率）、Prometheus+Grafana，风控一致性SLA的保障。
Prometheus
Grafana
26
案例实战（一）
支付风控的扣款一致性——从2PC到Saga的演进。
2PC
Saga
27
案例实战（二）
反欺诈规则引擎的配置一致性——基于Raft的配置同步。
Raft
配置同步
28
案例实战（三）
实时风控事件流的Exactly-Once语义——基于Kafka事务与Flink Checkpoint。
Exactly-Once
Flink
29
案例实战（四）
风控黑白名单的最终一致性——基于本地消息表+MQ。
本地消息表
MQ
30
总结与展望
分布式风控一致性的未来趋势（NewSQL、Serverless、AI辅助一致性决策）。
NewSQL
Serverless