3. 高并发风控数据模型设计

在高并发风控评分场景中，数据模型的设计直接决定了评分查询的吞吐量和延迟。本节围绕五张核心表——用户表、订单表、行为日志表、黑名单表、评分结果表，详细阐述其设计原则、分区键选择与索引策略，确保模型在千万级数据量下仍能保持毫秒级响应。

3.1 五张核心表的设计原则

3.2 分区键选择策略

分区键的选择需兼顾 数据倾斜 与 查询裁剪。以下是各表的分区键推荐方案：

• 用户表： 按 user_id % 64 做 Hash 分区，避免热点用户集中在同一分区。
• 订单表： 按 create_time 做 Range 分区（按月），配合 user_id 作为二级分区键（子分区），实现时间范围裁剪 + 用户级数据局部性。
• 行为日志表： 按 event_time 做 Range 分区（按天），保留最近 30 天数据，过期分区直接 TRUNCATE 或 DROP。
• 黑名单表： 按 entity_type 做 List 分区（如 'IP', 'PHONE', 'IDCARD'），避免全表扫描。
• 评分结果表： 按 calc_time 做 Range 分区（按周），同时以 user_id 作为聚簇索引前缀，加速单用户历史评分查询。

-- 示例：订单表分区定义（MySQL）
CREATE TABLE orders (
    order_id BIGINT NOT NULL,
    user_id INT NOT NULL,
    amount DECIMAL(12,2),
    status TINYINT,
    create_time DATETIME NOT NULL,
    PRIMARY KEY (order_id, create_time),
    INDEX idx_user_time (user_id, create_time)
) ENGINE=InnoDB
PARTITION BY RANGE (TO_DAYS(create_time))
SUBPARTITION BY HASH (user_id)
SUBPARTITIONS 4 (
    PARTITION p202501 VALUES LESS THAN (TO_DAYS('2025-02-01')),
    PARTITION p202502 VALUES LESS THAN (TO_DAYS('2025-03-01')),
    PARTITION p202503 VALUES LESS THAN (TO_DAYS('2025-04-01')),
    PARTITION p_future VALUES LESS THAN MAXVALUE
);

3.3 索引策略与覆盖索引设计

索引设计遵循 最左前缀 与 覆盖索引 原则，避免回表查询。以下是各表的关键索引：

-- 示例：评分结果表覆盖索引
CREATE TABLE score_result (
    score_id BIGINT NOT NULL AUTO_INCREMENT,
    user_id INT NOT NULL,
    score DECIMAL(5,2) NOT NULL,
    version INT NOT NULL DEFAULT 1,
    calc_time DATETIME NOT NULL,
    extra_info JSON,
    PRIMARY KEY (score_id, calc_time),
    INDEX idx_user_score (user_id, calc_time, score)
) ENGINE=InnoDB
PARTITION BY RANGE (TO_DAYS(calc_time))
(
    PARTITION p2025w01 VALUES LESS THAN (TO_DAYS('2025-01-07')),
    PARTITION p2025w02 VALUES LESS THAN (TO_DAYS('2025-01-14')),
    PARTITION p_future VALUES LESS THAN MAXVALUE
);

3.4 数据模型架构总览

下图展示了五张表之间的关联关系、分区策略与索引路径，帮助理解数据在风控评分链路中的流转方式。

3.5 冷热数据分离与归档策略

高并发场景下，数据量持续增长，必须通过 冷热分离 控制活跃数据规模：

• 热数据（最近 7 天）： 行为日志表、订单表、评分结果表保留在 SSD 存储的高性能分区，索引全量在线。
• 温数据（7~30 天）： 迁移至 HDD 或成本较低的存储层，仅保留必要索引。
• 冷数据（超过 30 天）： 行为日志表直接 DROP PARTITION；订单表与评分结果表归档至历史库或列式存储（如 ClickHouse），仅保留汇总统计。

-- 示例：行为日志表按天分区，过期分区自动清理
ALTER TABLE behavior_log DROP PARTITION p_20250101;

-- 评分结果表归档至历史表
INSERT INTO score_result_history
SELECT * FROM score_result PARTITION (p_2025w01)
WHERE calc_time < DATE_SUB(NOW(), INTERVAL 30 DAY);

3.6 模型设计检查清单