3. 实时风控系统架构：整体架构概览、数据流管道、规则引擎、决策引擎、API网关层

实时交易风控系统是一个对延迟极度敏感、对准确性要求严苛的分布式系统。本章从架构全局出发，逐层剖析数据流管道、规则引擎、决策引擎与API网关层的核心职责与协作模式，为后续API设计与集成奠定架构基础。

3.1 整体架构概览：四层协同模型

实时风控系统采用分层解耦设计，自上而下分为接入层、计算层、决策层与存储层。各层职责清晰，通过异步消息与同步RPC混合通信，兼顾吞吐与低延迟。

3.2 数据流管道：实时事件处理中枢

数据流管道是风控系统的神经末梢，负责将异构、高并发的交易事件转化为结构化、可计算的决策上下文。典型管道包含以下阶段：

3.3 规则引擎：轻量级实时决策

规则引擎负责执行确定性逻辑，适用于已知风险模式的快速匹配。规则通常由风控分析师通过可视化界面配置，并实时下发至引擎。

规则引擎的核心能力包括：

• 规则编译与加载：将 DSL 规则编译为可执行对象树，支持热加载。
• 条件匹配：支持等于、范围、正则、集合、时间窗口等算子。
• 优先级与短路：高优先级规则命中后，可跳过后续规则，降低计算开销。
• 规则版本管理：每条规则携带版本号，支持灰度发布与回滚。

// 规则 DSL 示例（简化）
rule "高频交易检测"
  when
    $tx: Transaction(amount > 10000)
    $history: UserHistory(txCountIn1Min > 5)
  then
    riskScore += 30;
    action = "BLOCK";
end

3.4 决策引擎：模型驱动的智能评分

决策引擎是风控系统的大脑，负责运行机器学习模型、评分卡、复杂策略组合。与规则引擎的确定性不同，决策引擎输出概率或分数，并支持多模型集成。

3.5 API网关层：统一接入与安全防护

API网关是风控系统的前门，所有外部交易请求、内部服务调用均通过网关统一接入。网关层承担以下关键职责：

• 协议适配：支持 HTTP/REST、gRPC、WebSocket 等多种协议，统一转换为内部 Protobuf 格式。
• 认证鉴权：基于 OAuth2.0 / JWT 验证调用方身份，支持 API Key + 签名校验。
• 流量控制：按商户、接口、用户维度实施令牌桶限流与并发控制。
• 请求路由：根据交易类型（支付、转账、提现）将请求分发至对应规则集。
• 熔断降级：当下游服务异常时，快速返回降级决策（如放行或拒绝），避免雪崩。

3.6 架构协同：一次交易的风控全流程

为帮助理解各层协作，以下是一次典型交易请求的完整风控路径：

1. 客户端通过 REST API 发起交易请求，携带商户ID、用户Token、交易金额等信息。
2. API网关校验签名与Token有效性，执行限流检查，将请求路由至数据流管道。
3. 数据流管道清洗事件、提取用户实时特征（如近1分钟交易次数、设备指纹），聚合上下文后分发至规则引擎。
4. 规则引擎并行匹配高频交易、大额转账、异地登录等规则，输出初步风险标签与分数。
5. 决策引擎接收规则结果与特征向量，运行机器学习模型，输出最终风险评分与决策（通过/拒绝/人工审核）。
6. API网关将决策结果返回客户端，同时异步记录完整决策日志至存储层。