系统架构总览

这一页回答什么

本页介绍 X For You 信息流的架构组成、组件连接方式以及单次推荐请求的完整阶段。本页是系统架构的总览入口，其他页面展开介绍各个子系统。

核心结论

1. 系统包含两条路径。请求路径在用户打开 For You 时实时运行，负责候选召回、水合、过滤、打分、选择与混排。标签路径持续在后台运行，内容理解模型与规则引擎持续评估帖子和账号并写入安全标签（README.md:99-185、:186-250）。
2. 两条路径在可见性过滤阶段汇合。请求路径选出候选帖子后，VFCandidateHydrator 向可见性过滤服务查询每条候选帖子。可见性过滤服务读取标签路径写入的安全标签，返回展示、添加提示、添加遮罩或丢弃四种动作之一（home-mixer/candidate_hydrators/vf_candidate_hydrator.rs:53-130）。
3. 排序与可见性逻辑解耦。排序阶段决定候选帖子的排列顺序。可见性过滤阶段决定候选帖子是否具备展示资格。两个阶段属于不同服务，使用不同输入，遵循不同规则（README.md:492-494）。
4. 请求路径采用两层嵌套流水线。外层 ForYouCandidatePipeline 混排候选帖子、广告与功能模块。内层 PhoenixCandidatePipeline 负责候选帖子的召回、过滤、打分与选择（home-mixer/candidate_pipeline/for_you_candidate_pipeline.rs:219-234、phoenix_candidate_pipeline.rs:237-556）。
5. 候选来自四类来源：Thunder（关注账号的近期帖）、Phoenix 召回、SimClusters 以及热门帖子列表（README.md:83）。内层流水线共装配 9 个候选源，其中 3 个在开源配置中默认关闭（详见 home-mixer 编排层）。
6. 系统采用单个排序模型搭配多个后处理组件。Phoenix 模型预测候选帖子在多种行为上的发生概率。VMRanker 将各行为概率加权计算为基础分，执行冷启动调整，随后调用 vm-ranker 服务完成重排（home-mixer/scorers/vm_ranker.rs:59-140）。
7. 代码库参数默认值由定时脚本同步自线上主值（README.md:432、home-mixer/params/param.rs:1）。本文档称之为“开源默认值”，线上实验组可能采用不同配置。

请求路径

flowchart TB
    REQ([For You 请求]) --> QB["QueryBuilder<br/>用户数据 + feature switches"]
    QB --> OQ["外层 Query 水合<br/>served history / 请求时间戳"]
    OQ --> OS
    subgraph OUTER["外层 ForYouCandidatePipeline"]
        OS["7 个源:ScoredPosts / 广告 / Who to Follow<br/>Prompt / PushToHome / Frame / 问卷"]
        BL["BlenderSelector<br/>帖子与广告混排,插入模块"]
        OS --> BL
    end
    OS -. "ScoredPostsSource 调用" .-> IQ
    subgraph INNER["内层 PhoenixCandidatePipeline"]
        IQ["21 个 Query 水合器<br/>互动序列 / 关注 / 屏蔽 / Bloom"] --> SRC["9 个候选源"]
        SRC --> HYD["15 个候选水合器"]
        HYD --> PRE["21 个预打分过滤器"]
        PRE --> SC["5 个打分器<br/>Phoenix / 沉浸视频 / VMRanker / 页级重排 ×2"]
        SC --> TOP["TopKScoreSelector 取 50"]
        TOP --> PH["10 个选后水合器<br/>含可见性查询"]
        PH --> PF["5 个选后过滤器<br/>VF / 附属 VF / 会话去重"]
    end
    SRC -. 站内 .-> TH[(Thunder)]
    SRC -. 站外 .-> PR["Phoenix 召回 / SimClusters / 热门帖子"]
    SC -. 打分 .-> PX[Phoenix 排序]
    SC -. 重排 .-> VM[vm-ranker]
    PH -. 查询 .-> VF[visibility-filtering]
    PF --> BL
    BL --> SE["side effect<br/>写 served history / 缓存 / 日志"]
    BL --> RESP([For You 信息流,至多 48 项])

各阶段组件数量以 Commit 2e2295b 的装配配置为准（phoenix_candidate_pipeline.rs:285-543、for_you_candidate_pipeline.rs:210-263）。历史版本曾装配 15 个 Query 水合器、6 个候选源、10 个候选水合器、14 个预打分过滤器、3 个打分器、6 个选后水合器与 3 个选后过滤器。

标签路径

flowchart TB
    subgraph CU["1 内容理解 · 持续运行,不在请求路径上"]
        GX["grox<br/>文本与媒体分类器"]
        MM["media-model-proxy<br/>图像与视频模型"]
        CL["clip<br/>图文嵌入"]
        AG["agatha<br/>屏蔽与举报相对点赞的比例"]
        BD["bdsm<br/>不真实行为"]
        UC["user-cred-v2<br/>关注与互动图上的 PageRank"]
    end
    subgraph LR["2 打标签规则"]
        SCW["scarecrow + botmaker<br/>事件触发的规则"]
        AES["abuse-enforcement-service<br/>按账号分数打标签、验证或封禁"]
        AGG["safety-label-user-agg<br/>按帖子标签给账号打标签"]
    end
    CU --> LR
    LR --> ST[("3 标签存储")]
    ST --> VFS["4 visibility-filtering<br/>ALLOW / NOTICE / INTERSTITIAL / DROP"]
    VFS --> PSF["5 选后过滤<br/>VFFilter / AncillaryVFFilter"]
    PSF --> FEED([For You 信息流])

1. 内容理解：帖子维度由 grox、media-model-proxy 与 clip 生成分类概率与嵌入向量；账号维度由 agatha、bdsm 与 user-cred-v2 计算账号信用分（README.md:189-200）。
2. 打标签规则：scarecrow 运行内嵌的 botmaker 规则引擎，在事件触发时执行条件规则并打上对应标签；abuse-enforcement-service 读取账号信用分，决定执行打标签、发起人机验证或封禁账号，申诉推翻的处置在冷却期内不再重复执行；safety-label-user-agg 根据账号下帖子累积的安全标签为账号本身打标签（README.md:202-214）。
3. 存储写入：系统将生成的标签持久化写入存储服务，供请求路径实时读取。
4. 可见性过滤：可见性过滤服务针对“用户-帖子”对返回展示裁定。规则除读取安全标签外，还会校验用户关系（屏蔽、静音、关注状态）、账号状态（受保护、封禁、停用）、订阅状态、用户偏好设置与访问国家。部分安全规则仅对站外推荐生效（README.md:220-237）。
5. 选后过滤：home-mixer 剔除被判定为 DROP 的帖子；若帖子的祖先帖子、引用帖或转发原帖被判定为 DROP，系统同样剔除该帖子。被判定为添加提示（NOTICE）或添加遮罩（INTERSTITIAL）的帖子继续保留在信息流中，客户端负责具体渲染（README.md:239-250）。

标签路径还在两处逻辑中接入请求路径：在选后水合阶段，AdsBrandSafetyVfHydrator 读取安全标签以计算品牌安全裁定（详见 广告混排）；在召回索引构建阶段，phoenix-rankall-strato 在帖子写入召回索引前预先查询可见性过滤服务（README.md:290）。

组件一览

编排与框架

候选来源

召回索引

排序

内容理解

可见性过滤与标签

语言列按目录内源文件扩展名统计，phoenix/ 的 Rust 部分属于推理服务层（README.md:300）。

流水线十阶段

无论内层还是外层流水线，执行顺序均由流水线框架中的 execute_stages() 统一编排（candidate-pipeline/candidate_pipeline.rs:126-179）：

框架并发执行无依赖任务以降低请求耗时；过滤与打分阶段依赖前置计算结果，因此采用顺序执行。详见 candidate-pipeline 框架。

外部依赖

内层流水线在 prod() 方法中并发初始化数十个客户端连接（phoenix_candidate_pipeline.rs:558-995）：社交图服务、帖子实体服务、Gizmoduck 用户服务、可见性过滤服务、Strato、Redis、Kafka、用户行为聚合服务、互动计数服务、SimClusters ANN、SID 召回服务及 vm-ranker 服务。mock() 方法使用替身对象装配结构相同的测试流水线（phoenix_candidate_pipeline.rs:996-1110）。上述服务均为 X 内部基础设施，整套在线推荐服务无法脱离内部网络独立运行。Phoenix 属于例外情况：它附带训练代码、推理代码与合成数据生成器，支持端到端运行小模型示例（README.md:460），详见 run_pipeline。

设计决策

常见问题

Q：外层流水线为什么没有打分器？
A：外层流水线的候选帖子由 ScoredPostsSource 提供，该数据源内部已执行完整的 PhoenixCandidatePipeline 排序流程。外层流水线仅负责将打分完毕的候选帖子与广告、推荐模块组装混排（for_you_candidate_pipeline.rs:336-354）。

Q：单条候选帖子的最终排序分如何计算？
A：Phoenix 模型预测用户产生各类互动行为的概率，打分器将各行为概率加权求和得出基础分。权重放大的是“当前请求用户发生该行为的预测概率”，而非帖子历史上已累积的互动计数（README.md:370）。详见 打分与排序。

Q：被打上安全标签的帖子是否一定会被删除？
A：不一定。可见性过滤服务依据规则将标签映射为四种动作之一，仅当裁定为 DROP 时才丢弃帖子。部分规则仅对站外推荐生效，同一条帖子仍可展示给作者的关注者（README.md:220-237）。详见 可见性过滤。

源码锚点

• README.md:99-250 —— 请求路径与标签路径
• candidate-pipeline/candidate_pipeline.rs:126-179 —— 十阶段编排
• home-mixer/candidate_pipeline/for_you_candidate_pipeline.rs:189-273 —— 外层流水线
• home-mixer/candidate_pipeline/phoenix_candidate_pipeline.rs:237-556 —— 内层流水线
• home-mixer/candidate_hydrators/vf_candidate_hydrator.rs:53-130 —— 两条路径的汇合点
• home-mixer/scorers/vm_ranker.rs:59-140 —— 加权、冷启动与重排

相关页面

• For You 是怎么工作的 —— 本页的白话版
• 五大组件 —— 组件的白话介绍
• 端到端数据流 —— 一条帖子从发布到被推荐
• home-mixer 编排层 —— 服务、流水线与候选源
• candidate-pipeline 框架 —— 十阶段框架
• 过滤流水线 —— 两道过滤
• 打分与排序 —— 打分器链
• 候选选择与成型 —— 选择与成型
• 广告混排 —— 外层广告混排
• 可见性过滤 —— 标签路径的终点
• 标签规则 —— 标签路径的规则层
• 开源版与线上版的差异 —— 哪些东西不在仓库里