通知系统设计#

业务方 → 通知 API → Kafka → 通知中心引擎 → 渠道网关 → 用户
                                    │
                    ┌───────────────┼───────────────┐
                    │               │               │
              ┌─────┴─────┐  ┌─────┴─────┐  ┌─────┴─────┐
              │ 站内信     │  │ Push推送   │  │ SMS/Email │
              │ (自建)    │  │ (APNs/FCM) │  │ (三方服务) │
              └───────────┘  └───────────┘  └───────────┘

1. 业务方调用: notify(userId, templateId, params, channels, priority)
2. 消息入 MQ（Kafka），按 priority 分 Topic
3. 通知引擎消费：
   a. 模板渲染（标题/正文/跳转链接）
   b. 去重检查（同一通知 X 分钟内不重发）
   c. 频控检查（单用户每天最多 N 条 Push）
   d. 用户偏好过滤（用户关闭了某类通知）
   e. 免打扰时段检查（22:00-08:00 延迟发送）
4. 分发到各渠道网关
5. 记录发送日志 + 状态回调

高优先级通知（交易/安全）：Push + SMS 双发
普通通知（营销）：Push → 未送达 → 站内信
低优先级（推荐）：仅站内信

// 频控：滑动窗口限流
// key = user:{userId}:channel:{channel}:date:{date}
// Redis INCR + EXPIRE

// 去重：
// key = dedup:{userId}:{templateId}:{bizId}
// Redis SETNX + TTL（如 5 分钟内同一通知不重发）

// 免打扰：
// 22:00-08:00 的通知写入延迟队列（Redis ZSET + score=目标发送时间）

高优先级（P0）：验证码、安全告警、交易通知 → 独立 Topic，专用消费者
中优先级（P1）：订单状态、系统通知 → 共享 Topic
低优先级（P2）：营销、推荐 → 低优先级 Topic，限速消费

实现：Kafka 多 Topic + 消费者资源倾斜

模板示例：
  标题: "您的订单 {{orderNo}} 已发货"
  正文: "预计 {{deliveryDate}} 送达，快递单号 {{trackingNo}}"
  跳转: "app://order/detail?id={{orderId}}"

模板中心：运营后台配置，支持 A/B 测试不同文案
多语言：根据用户 locale 选择模板版本

核心指标：
- 发送量/成功率/失败率（per channel）
- 端到端延迟（从业务调用到用户收到）
- 打开率/点击率（Push/Email 的 CTR）
- 退订率/投诉率（Email 域名信誉）