架构总览

Gateway New 是一套远程主机控制平面 SaaS。 核心思想：把 RMM/远控的”控制台 + 命令调度 + 计费”做成多租户云服务，agent 端尽量轻。

模块图

┌──────────────┐                         ┌──────────────────┐
│ 用户浏览器    │                         │ 用户的 Windows 主机 │
│ (user-web)   │ ──── BFF / cookie ──→  │ (m2-gateway agent) │
└──────────────┘                         └────────┬─────────┘
                                                  │
                                                wss
                                                  │
┌──────────────┐                                  ↓
│ admin 浏览器 │                         ┌──────────────────┐
│ (admin-web)  │ ──── BFF / cookie ──→  │   API 中枢       │
└──────────────┘                         │   (api/, Go)     │
                                         └────────┬─────────┘
                                                  │
                                              PG + Redis
                                                  │
                                         ┌────────┴─────────┐
                                         │   PostgreSQL 16  │
                                         └──────────────────┘

模块清单

数据流：典型调用

用户在自己代码里调 SDK：

SDK.exec_shell(host_id, req)
  ↓ HTTPS
中枢 /v1/api/hosts/{id}/process/shell
  middleware:
    1. AuthAPIKey      → 解 ak_xxx.yyy → 验 sha256 → 注入 user_id / api_key_id
    2. BillingCharge   → 查 pricing_rules → SELECT FOR UPDATE balance → 扣 5 token
                       → 不够 → 直接返 402
                       → 够 → next()
  handler:
    3. host 归属校验：host.user_id == ctx.user_id
    4. wshub.IsOnline(host_id) → 不在线返 409
    5. wshub.SendCmd({controls: 1<<13, ...}) → 阻塞等回包（30s deadline）
       ↓ wss frame: {type:"cmd", ...}
       Rust agent.controls::dispatch
         → proc_ops::exec_shell（async tokio::process）
         → 同步等命令 + 捕获 stdout/stderr/exit_code
       ↑ wss frame: {type:"cmd_resp", data: {stdout, stderr, exit_code, ...}}
    6. 异步写 call_logs（不阻塞响应）
  ← HTTP 200 + JSON

协议层

• L1（向下兼容）：HTTP POST /gateway + AES-256-CBC + 16 个老 controls
• L2（新协议）：POST /v2/gateway + AES-GCM；agent ↔ 中枢用 wss + JSON envelope + binary stream frame

详见 Agent ↔ 中枢 协议。

计费

• 每个 user_id 维护一个 billing_balances 表的 token 余额
• 每条 /v1/api/* 路由按 billing_pricing_rules 表的 code 扣（如 control.exec_shell.per_call = 5 token）
• 充值：1 CNY = 100 token
• 退款 / 调整：admin 手工，自动落 audit
• 流水：billing_events + call_logs（月分区）

技术决策（已锁定）