《基于Spark Streaming与Lambda架构的实时金融反欺诈风控系统》。
这是一个什么样的系统?
简单来说,这是一个能够实时检测和拦截金融交易欺诈的智能风控平台。当一笔交易发生时,系统能在秒级内判断这笔交易是否存在欺诈风险,并自动决定是放行、标记还是拦截。
系统核心架构:
系统采用 Lambda架构,分为三个层次:
实时处理层:Spark Streaming从Kafka消费交易数据流,通过五维度规则引擎实时评分
批处理层:Spark Core对全量历史数据进行离线统计分析
服务层:Spring Boot提供API,Vue 3展示可视化大屏
五大核心功能:
一是风控概览大屏,以ECharts图表实时展示交易趋势、风险分布等关键指标;二是实时交易监控,每笔交易的风险评分和处置结果一览无余;三是风险告警管理,高风险交易自动生成告警,支持标记处理;四是风控规则管理,支持管理员动态启停规则;五是用户管理,实现基于角色的权限控制。
技术栈:
后端使用Java + Spring Boot,实时计算使用PySpark,消息队列使用Kafka,缓存使用Redis,持久化使用MySQL,前端使用Vue 3 + ECharts,覆盖了大数据实时处理的完整技术链路。