大海
29 KiB
29 KiB
第六部分：智能调度系统
6.1 实时链路探测
┌──────────────────────────────────────────────────────────────────┐
│ 实时链路探测系统 │
├──────────────────────────────────────────────────────────────────┤
│ │
│ 探测架构： │
│ ┌─────────────────────────────────────────────────────────┐ │
│ │ 探测集群 │ │
│ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │
│ │ │ 探测节点 │ │ 探测节点 │ │ 探测节点 │ ... │ │
│ │ │ (北京) │ │ (上海) │ │ (广州) │ │ │
│ │ └────┬─────┘ └────┬─────┘ └────┬─────┘ │ │
│ │ │ │ │ │ │
│ │ └──────────────┴──────────────┘ │ │
│ │ │ │ │
│ │ ┌──────┴──────┐ │ │
│ │ │ 数据汇聚 │ │ │
│ │ │ (ClickHouse)│ │ │
│ │ └──────┬──────┘ │ │
│ │ │ │ │
│ │ ┌──────┴──────┐ │ │
│ │ │ 分析引擎 │ │ │
│ │ │ (实时计算) │ │ │
│ │ └──────┬──────┘ │ │
│ │ │ │ │
│ │ ┌──────┴──────┐ │ │
│ │ │ 调度决策 │ │ │
│ │ │ (路由更新) │ │ │
│ │ └─────────────┘ │ │
│ └─────────────────────────────────────────────────────────┘ │
│ │
│ 探测指标： │
│ ┌──────────────┬──────────────┬──────────────┬──────────────┐ │
│ │ 指标 │ 方法 │ 频率 │ 精度 │ │
│ ├──────────────┼──────────────┼──────────────┼──────────────┤ │
│ │ Ping │ ICMP/UDP │ 每5秒 │ ±1ms │ │
│ │ Jitter │ RTT标准差 │ 每5秒 │ ±2ms │ │
│ │ Loss │ 统计法 │ 每10秒 │ ±0.1% │ │
│ │ RTT │ TCP/UDP │ 每5秒 │ ±1ms │ │
│ │ Bandwidth │ 递增探测 │ 每分钟 │ ±10% │ │
│ │ Node Load │ 心跳上报 │ 每10秒 │ ±5% │ │
│ └──────────────┴──────────────┴──────────────┴──────────────┘ │
│ │
│ 探测数据存储： │
│ - 实时数据：Redis（最新值，TTL 5分钟） │
│ - 历史数据：ClickHouse（聚合后，保留30天） │
│ - 告警数据：MySQL（持久化） │
│ │
└──────────────────────────────────────────────────────────────────┘
6.2 调度算法设计
6.2.1 基础版本（规则引擎）
┌──────────────────────────────────────────────────────────────────┐
│ 基础调度算法（规则引擎） │
├──────────────────────────────────────────────────────────────────┤
│ │
│ 输入： │
│ - 用户位置（城市、ISP） │
│ - 游戏服务器位置 │
│ - 节点列表及其状态 │
│ │
│ 输出： │
│ - 最优节点 │
│ - 路由路径 │
│ │
│ 规则优先级： │
│ ┌──────────────────────────────────────────────────────────┐ │
│ │ 规则1：同城市同ISP → 直连 │ │
│ │ 条件：user.city == node.city && user.isp == node.isp │ │
│ │ 动作：直接选择该节点 │ │
│ │ 优先级：1（最高） │ │
│ │ │ │
│ │ 规则2：同城市跨ISP → BGP节点 │ │
│ │ 条件：user.city == node.city && user.isp != node.isp │ │
│ │ 动作：选择BGP节点 │ │
│ │ 优先级：2 │ │
│ │ │ │
│ │ 规则3：同区域跨城市 → 区域核心节点 │ │
│ │ 条件：user.region == node.region && user.city != node.city│ │
│ │ 动作：选择区域核心节点 │ │
│ │ 优先级：3 │ │
│ │ │ │
│ │ 规则4：跨区域 → 中转节点 │ │
│ │ 条件：user.region != node.region │ │
│ │ 动作：选择最优中转节点 │ │
│ │ 优先级：4 │ │
│ │ │ │
│ │ 规则5：跨境 → 国际专线节点 │ │
│ │ 条件：user.country != node.country │ │
│ │ 动作：选择国际专线节点 │ │
│ │ 优先级：5（最低） │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ 伪代码实现： │
│ │
│ func basicSchedule(user *User, game *Game) *Node { │
│ candidates := getCandidateNodes(game) │
│ │
│ // 规则1：同城市同ISP │
│ for _, node := range candidates { │
│ if node.City == user.City && node.ISP == user.ISP { │
│ return node │
│ } │
│ } │
│ │
│ // 规则2：同城市BGP │
│ for _, node := range candidates { │
│ if node.City == user.City && node.IsBGP { │
│ return node │
│ } │
│ } │
│ │
│ // 规则3：同区域核心节点 │
│ for _, node := range candidates { │
│ if node.Region == user.Region && node.IsCore { │
│ return node │
│ } │
│ } │
│ │
│ // 规则4：中转节点 │
│ bestScore := 0.0 │
│ var bestNode *Node │
│ for _, node := range candidates { │
│ score := calculateScore(node, user) │
│ if score > bestScore { │
│ bestScore = score │
│ bestNode = node │
│ } │
│ } │
│ return bestNode │
│ } │
│ │
└──────────────────────────────────────────────────────────────────┘
6.2.2 高级版本（多因子加权）
┌──────────────────────────────────────────────────────────────────┐
│ 高级调度算法（多因子加权） │
├──────────────────────────────────────────────────────────────────┤
│ │
│ 输入因子： │
│ ┌──────────────┬──────────┬──────────┬──────────────────────┐ │
│ │ 因子 │ 权重 │ 范围 │ 说明 │ │
│ ├──────────────┼──────────┼──────────┼──────────────────────┤ │
│ │ RTT │ 0.35 │ 0-500ms │ 往返延迟 │ │
│ │ Loss Rate │ 0.25 │ 0-100% │ 丢包率 │ │
│ │ Jitter │ 0.15 │ 0-100ms │ 抖动 │ │
│ │ Node Load │ 0.10 │ 0-100% │ 节点负载 │ │
│ │ ISP Match │ 0.05 │ 0/1 │ ISP匹配 │ │
│ │ Geo Distance │ 0.05 │ 0-10000km│ 地理距离 │ │
│ │ Line Quality │ 0.05 │ 0-1 │ 线路质量 │ │
│ └──────────────┴──────────┴──────────┴──────────────────────┘ │
│ │
│ 评分公式： │
│ │
│ Score(i) = Σ(Wj × normalize(Fij)) │
│ │
│ 其中： │
│ - Wj = 第j个因子的权重 │
│ - Fij = 节点i在第j个因子上的值 │
│ - normalize() = 归一化到[0,1]区间 │
│ │
│ 归一化方法： │
│ - RTT: norm = 1 - (RTT / max_RTT) │
│ - Loss: norm = 1 - Loss │
│ - Jitter: norm = 1 - (Jitter / max_Jitter) │
│ - Load: norm = 1 - Load │
│ - ISP Match: norm = 1 if match else 0 │
│ - Geo Distance: norm = 1 - (dist / max_dist) │
│ - Line Quality: norm = Quality_Score │
│ │
│ 伪代码实现： │
│ │
│ type ScheduleFactor struct { │
│ Name string │
│ Weight float64 │
│ MaxVal float64 │
│ } │
│ │
│ var factors = []ScheduleFactor{ │
│ {"rtt", 0.35, 500}, │
│ {"loss", 0.25, 1.0}, │
│ {"jitter", 0.15, 100}, │
│ {"load", 0.10, 1.0}, │
│ {"isp_match", 0.05, 1.0}, │
│ {"geo_dist", 0.05, 10000}, │
│ {"line_quality", 0.05, 1.0}, │
│ } │
│ │
│ func advancedSchedule(user *User, game *Game) *Node { │
│ candidates := getCandidateNodes(game) │
│ │
│ var bestNode *Node │
│ bestScore := -1.0 │
│ │
│ for _, node := range candidates { │
│ score := 0.0 │
│ │
│ // RTT因子 │
│ rttNorm := 1.0 - (node.RTT / 500.0) │
│ score += 0.35 * rttNorm │
│ │
│ // 丢包因子 │
│ lossNorm := 1.0 - node.LossRate │
│ score += 0.25 * lossNorm │
│ │
│ // 抖动因子 │
│ jitterNorm := 1.0 - (node.Jitter / 100.0) │
│ score += 0.15 * jitterNorm │
│ │
│ // 负载因子 │
│ loadNorm := 1.0 - node.LoadRate │
│ score += 0.10 * loadNorm │
│ │
│ // ISP匹配 │
│ ispNorm := 0.0 │
│ if node.ISP == user.ISP { │
│ ispNorm = 1.0 │
│ } │
│ score += 0.05 * ispNorm │
│ │
│ // 地理距离 │
│ dist := haversine(user.Lat, user.Lng, node.Lat, node.Lng)│
│ distNorm := 1.0 - (dist / 10000.0) │
│ score += 0.05 * distNorm │
│ │
│ // 线路质量 │
│ score += 0.05 * node.LineQuality │
│ │
│ if score > bestScore { │
│ bestScore = score │
│ bestNode = node │
│ } │
│ } │
│ │
│ return bestNode │
│ } │
│ │
└──────────────────────────────────────────────────────────────────┘
6.2.3 AI版本（机器学习）
┌──────────────────────────────────────────────────────────────────┐
│ AI调度算法（机器学习） │
├──────────────────────────────────────────────────────────────────┤
│ │
│ 模型选择：XGBoost / LightGBM │
│ 原因： │
│ - 推理速度快（<1ms） │
│ - 可解释性好 │
│ - 特征重要性可分析 │
│ - 训练数据要求相对低 │
│ │
│ 特征工程： │
│ ┌──────────────────────────────────────────────────────────┐ │
│ │ 用户特征： │ │
│ │ - user_city (one-hot编码) │ │
│ │ - user_isp (one-hot编码) │ │
│ │ - user_latency_avg (历史平均延迟) │ │
│ │ - user_loss_avg (历史平均丢包率) │ │
│ │ - user_bandwidth (用户带宽) │ │
│ │ - time_of_day (时段，0-23) │ │
│ │ - day_of_week (星期，0-6) │ │
│ │ - is_peak_hour (是否高峰时段) │ │
│ │ │ │
│ │ 节点特征： │ │
│ │ - node_city (one-hot编码) │ │
│ │ - node_isp (one-hot编码) │ │
│ │ - node_rtt (当前延迟) │ │
│ │ - node_loss (当前丢包率) │ │
│ │ - node_jitter (当前抖动) │ │
│ │ - node_load (当前负载) │ │
│ │ - node_bandwidth (节点带宽) │ │
│ │ - node_line_type (线路类型，0-5) │ │
│ │ │ │
│ │ 游戏特征： │ │
│ │ - game_id (游戏ID) │ │
│ │ - game_region (游戏区域) │ │
│ │ - game_protocol (游戏协议，TCP/UDP/混合) │ │
│ │ - game_server_distance (游戏服务器距离) │ │
│ │ │ │
│ │ 交叉特征： │ │
│ │ - user_node_distance (用户到节点距离) │ │
│ │ - user_node_isp_match (ISP是否匹配) │ │
│ │ - node_game_distance (节点到游戏服务器距离) │ │
│ │ - historical_score (历史评分) │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ 标签： │
│ - 实际加速效果评分（0-100） │
│ - 用户满意度（点击"反馈"按钮） │
│ - 是否掉线（0/1） │
│ │
│ 训练流程： │
│ ┌──────────────────────────────────────────────────────────┐ │
│ │ │ │
│ │ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ │
│ │ │ 数据收集 │───→│ 特征工程 │───→│ 模型训练 │ │ │
│ │ │ 30天数据 │ │ 特征提取 │ │ XGBoost │ │ │
│ │ └──────────┘ └──────────┘ └──────────┘ │ │
│ │ │ │ │ │
│ │ │ ┌───────────────────┘ │ │
│ │ │ ↓ │ │
│ │ │ ┌──────────┐ ┌──────────┐ │ │
│ │ │ │ 模型评估 │───→│ 模型部署 │ │ │
│ │ │ │ A/B测试 │ │ 在线推理 │ │ │
│ │ │ └──────────┘ └──────────┘ │ │
│ │ │ │ │
│ │ └─── 每周重新训练，持续优化 │ │
│ │ │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ 推理流程： │
│ ┌──────────────────────────────────────────────────────────┐ │
│ │ │ │
│ │ func aiSchedule(user *User, game *Game) *Node { │ │
│ │ candidates := getCandidateNodes(game) │ │
│ │ │ │
│ │ // 提取特征 │ │
│ │ features := extractFeatures(user, candidates, game) │ │
│ │ │ │
│ │ // 模型推理 │ │
│ │ scores := model.Predict(features) │ │
│ │ │ │
│ │ // 选择最高分节点 │ │
│ │ bestIdx := argmax(scores) │ │
│ │ return candidates[bestIdx] │ │
│ │ } │ │
│ │ │ │
│ └──────────────────────────────────────────────────────────┘ │
│ │
│ A/B测试： │
│ - 10%用户使用AI调度 │
│ - 90%用户使用高级调度 │
│ - 对比指标：延迟、丢包率、用户满意度 │
│ - 显著提升后全量切换 │
│ │
└──────────────────────────────────────────────────────────────────┘