企业官网建设流程全解析

• 音视频
• 直播
• 移动开发

本篇围绕 pure_live 仓库中 docs/HUYA_FLV_CORRELATION_2026_09_06.md 记录的审计方法展开：当虎牙 FLV 播放出现缓冲耗尽时，如何用"同一条上游会话"上的中继收包计时、只读 FLV 时间戳解析与 libmpv 原生缓冲事件三条时间线做关联，从而排除本地写入回压与源端 DTS 跳变，把停顿归因到 HTTP 媒体供给的到达间歇。读完本文，你可以掌握这套可复现的诊断基础设施的完整设计（loopback 中继、有界解析器、停止意图归因），以及它在 TX/AL 两条 CDN 真实样本上的判定过程与证据边界。

1. 基线、目的与观测边界

本轮审计的本地起点是提交d6d4123cd83ffaf14903d74a23bf800087adc8d4。上一轮的两处生产修复已推送；本轮明确不合并上游、不连接手机、不修改生产缓冲或线路默认值。目标是进一步定位此前已测到的缓冲耗尽现象，而不是以"更多延迟"或"自动重连"作为解释。

观测方法与边界是这份文档的核心方法论，逐条继承如下：

• tool/probes/flv_observation_relay.py：只绑定随机 loopback 端口，只接受一次/observe.flv请求；一条上游 HTTP 会话原样转发给同一个 libmpv 实例。
• 分开记录readWaitMs（等待上游read1）与writeWaitMs（向播放器写入），与 native 时间线共用同一个 monotonic 起点。
• 只读解析 FLV tag 边界、AVC/AAC 媒体 DTS、AVC 有符号 CTS；不把配置头当帧，不把正常 32 位回绕当倒退，不猜未知增强编码布局。检查PreviousTagSize，记录解析错误但不修改、不截断转发字节。
• 时间戳历史上限 700 条，跳变事件 64 条，IO 事件 128 条；chunk 为 64 KiB，FLV 单 tag 长度来自有界 24 位字段。无媒体文件、签名地址、账号或请求头日志。
• 上游请求和本地写入都有 15 秒超时；关闭 listener/thread，等已接管的 handler 退出；不停止其他项目的进程。将 native 主动 stop 前的停止意图传给 relay，区分测试收尾和运行中错误。
• 该方法改变了 TLS/HTTP 客户端和本地转发路径，因此不把它当成 direct-mpv 等效证明；但同一个样本内部的收包、时间戳和 native 缓冲来自同一条流，而不是两条独立连接拼接出的"因果关系"。

协议核对依据为 VSO Enhanced RTMP v2 文档中的 FLV/AVC CTS 定义，仅使用传统 AVC/AAC 分支（本文按仓库规范不输出外部链接，可自行检索 "VSO enhanced-rtmp-v2 FLV CTS"）。

2. 关联观测架构：三条时间线为什么必须来自同一条流

关联诊断的难点在于：如果分别用一条连接采样网络收包、用另一条连接跑播放器，两者的时间序列无法互相归因——同一条流的"卡顿"可能被拆成两个样本，产生虚假因果。仓库中的方案是让一个libmpv 实例去消费一个loopback 中继地址，中继背后再发起真实的上游虎牙 FLV 请求，从而让"字节何时到达"（readWaitMs）、"字节何时写入播放器"（writeWaitMs）与"播放器何时进入缓冲"（paused-for-cache）共享同一 monotonic 时钟起点。

2.1 loopback 单连接中继

tool/probes/flv_observation_relay.py 中的FlvObservationRelay是这套架构的核心，关键约束都有源码依据：

• 只接受一次接管：Handler 仅匹配路径/observe.flv，且owner.opens为 0 时才接管，第二次请求直接返回 409（L105-L110）。这保证样本内"上游连接数 == 1"这一前提可被断言。
• 双 15 秒超时：本地 socket 用self.connection.settimeout(15)，上游urllib.request.urlopen(request, timeout=15)（L106-L117），与生产播放器的network-timeout=15语义一致。
• 64 KiB 的 read1 分块：response.read1(65536)在每次循环中计时，read_ms与write_ms分别取最大值；只有read_ms >= 300或write_ms >= 300的样本才进入有界的events时间线（deque(maxlen=128)，L88、L123-L141）。
• 字节保真转发：chunk 先feed给只读解析器，再原样self.wfile.write(chunk)，解析错误不会导致截断或改写。
• 停止意图归因：close()先stop.set()再 shutdown，handler 结束时把end标记为probe_stop而非异常类型（L156-L164）。这条设计专门解决 TX 样本早期出现的误报：native 已主动 stop 后 relay 收尾记录到ConnectionResetError，而观测期EOF=0、handler 正常结束——显式停止意图避免了"把测试关闭读端冒充运行中上游断流"。

2.2 为什么它不是 direct-mpv 等效证明

中继替换了 mpv 的 HTTP/TLS 客户端（Pythonurllib替代 mpv 的 lavf 网络栈），因此它只能证明"同一个样本内部的收包/时间戳/缓冲三者同流"，不能证明"直连时一定也这样"。文档中这条边界被明确写入，也是后续结论措辞保守的原因：TX 停顿"指向 HTTP 媒体供给到达间歇"，但"不仅凭这一端的 read1 时长断言哪一段网络/CDN 负责；调用调度、TLS 与网络接收仍属于其观测边界"。

3. FlvObserver：只读、有界、不猜测的 FLV 解析器

tool/probes/flv_observation_relay.py 中的FlvObserver（L13-L81）是"只读解析"的落实，其每个防御性设计都能在源码里对上号：

FLV 头校验（有界失败）

if self.pending[:3] != b'FLV': raise ValueError('signature') offset = int.from_bytes(self.pending[5:9], 'big') if not 9 <= offset <= 4096: raise ValueError('header_length') if self.pending[offset:offset + 4] != b'\0\0\0\0': raise ValueError('initial_previous_size')

头长度被限制在[9, 4096]区间内等待，避免无限挂起；初始PreviousTagSize必须为 0。解析错误只记录固定标签（signature、header_length、previous_tag_size），绝不记录载荷内容（L74-L75 注释：Fixed parser labels only, never payload），这保证了诊断日志中不会出现签名 URL 或媒体内容。

tag 边界与 PreviousTagSize 校验

data_size = int.from_bytes(self.pending[1:4], 'big') # 有界 24 位长度字段 total = 11 + data_size + 4 if int.from_bytes(self.pending[total - 4:total], 'big') != total - 4: raise ValueError('previous_tag_size')

data_size来自 24 位大端字段，total天然有界；随后校验 tag 尾部的PreviousTagSize是否等于total - 4，任何一字节损坏都会在 tag 边界处暴露。

只解释传统 AVC/AAC 媒体包

is_audio = kind == 8 and len(payload) >= 2 and payload[0] >> 4 == 10 and payload[1] == 1 is_video = (kind == 9 and len(payload) >= 5 and not payload[0] & 128 and payload[0] & 15 == 7 and payload[1] == 1)

• 音频：tag type 8，payload 前 2 字节为 AAC raw（format=10，objectType=1）；
• 视频：tag type 9，frame_type非增强位（not payload[0] & 128）、codec_id == 7（AVC NALU）、AVCPacketType == 1（数据帧）。

配置头（AVCPacketType == 0）、元数据和未知/增强编码布局一律跳过，不进时间线——对应文档中"不把配置头当帧""不猜未知增强编码布局"。测试文件中的test_extended_codec_payload_is_not_misread_as_legacy_avc（test_flv_observation_relay.py L57-L61）用0x97开头（frame_type位被置起）的载荷验证了增强编码不会被误读为传统 AVC。

32 位回绕与跳变判定

delta = None if previous is None else ((dts - previous['dts'] + 2**31) % 2**32) - 2**31

DTS 差值按有符号 32 位环绕处理（L63），正常的毫秒计数回绕不会触发倒退告警；只有delta < 0 or delta > 500才记入discontinuities（有界 64 条）。CTS 用int.from_bytes(payload[2:5], 'big', signed=True)解析为有符号 24 位，pts = dts + cts（L64）——测试test_every_split_preserves_tag_boundaries_and_signed_cts中0xff_ff_f6的 CTS 对应 pts=990，验证了负 CTS（B 帧）解析。

有界采样：samples按整秒各采一条（上限 700），内容是该秒末最后一条媒体标签的dts/pts/receivedSeconds，构成"接收时刻—媒体时钟"的对照序列，与 native 侧的cache_pause时间线对齐。

4. 原生侧：headless libmpv 时间线探针

tool/probes/libmpv_continuity_probe.py 是无头 libmpv 的解码/时钟探针，与 relay 共同构成关联观测的另一半：

• 选项对齐生产：config=no、vo=null、ao=null、hwdec=no、network-timeout=15，再叠加 Dart 侧通过 stdin 传入的bufferProperties（来自生产缓冲策略表，L139-L145）。
• 请求头回读校验：通过mpv_set_property写入http-header-fields后立即读回比对（L153-L171）。注释点明了动机：虎牙 HYSDK User-Agent 中包含逗号（HYSDK(Windows,30000002)_APP(pc_exe&7100004&official)_SDK(trans&2.40.0.6448)，见 lib/shared/platforms/huya/huya_site.dart L158-L164），若按字符串拼接字段会被静默拆成两个 header，因此必须走 media_kit 风格的 typed-node API 并做 round-trip 断言。
• 缓冲事件捕获：轮询循环（mpv_wait_event，0.20 s）中读取paused-for-cache，状态翻转时mark一条cache_pause_start/end事件并附demuxer-cache-state（fw-bytes、total-bytes、cache-duration、underrun等，L126-L136）；同时统计maxPollIntervalMs、frame-drop-count/decoder-frame-drop-count变化（L202-L242）。时间线最多 64 条、无 URL/身份信息。
• 观察模式切换：observeFlvTransport为真时，把loadfile的目标从媒体 URL 换成relay.url（L179-L182）；收尾时先relay.stop.set()再发stop命令，最后relay.close()并采集flvTransport摘要（L267-L283）——这就是文档中"将 native 主动 stop 前的停止意图传给 relay"的实现落点。

生产播放器的缓冲参数表在 lib/core/player/kernel/media_kit_live_properties.dart：cacheSeconds = 30、cachePauseWaitSeconds = 4、正向缓存 96 MiB（低配机 40 MiB）、回读 8 MiB（低配 5 MiB）、readahead 8 s（L21-L27、L58-L68）。注意两点与本文结论相关：

1. cache-secs是缓存上限而非开播最小余量，把上限当作"已有 N 秒抗抖缓存"是错误结论——这正是关联审计要在实证层面澄清的；
2. sourceProperties中明确远端渐进式流（FLV 等）按直播对待：直播数据没有"缓存目标凑齐"的时刻，cache-pause那套点播假设不适用（L216-L219）。

5. Dart 侧入口：opt-in 实网探针与断言

tool/probes/huya_native_transport_probe_test.dart 是关联观测的生产入口（skip于PURELIVE_HUYA_LIVE_PROBE != '1'）：

• 环境变量：PURELIVE_HUYA_ROOM（默认 660000）、PURELIVE_HUYA_SECONDS（130–600 s 钳制）、PURELIVE_HUYA_BITRATE、PURELIVE_HUYA_CDN（选择sCdnType对应线路）、PURELIVE_HUYA_INITIAL_BUFFER_SECONDS、PURELIVE_HUYA_EMPTY_WEB_TOKEN（故障注入：把网页令牌置空，证明原生 WUP 凭据独立于网页 token）、PURELIVE_HUYA_OBSERVE_FLV（开启同会话 relay，L17-L24、L78）。
• 关联模式下的断言（L101-L108）：transport['opens'] == 1、bytes > 0、tags > 0、parseError为 null、handlerFinished为真——与本文第 2 节的"单连接、字节保真"前提逐一对应。
• 探针还断言headerRoundTripVerified、endEvents == 0、pauseSamples == 0、clockAdvancedSeconds > duration - 15（L95-L98），并在注释中明确"这是传输证据，不是渲染帧率或纹理/音频验收"。

6. 确定性验证：7/7 Python 回归

命令（继承原文档）：

python -W error::ResourceWarning -m unittest discover -s tool/probes -p test_flv_observation_relay.py -v

结果 7/7，1.058 秒。七个用例覆盖每一种关键路径，均在 tool/probes/test_flv_observation_relay.py 中可查：

其中"UA 逗号保留"直接对应第 4 节的 typed-node 请求头契约；文档还提到早期夹具未关闭预期的HTTPError触发过 ResourceWarning，已补显式close()（见 test 文件 L92-L94 的caught.exception.close()），最终在-W error::ResourceWarning下无告警。

本轮只有诊断代码，不重复上一轮 1101 项生产回归或全量 analyze；Dart 探针编译、Python 用例和实网测试分别记账。

7. 实网结果：TX 样本与 AL 对照

7.1 TX 样本（记录20260905T192116524Z-quality-focused.json，原始脱敏数据local-artifacts/huya-correlated-tx.log）

条件：房间 660000、TX、请求码率 10000、网页令牌故意为空（PURELIVE_HUYA_EMPTY_WEB_TOKEN=1）、原生 WUP。单连接 330.125 秒主动结束，读取 101,985,117 B、34,005 tags，解析错误 0、EOF 0。

关联结论：

• native 在44.142–46.209 秒缓冲暂停；暂停开始时前向字节 0、cache-duration0、underrun=true。
• 同一输入在43.324–45.650 秒附近等待read1达 2326 ms；该次向 native 写入等待 0 ms，全样本最长写入等待仅 3 ms。
• 视频最大相邻 DTS 差 33 ms、音频 78 ms，无超过 500 ms 的 DTS 跳变或倒退；native 最大轮询间隔 415 ms，不足以解释约两秒的时钟停顿。
• 因此该次停顿的直接证据指向HTTP 媒体供给到达间歇，不是本地转发写入回压，也不是源 DTS 跳变。
• 呈现丢帧计数 2、解码丢帧 0；无 Flutter 纹理、硬解或真实音频设备，不作为全部观看体验通过。
• 早期 relay 收尾记录的ConnectionResetError归因为 native 主动 stop（观测期 EOF=0、handler 已结束），之后增加的显式停止意图归因避免了误判上游断流。

7.2 AL 对照（记录20260905T192822939Z-quality-focused.json，原始脱敏数据local-artifacts/huya-correlated-al.log）

相同房间、请求码率、原生凭据和默认缓存，串行切换 AL 观测 330.083 秒：

• 1 次上游连接，128,788,131 B、33,993 tags，EOF=0、解析错误=0、正常主动停止、handler 结束。
• 103.185–103.590 秒发生约 405 ms 缓冲暂停；同一输入 101.899–103.342 秒等待read11443 ms，最大 native 写入等待仅 2 ms。
• 视频最大 DTS 差 18 ms、音频 34 ms，无异常跳变；最大轮询间隔/时钟进度间隔均 426 ms。两次cachePauseSamples是同一个暂停区间内的采样，不是两次卡顿。
• AL 样本的短暂停顿比 TX 少，但 AL 仍未达到零停顿。网络条件随时刻变化，两个顺序样本不支持永久硬编码某个 CDN，更不支持宣称"用户网络或整个虎牙服务器有统一故障"。
• 另一次只读网页元数据检查发现，样本中 PC/Web/Mobile 的 PriorityRate 数值一致；没有证据支持"改用 PC 优先级字段"作为本轮修复。只输出 CDN/优先级，未保存房间签名材料。
• 两次探针结束后的活跃重型进程归零由各自记录核对；AL 阶段资源峰值为验证工具工作集 14,178,594,816 B、CPU 48.34%，不充当客户端占用。

两条样本的排除项汇总：DTS 跳变（无）、本地写入回压（2–3 ms）、自动换播放器（单连接、无 end event）均被排除，停顿与收包间歇在时间上严格对齐。

8. 下一步与发布门禁

继承原文档的三条门禁，它们同时定义了这套证据的使用限度：

1. 本次定位到同会话媒体供给到达间歇，并排除了对应样本的 DTS 跳变、本地写入回压和自动换播放器。后续继续评估有界的抗抖与 CDN 健康策略，并把额外延迟作为明确代价；不以线程数、关闭缓冲 UI、固定周期换源来处理此证据。
2. 任何缓冲/线路默认值修改需要故障输入回放、当前原生链路对照与首播等待度量。上一轮六秒预缓冲方案已失败（见 docs/HUYA_REAUDIT_2026_09_06.md 第三样本），不因为这轮定位更清楚就重新默认启用它。
3. 当前新增的是可重复定位基础设施与实证，不是宣告客户端彻底修复。3.2.0 发布门禁保持未完成；此次不构建或发布 APK，不修改生产版本号。

9. 延伸阅读与源码索引

• 方法论前篇（三类故障划分、缓冲期限 guard 修复）：docs/HUYA_BUFFERING_DEADLINE_2026_09_06.md
• 前序二次审计（三个真实 TX 样本、六秒预缓冲候选与否决）：docs/HUYA_REAUDIT_2026_09_06.md
• 虎牙播放会话与短会话租约设计背景：docs/HUYA_PLAYBACK_SESSION.md
• 合成抖动回放对照工具（与本 relay 同族，用于"相同故障输入"门禁）：tool/probes/live_jitter_fixture_probe.py
• 中继与解析器实现/测试：tool/probes/flv_observation_relay.py、tool/probes/test_flv_observation_relay.py
• 原生探针与 Dart 入口：tool/probes/libmpv_continuity_probe.py、tool/probes/huya_native_transport_probe_test.dart
• 生产缓冲属性表：lib/core/player/kernel/media_kit_live_properties.dart

使用前提与限制：上述实网探针均为 opt-in（需PURELIVE_HUYA_LIVE_PROBE=1及实网环境），最低观测窗口 130 秒；文档中引用的local-artifacts/原始日志为本地证据索引，未提交进仓库；headless libmpv 样本不覆盖 Flutter 纹理呈现、硬件解码与真实音频设备，不能替代全端观看体验验收。

• 音视频
• 直播
• 移动开发