限流规则详解

请求到达
    │
    ▼
┌─────────────────────────┐
│   用户层限流 (User)      │  ← RPM + 每日消费额度
└───────────┬─────────────┘
            │
            ▼
┌─────────────────────────┐
│   密钥层限流 (Key)       │  ← 5h/日/周/月金额 + 并发 Session
└───────────┬─────────────┘
            │
            ▼
┌─────────────────────────┐
│   供应商层限流 (Provider)│  ← 5h/日/周/月金额 + 并发 Session
└───────────┬─────────────┘
            │
            ▼
      请求转发

用户请求 → RateLimitGuard.ensure()
    │
    ├─► checkUserRPM(userId, rpmLimit)
    │       └─► 检查 user:{userId}:rpm_window ZSET
    │
    └─► checkUserDailyCost(userId, dailyLimitUsd)
            └─► 检查 user:{userId}:daily_cost STRING

                    用户限额: $100/日
                          │
                          ▼
                    ┌─────┴─────┐
                    │           │
              Key A: $50/日   Key B: $30/日
                    │           │
              实际: $50/日    实际: $30/日

{type}:{id}:cost_{period}_{suffix}

示例：
key:123:cost_daily_1800       # Key 123 的日限额，18:00 重置
provider:456:cost_daily_0000  # Provider 456 的日限额，00:00 重置
key:123:cost_weekly           # Key 123 的周限额
key:123:cost_monthly          # Key 123 的月限额

{type}:{id}:cost_{period}_rolling

示例：
key:123:cost_5h_rolling       # Key 123 的 5 小时滚动窗口
key:123:cost_daily_rolling    # Key 123 的日滚动窗口（24 小时）
provider:456:cost_5h_rolling  # Provider 456 的 5 小时滚动窗口

user:{userId}:rpm_window

示例：
user:1:rpm_window             # 用户 1 的 RPM 滑动窗口

{type}:{id}:active_sessions

示例：
key:123:active_sessions       # Key 123 的活跃 Session
provider:456:active_sessions  # Provider 456 的活跃 Session
global:active_sessions        # 全局活跃 Session

-- 1. 清理过期 session（5 分钟前）
-- 2. 检查 session 是否已追踪
-- 3. 获取当前并发数
-- 4. 检查限制（排除已追踪的 session）
-- 5. 追踪 session
-- 返回：{allowed, count, tracked}

-- 1. 清理过期记录（5 小时前）
-- 2. 添加当前消费记录（timestamp:cost）
-- 3. 计算窗口内总消费
-- 4. 设置兜底 TTL（6 小时）
-- 返回：当前窗口总消费

Redis 状态检查
    │
    ├─► status === 'ready' → 正常执行限流检查
    │
    └─► status !== 'ready' → Fail-Open
            │
            ├─► 记录警告日志
            ├─► 返回 { allowed: true }
            └─► 业务正常继续

{
  "type": "rate_limit_error",
  "message": "用户每分钟请求数上限已达到（60/60）",
  "limit_type": "rpm",
  "current_usage": 60,
  "limit_value": 60,
  "reset_time": "2024-01-01T12:01:00.000Z"
}

[RateLimit] User RPM exceeded: user=123, 用户每分钟请求数上限已达到（60/60）
[RateLimit] Redis unavailable, checking key cost limits from database
[RateLimit] Cache miss for key:123:cost_5h, querying database
[RateLimit] Cache warmed for key:123:cost_5h_rolling, value=15.5 (rolling window)