流式连接断了，怎么续传？

POST /api/chat（带 requestId）
  已有这个 requestId 的任务：直接返回，不重复生成
  没有：创建任务，后台开始生成，每个片段追加到 Redis Stream，自动得到递增的条目 ID

GET /api/chat/:requestId/events（可以带 Last-Event-ID）
  先补发这个 ID 之后已有的片段，再阻塞等待新片段，直到读到结束标记

任务结束：写入结束标记，全文保存到数据库，缓存设置过期时间

app.post('/api/chat', async (req, res) => {
  const { requestId, messages } = req.body
  // NX：只有第一次请求能创建任务，重试的请求不会重复生成
  const created = await redis.set(`chat:task:${requestId}`, 'running', 'EX', 3600, 'NX')
  if (created) generate(requestId, messages) // 不等待，后台执行
  res.json({ requestId })
})

async function generate(requestId, messages) {
  const key = `chat:${requestId}`
  try {
    for await (const delta of streamLLM(messages)) {
      await redis.xadd(key, '*', 'type', 'delta', 'text', delta)
    }
    await redis.xadd(key, '*', 'type', 'done')
  } catch {
    await redis.xadd(key, '*', 'type', 'error')
  } finally {
    await redis.expire(key, 3600) // 一小时后自动清理
  }
}

app.get('/api/chat/:id/events', async (req, res) => {
  const key = `chat:${req.params.id}`
  let lastId = req.get('Last-Event-ID') || '0' // 0 表示从头读
  res.writeHead(200, { 'Content-Type': 'text/event-stream', 'Cache-Control': 'no-cache' })
  const reader = redis.duplicate() // XREAD BLOCK 会阻塞所在的连接，每个读者用单独的连接
  let closed = false
  res.on('close', () => {
    closed = true
    reader.disconnect()
  })
  try {
    while (!closed) {
      const result = await reader.xread('BLOCK', 15000, 'STREAMS', key, lastId)
      if (!result) {
        res.write(': ping\n\n') // 15 秒没有新内容，发一次心跳
        continue
      }
      for (const [id, fields] of result[0][1]) {
        const [, type, , text] = fields // ['type', 'delta', 'text', '...']
        res.write(`id: ${id}\nevent: ${type}\ndata: ${JSON.stringify({ text })}\n\n`)
        lastId = id
        if (type !== 'delta') return // 读到结束标记
      }
    }
  } catch {
    // 客户端断开时 reader 被关闭，阻塞中的读取会抛错
  } finally {
    reader.disconnect()
    res.end()
  }
})

const res = await fetch(`/api/chat/${requestId}/events`, {
  headers: lastEventId ? { 'Last-Event-ID': lastEventId } : {},
})