官方文档GeWe API - GeWe API微信 API 开发文档一、业务痛点与技术背景单账号单节点足以 Demo不足以支撑业务| 场景 | 风险 | |------|## 五、本篇交付清单会话粘性映射故障转移与健康摘除容量规划与演练剧本多账号舰队调度目标把多个 GeWe 执行节点组成Bot Fleet实现会话粘性、故障转移、配额调度与演练。二、核心架构设计与数据流转┌─ Node A (online) CRM Session Map ──► │─ Node B (online) ◄── Health Watchdog peer→appid 粘性 └─ Node C (standby) │ ▼ Scheduler - sticky first - failover if offline - load aware (queue depth) │ ▼ Outbound Gateway粘性规则同一peerId固定落到同一appid避免多号同时服务一人造成分裂人格仅在节点offline/banned时迁移。三、关键代码与配置示例3.1 会话粘性映射def resolve_appid(peer_id: str, fleet: list[str]) - str: key fgewe:sticky:{peer_id} appid redis.get(key) if appid and redis.hget(fgewe:node:{appid}, status) online: return appid # 选队列最浅且在线的节点 appid min( (a for a in fleet if redis.hget(fgewe:node:{a}, status) online), keylambda a: int(redis.get(fgewe:outbound:depth:{a}) or 0), defaultNone, ) if not appid: raise NoCapacity(no online gewe node) redis.set(key, appid, ex30 * 86400) return appid3.2 故障转移async function withFailover(peerId: string, task: (appid: string) Promisevoid) { let appid await sticky.get(peerId); try { await task(appid); } catch (e) { if (!isNodeDeadError(e)) throw e; const next await fleet.pickExclude(appid); await sticky.migrate(peerId, next, reason failover); await audit.write({ type: sticky_migrate, peerId, from: appid, to: next }); await task(next); await notify.ops(peer ${peerId} migrated ${appid} - ${next}); } }3.3 健康检查与自动摘除func (w *Watchdog) Tick() { for _, n : range w.Nodes() { online : w.Gewe.CheckOnline(n.AppID) if !online { w.Registry.SetStatus(n.AppID, offline) w.Alert.Page(node offline n.AppID) continue } // 合成探测自发自收或探测号 if err : w.Probe.Ping(n.AppID); err ! nil { w.Registry.SetStatus(n.AppID, degraded) } else { w.Registry.SetStatus(n.AppID, online) w.Registry.Heartbeat(n.AppID, time.Now()) } } }3.4 容量规划模型有效会话能力 ≈ Σ(账号安全发送速率) × 平均会话轮次预算 建议预留 30% 冗余任一账号进入 FREEZE 不影响 P0 客服备援号接管fleet: nodes: - { logical_id: bot_a, appid: wx_a, role: primary_cs, weight: 3 } - { logical_id: bot_b, appid: wx_b, role: primary_cs, weight: 3 } - { logical_id: bot_c, appid: wx_c, role: standby, weight: 1 } failover: auto: true cool_down_sec: 120 max_migrations_per_hour: 503.5 灾难演练剧本1. 人为将 Node A 置 offline 2. 观察 sticky 迁移速率与告警 3. 抽样会话连续性欢迎语是否重复、上下文是否丢 4. 恢复 Node A 后是否「抢回」会话建议不抢回避免来回抖 5. 记录 RTO/RPO 与改进项四、生产环境避坑与安全风控Failover 不是加粉借口备援号同样受风控配额约束。迁移后会话记忆Redis session key 按 peer 存不按 appid或做复制。回调 URL 与 Token多账号同 Token 时共用回调Ingress 必须用appid分流。禁止无限重登掉线告警到人自动重登需熔断。私有化场景网关与节点同地域减少跨网抖动。部署模式SaaS/私有化说明见文首官方文档。五、本篇交付清单会话粘性映射故障转移与健康摘除容量规划与演练剧本多账号舰队调度