BeeX ID 生产环境资源架构与成本规划

flowchart TD
  subgraph Client["用户端 / 外部平台"]
    App["BeeX App / H5"]
    WAUser["WhatsApp 用户"]
    Xendit["Xendit"]
    Tiktok["TikTok Shop"]
    Shopee["Shopee"]
    Feishu["飞书"]
  end

  subgraph Static["静态资源层"]
    CDN["CDN"]
    OSS["OSS
H5 / 离线包 / 图片 / 日志包"]
    CDN --> OSS
  end

  subgraph Entry["公网入口层"]
    DNS["DNS
beexofficial.com"]
    ALB["公网 ALB
HTTPS / 路由 / 健康检查"]
  end

  subgraph Service["业务服务层 - ECS"]
    API1["beex-api-01
2C4G"]
    API2["beex-api-02
2C4G"]
    WA1["beex-wa-service-01
2C4G"]
    WA2["beex-wa-service-02
2C4G"]
    Mix1["worker-webhook-01
beex-worker + beex-webhook
2C4G"]
    Mix2["worker-webhook-02
beex-worker + beex-webhook
2C4G"]
    Admin1["beex-admin-api-01
2C2G"]
  end

  subgraph Data["数据与中间件"]
    RDS["RDS MySQL 主库
正式写库"]
    RDSRO["RDS 只读实例
后台 / 报表查询"]
    Redis["Redis 主备
缓存 / 登录态 / 验证码 / 锁 / 幂等"]
    MQ["RocketMQ
异步消息 / 削峰"]
  end

  subgraph Obs["监控与日志"]
    SLS["SLS 日志"]
    ARMS["ARMS APM"]
    Monitor["CloudMonitor + 飞书告警"]
  end

  App --> CDN
  App --> DNS
  WAUser --> DNS
  Xendit --> DNS
  Tiktok --> DNS
  Shopee --> DNS
  Feishu --> DNS

  DNS --> ALB

  ALB -->|"/api/**"| API1
  ALB -->|"/api/**"| API2
  ALB -->|"/webhooks/whatsapp"| WA1
  ALB -->|"/webhooks/whatsapp"| WA2
  ALB -->|"/webhooks/xendit/** / tiktok/** / shopee/** / feishu/**"| Mix1
  ALB -->|"/webhooks/xendit/** / tiktok/** / shopee/** / feishu/**"| Mix2
  ALB -->|"/admin/**"| Admin1

  API1 --> RDS
  API2 --> RDS
  API1 --> Redis
  API2 --> Redis
  API1 --> MQ
  API2 --> MQ

  WA1 --> RDS
  WA2 --> RDS
  WA1 --> Redis
  WA2 --> Redis
  WA1 --> MQ
  WA2 --> MQ

  Mix1 --> RDS
  Mix1 --> Redis
  Mix1 --> MQ
  Mix2 --> RDS
  Mix2 --> Redis
  Mix2 --> MQ

  Admin1 --> RDSRO
  Admin1 --> RDS
  Admin1 --> Redis

  RDS --> RDSRO

  API1 --> SLS
  API2 --> SLS
  WA1 --> SLS
  WA2 --> SLS
  Mix1 --> SLS
  Mix2 --> SLS
  Admin1 --> SLS

  API1 --> ARMS
  API2 --> ARMS
  WA1 --> ARMS
  WA2 --> ARMS
  Mix1 --> ARMS
  Mix2 --> ARMS
  Admin1 --> ARMS

  SLS --> Monitor
  ARMS --> Monitor
        

flowchart TD
  subgraph Client["测试用户 / 三方测试平台"]
    App["BeeX App
88.88.88 调试版本"]
    WA["WhatsApp 测试号"]
    Xendit["Xendit Sandbox"]
    Tiktok["TikTok / Shopee 测试或低风险账号"]
    Feishu["飞书测试群"]
  end

  subgraph Static["测试静态资源"]
    H5["h5-id-test.beexofficial.com"]
    OSS["beex-id-test-h5
H5 / 离线包 / 图片 / 日志包"]
    H5 --> OSS
  end

  subgraph Entry["测试入口"]
    ALB["测试 ALB
api-id-test.beexofficial.com"]
  end

  subgraph Service["测试服务层 - 当前建议"]
    Node1["beex-id-test-service
2C8G
api + wa + worker + webhook + admin-api"]
    Node2["test-biz-02
2C8G
api + wa + worker + webhook
下一步新增"]
    Admin["admin ECS
2C2G
sso + rollback"]
  end

  subgraph Data["测试数据层"]
    RDS["RDS MySQL Test
测试库 + admin 独立库"]
    Redis["Redis Test
测试 DB + admin 独立 DB"]
    MQ["RocketMQ Test
可先低配或按需打开"]
  end

  App --> H5
  App --> ALB
  WA --> ALB
  Xendit --> ALB
  Tiktok --> ALB
  Feishu --> ALB

  ALB -->|"/api/**"| Node1
  ALB -->|"/api/**"| Node2
  ALB -->|"/webhooks/whatsapp"| Node1
  ALB -->|"/webhooks/whatsapp"| Node2
  ALB -->|"/webhooks/xendit/** / tiktok/** / shopee/** / feishu/**"| Node1
  ALB -->|"/webhooks/xendit/** / tiktok/** / shopee/** / feishu/**"| Node2
  ALB -->|"/admin/**"| Node1

  Node1 --> RDS
  Node2 --> RDS
  Admin --> RDS

  Node1 --> Redis
  Node2 --> Redis
  Admin --> Redis

  Node1 --> MQ
  Node2 --> MQ
        

flowchart LR
  Normal["常态测试
test-biz x2
admin-test x1"] --> Expand["容量预演
临时增加生产拆分节点
api x2
wa x2
worker-webhook x2"]
  Expand --> Rehearsal["线上预演
ALB 多实例路由
滚动发布
Worker 抢锁
Webhook 幂等
全链路回归"]
  Rehearsal --> Decision{"结果是否通过"}
  Decision -->|通过| Release["允许生产发布"]
  Decision -->|不通过| Fix["修复后重新预演"]
  Release --> Shrink["预演结束
释放临时容量节点
回到常态测试"]
  Fix --> Expand
        

flowchart LR
  DNS["api-id.beexofficial.com"] --> ALB["公网 ALB"]
  H5["h5-id.beexofficial.com"] --> CDN["CDN / OSS"]
  AdminWeb["admin.beexofficial.com"] --> AdminCDN["管理后台 OSS/CDN"]

  ALB --> Api["/api/**
beex-api x2"]
  ALB --> WA["/webhooks/whatsapp
beex-wa-service x2"]
  ALB --> Webhook["/webhooks/xendit/**
/webhooks/tiktok/**
/webhooks/shopee/**
/webhooks/feishu/**
beex-webhook x2
混部在 worker-webhook 节点"]
  AdminApi["admin-api-id.beexofficial.com"] --> Admin["beex-admin-api"]
  SSO["sso.beexofficial.com"] --> SSOService["SSO 服务"]
        

flowchart LR
  T["定时触发
每 5/15 分钟"] --> W1["worker-01"]
  T --> W2["worker-02"]
  W1 --> L["Redis/DB 分布式锁
job:ID:TIKTOK_ORDER_SYNC:account"]
  W2 --> L
  L -->|抢到锁| Run["执行拉取
TikTok/Shopee 订单"]
  L -->|没抢到| Skip["本轮 skip
只打日志/指标"]
  Run --> Upsert["幂等写入
platform + order_id 唯一键"]
  Upsert --> Reward["触发分佣/钱包/通知"]
        

flowchart LR
  Normal["平时
api x2
wa x2
worker-webhook x2
admin x1"] --> Before["活动前 1-2 天
api x4
wa x4
worker-webhook x4
admin x1"]
  Before --> Day["活动当天
盯 p95/p99
WA 延迟
MQ 堆积
RDS/Redis
三方错误率"]
  Day --> After["活动后
确认 MQ 追平
订单同步追平
佣金无异常
释放临时 ECS"]