📚 课程目录第2章 LinkTest基础架构

LinkTest周期参数配置与网络波动容错测试 - 第2节

2.1 LinkTest 核心组件架构

LinkTest 的基础架构围绕三个核心组件构建：调度器（Scheduler）、探测器（Prober）和分析器（Analyzer）。三者形成“策略下发 → 数据采集 → 结果分析”的闭环，支撑周期参数配置与网络波动容错测试。

  架构设计原则：调度器负责“何时测”，探测器负责“怎么测”，分析器负责“测出什么”。组件间通过轻量级消息队列解耦，支持水平扩展。

2.1.1 调度器（Scheduler）

调度器是测试任务的“大脑”，负责解析用户配置的周期参数，生成测试计划并下发至探测器集群。核心职责包括：

周期解析：支持固定间隔（如每 30 秒）、Cron 表达式（如 */5 * * * *）和日历触发三种模式。
任务分发：根据探测器负载和网络拓扑，将测试任务均匀分配到可用探测器节点。
心跳维护：每 10 秒检测探测器存活状态，失效节点自动从任务池移除。
容错重试：当探测器返回超时或错误码时，调度器按指数退避策略（1s、2s、4s）最多重试 3 次。

调度模式	配置示例	适用场景
固定间隔	`interval: 30s`	持续监控、告警触发
Cron 表达式	`cron: "0 /5 * *"`	定时巡检、非高峰测试
日历触发	`calendar: "2025-03-15 02:00"`	变更窗口、版本发布验证

最佳实践：在波动容错测试中，建议使用固定间隔模式（如 10s），以捕获毫秒级网络抖动。Cron 模式更适合长期趋势分析。

2.1.2 探测器（Prober）

探测器是部署在网络边缘的轻量级代理，负责执行具体的网络探测任务。每个探测器包含以下模块：

协议引擎：支持 ICMP Ping、TCP Connect、HTTP Get、DNS 查询、Traceroute 五种协议。
本地缓存：当调度器连接中断时，探测器可缓存最近 1000 条探测结果，待恢复后批量上报。
资源限制：单节点并发探测数上限可配置（默认 50），防止探测器过载影响业务。
时间戳校准：每次探测前与 NTP 服务器同步，确保延迟数据精度在 ±1ms 内。

# 探测器配置文件示例（prober.yaml）
prober:
  id: "prober-01"
  max_concurrency: 50
  cache_size: 1000
  ntp_server: "pool.ntp.org"
  protocols:
    - icmp
    - tcp
    - http
  heartbeat_interval: 10s

2.1.3 分析器（Analyzer）

分析器负责接收探测器上报的原始数据，执行实时计算与历史聚合。核心功能包括：

实时窗口计算：基于滑动窗口（默认 5 分钟）计算平均延迟、丢包率、抖动值。
波动检测：使用标准差算法识别异常波动，当延迟标准差超过阈值（默认 20ms）时触发告警。
容错评估：对比测试周期内的成功/失败比例，生成网络可用性评分（0-100）。
数据持久化：将聚合结果写入时序数据库（如 InfluxDB），保留 90 天历史数据。

注意：分析器的滑动窗口大小直接影响波动检测灵敏度。窗口过小（< 1 分钟）会导致误报增多；窗口过大（> 30 分钟）会掩盖瞬时抖动。建议根据业务容忍度调整。

2.2 数据流与工作流程

LinkTest 的数据流遵循“配置 → 调度 → 探测 → 上报 → 分析 → 展示”的线性流程，同时包含异常处理与反馈回路。

2.2.1 详细工作流程步骤

配置下发：用户通过 Web UI 或 API 定义测试周期、目标地址、协议类型，配置写入调度器内存。
任务生成：调度器根据周期参数生成探测任务，每个任务包含唯一 ID、目标 IP、协议、超时时间（默认 5s）。
任务分发：调度器通过 gRPC 流将任务推送至探测器，探测器返回 ACK 确认。
探测执行：探测器按任务参数发送探测包，记录 RTT、状态码、丢包标志，并打上毫秒级时间戳。
数据上报：探测器每 5 秒或缓存满 200 条时，通过 Kafka 或 HTTP 批量上报至分析器。
实时分析：分析器对上报数据进行滑动窗口计算，生成延迟、抖动、可用性指标。
结果存储：原始数据与聚合结果写入时序数据库，供历史查询与趋势分析。
异常反馈：当波动检测触发阈值时，分析器通过回调接口通知调度器调整探测频率或触发告警。

  关键指标：从探测完成到分析器输出结果，端到端延迟控制在 500ms 以内（不含网络传输）。在 1000 个探测器并发场景下，系统吞吐量可达 50000 条/秒。

2.2.2 容错机制数据流

在网络波动容错测试中，数据流需额外处理以下异常场景：

异常场景	处理方式	影响范围
探测器离线	调度器标记节点不可用，任务重新分配至其他探测器	仅影响该节点覆盖的测试目标
数据上报超时	探测器本地缓存，网络恢复后补报（最多保留 30 分钟）	实时指标延迟，历史数据完整
分析器过载	降级为仅存储原始数据，跳过实时计算	告警延迟，不影响数据持久化
调度器重启	从持久化存储恢复任务状态，未完成的任务重新分发	短暂中断（< 5 秒）

2.3 组件间通信协议

LinkTest 组件间采用统一的 gRPC 双向流通信，确保低延迟与高可靠性。关键接口定义如下：

// 调度器 → 探测器：任务分发
service TaskDistribution {
  rpc AssignTask(stream TaskRequest) returns (stream TaskAck);
}

// 探测器 → 分析器：数据上报
service DataReport {
  rpc ReportProbeData(stream ProbeRecord) returns (ReportResponse);
}

// 分析器 → 调度器：反馈调整
service FeedbackAdjust {
  rpc NotifyAdjustment(AdjustmentRequest) returns (AdjustmentResponse);
}

message TaskRequest {
  string task_id = 1;
  string target_ip = 2;
  string protocol = 3;  // icmp | tcp | http
  int32 timeout_ms = 4;
  int64 timestamp = 5;
}

message ProbeRecord {
  string task_id = 1;
  string prober_id = 2;
  int64 rtt_ms = 3;
  bool packet_loss = 4;
  int32 status_code = 5;
  int64 probe_timestamp = 6;
}

性能数据：gRPC 双向流在 1000 并发连接下，单条消息传输延迟 < 2ms，吞吐量可达 80000 条/秒。相比 HTTP REST，延迟降低 60%，吞吐提升 3 倍。

2.4 架构总结

LinkTest 的三组件架构通过明确的职责分离与容错设计，为周期参数配置和网络波动测试提供了坚实基础。调度器保证测试节奏，探测器确保数据采集的广度与精度，分析器则赋予数据洞察能力。三者协同，使得在复杂网络环境下仍能获得可靠、可复现的测试结果。