企业官网建设流程全解析

官方文档：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 = f"gewe:sticky:{peer_id}" appid = redis.get(key) if appid and redis.hget(f"gewe:node:{appid}", "status") == "online": return appid # 选队列最浅且在线的节点 appid = min( (a for a in fleet if redis.hget(f"gewe:node:{a}", "status") == "online"), key=lambda a: int(redis.get(f"gewe:outbound:depth:{a}") or 0), default=None, ) if not appid: raise NoCapacity("no online gewe node") redis.set(key, appid, ex=30 * 86400) return appid

3.2 故障转移

async function withFailover(peerId: string, task: (appid: string) => Promise<void>) { 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: 50

3.5 灾难演练剧本

1. 人为将 Node A 置 offline 2. 观察 sticky 迁移速率与告警 3. 抽样会话连续性（欢迎语是否重复、上下文是否丢） 4. 恢复 Node A 后是否「抢回」会话（建议不抢回，避免来回抖） 5. 记录 RTO/RPO 与改进项

四、生产环境避坑与安全风控

1. Failover 不是加粉借口：备援号同样受风控配额约束。

2. 迁移后会话记忆：Redis session key 按 peer 存，不按 appid，或做复制。

3. 回调 URL 与 Token：多账号同 Token 时共用回调，Ingress 必须用appid分流。

4. 禁止无限重登：掉线告警到人，自动重登需熔断。

5. 私有化场景：网关与节点同地域，减少跨网抖动。

6. 部署模式（SaaS/私有化）说明见文首官方文档。

五、本篇交付清单

• 会话粘性映射

• 故障转移与健康摘除

• 容量规划与演练剧本

• 多账号舰队调度