设计一个即时通讯（IM）系统

客户端（手机 / PC / Web）
   │ 长连接：WebSocket 或自定义 TCP 协议，连上后先鉴权
   ▼
接入层：长连接网关集群（只管连接：鉴权、心跳、收发包，不含业务逻辑）
   │  上线时登记路由：用户 + 设备 → 网关节点（Redis，带过期时间，心跳时续期）
   ▼  RPC 或消息队列
逻辑层：消息服务
   1 校验：好友关系、群成员、是否禁言；按发送方的 client_msg_id 去重
   2 分配会话内递增的 seq，写入消息存储
   3 回 ACK 给发送方（带服务端生成的 msg_id 和 seq）
   4 查路由，把消息交给接收方所在的网关，网关推给客户端
   5 接收方离线：消息已经存好，等上线后拉取；另发一条手机系统推送提醒
   ▼
存储：消息表（按会话分片）、会话表；Redis：路由、在线状态、seq 计数器

发送方                         服务端                          接收方
  │── 消息(client_msg_id) ──────>│                               │
  │                              │ 去重、分配 seq、存储           │
  │<── ACK(msg_id, seq) ─────────│                               │
  │                              │── 推送(msg_id, seq) ─────────>│
  │                              │<── ACK ───────────────────────│
超时没收到 ACK：用同一个 client_msg_id 重发      超时没收到 ACK：重推几次，再不行等它来拉

class ConversationSync {
  constructor(pullAfter, onMessage) {
    this.pullAfter = pullAfter // (seq) => Promise<消息数组>：拉取 seq 之后的消息
    this.onMessage = onMessage // 按 seq 顺序交给界面展示
    this.maxSeq = 0 // 已经连续收到的最大序号，持久化在本地
    this.buffer = new Map() // 先到的、序号不连续的消息
    this.pulling = null
  }

  // 收到服务端推送（不管是否重复，都要给服务端回 ACK，这里省略）
  async onPush(msg) {
    this.accept([msg])
    if (this.buffer.size > 0) await this.sync() // 有缺口：中间的消息丢了或者还在路上
  }

  // 断线重连、启动时也调用：拉取本地最大序号之后的所有消息
  async sync() {
    this.pulling ??= this.pullAfter(this.maxSeq)
      .then((msgs) => this.accept(msgs))
      .finally(() => (this.pulling = null))
    return this.pulling // 并发触发时复用同一次拉取
  }

  accept(msgs) {
    for (const m of msgs) {
      if (m.seq > this.maxSeq) this.buffer.set(m.seq, m) // seq <= maxSeq 是重复消息，丢弃
    }
    while (this.buffer.has(this.maxSeq + 1)) {
      const next = this.buffer.get(this.maxSeq + 1)
      this.buffer.delete(next.seq)
      this.maxSeq = next.seq
      this.onMessage(next)
    }
  }
}

const server = [1, 2, 3, 4].map((seq) => ({ seq, text: `消息${seq}` }))
const c = new ConversationSync(async (after) => server.filter((m) => m.seq > after), (m) => console.log(m.seq))
await c.onPush(server[0]) // 输出 1
await c.onPush(server[0]) // 重复，忽略
await c.onPush(server[2]) // 缺 2 → 拉取，输出 2 3 4