SSE 回答式生成：精确用户问题范围、连续提问与结束提问的工程实践-育师

1. 引言

在构建大模型对话应用时，SSE（Server-Sent Events）回答式生成是常见的流式交互方案。相比一次性返回完整结果，SSE 可以让用户实时看到模型逐字生成的内容，显著提升交互体验。但在实际工程中，如何精确界定用户问题范围、支持多个问题连续提问、以及正确结束一次提问，是三个容易被忽视却又至关重要的细节。

本文围绕这三个核心问题展开，结合可运行的代码示例，梳理 SSE 回答式生成的设计思路与落地要点。

2. 精确用户问题范围

所谓「精确用户问题范围」，指的是在一次 SSE 会话中，服务端需要明确当前正在回答的是哪一个用户问题。尤其在多轮对话场景下，用户可能连续抛出多个问题，如果服务端不能准确区分问题边界，就会出现回答串台、上下文错乱等问题。

实践中通常采用以下两种方式界定问题范围：

会话级问题 ID：每个用户问题在进入服务端时分配唯一 ID，SSE 事件中携带该 ID，前端据此将流式内容归位到对应的问题气泡。
问题序号递增：在连续提问场景下，服务端维护一个递增的序号，每次回答都携带当前序号，前端据此判断当前流属于第几个问题。

下面给出一个基于 Node.js 的简化示例，演示如何在 SSE 事件中携带问题 ID：

// 服务端：为每个问题分配唯一 ID，并在 SSE 事件中携带 const { EventEmitter } = require('events'); const emitter = new EventEmitter(); function handleQuestion(questionText, questionId) { // 模拟模型流式生成 const tokens = questionText.split(' '); let index = 0; const timer = setInterval(() => { if (index < tokens.length) { // 每个事件都携带 questionId，前端据此归位 emitter.emit('sse', { questionId, delta: tokens[index] + ' ', done: false }); index++; } else { emitter.emit('sse', { questionId, delta: '', done: true }); clearInterval(timer); } }, 200); } // 前端通过 EventSource 或 fetch 流式接收 // 每次收到事件，先读取 questionId，再决定追加到哪个问题气泡

通过这种方式，即使多个问题几乎同时进入服务端，前端也能根据 questionId 精确区分每个问题的回答范围，避免内容串扰。

3. 多个问题连续提问

连续提问是对话类应用的常见诉求。用户可能在一个输入框里连续输入多个问题，也可能在上一轮回答尚未结束时就开始追问。这两种情况需要分别处理。

情况一：一次输入包含多个问题

当用户在一次输入中抛出多个问题时，服务端需要先做问题拆分，再逐个生成回答。拆分可以基于标点符号（问号、换行）或语义模型完成。拆分后，每个子问题独立走一遍 SSE 生成流程，前端按顺序展示。

// 服务端：拆分多个问题并逐个流式回答 function splitQuestions(rawInput) { // 简化实现：按问号和换行拆分 return rawInput .split(/[?？\n]/) .map(s => s.trim()) .filter(Boolean); } const questions = splitQuestions('什么是 SSE？如何实现连续提问？'); questions.forEach((q, idx) => { handleQuestion(q, `q-${Date.now()}-${idx}`); });

情况二：上一轮未结束时追问

这种情况下，服务端需要决定是打断上一轮回答，还是排队处理。通常建议采用「队列 + 取消令牌」机制：新问题到来时，若上一轮仍在生成，可选择取消旧任务并立即响应新问题，或让旧任务完成后按顺序处理新问题。具体策略取决于产品交互预期。

无论哪种情况，前端都需要维护一个「问题列表 + 对应流式回答」的数据结构，确保每个问题的回答独立渲染、互不干扰。

4. 结束提问

「结束提问」包含两层含义：一是单次回答的结束，二是整个对话回合的结束。两者在 SSE 协议层面都需要明确的信号。

单次回答结束

服务端在生成完某个问题的全部内容后，应发送一个携带结束标记的事件（如 done: true），前端收到后停止该问题的流式渲染，并展示完整回答。若缺少明确的结束信号，前端只能依赖超时判断，体验较差。

// 服务端：发送结束事件 emitter.emit('sse', { questionId, delta: '', done: true, finishReason: 'stop' // 可选：stop / length / error });

整个对话回合结束

当用户明确表示结束对话（如输入「结束」「退出」），或服务端判定任务已完成时，应发送一个回合级结束事件。前端收到后可以关闭连接、清理状态，并提示用户本次会话已结束。

// 服务端：回合结束事件 emitter.emit('sse', { type: 'session_end', reason: 'user_exit', summary: '本次对话共完成 3 个问题' });

需要特别注意的是，结束事件与普通回答事件应使用不同的字段或类型标识，避免前端混淆。同时，服务端在发送结束事件后应主动关闭 SSE 连接，释放资源。

5. 完整流程示例

下面整合上述要点，给出一个完整的 SSE 回答式生成流程示意：

// 服务端：完整 SSE 回答式生成流程 const http = require('http'); http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/event-stream', 'Cache-Control': 'no-cache', 'Connection': 'keep-alive' }); // 1. 接收用户输入，拆分问题 const rawInput = '什么是 SSE？如何结束提问？'; const questions = splitQuestions(rawInput); // 2. 逐个问题流式回答 questions.forEach((q, idx) => { const questionId = `q-${Date.now()}-${idx}`; const tokens = q.split(' '); let i = 0; const timer = setInterval(() => { if (i < tokens.length) { res.write(`data: ${JSON.stringify({ questionId, delta: tokens[i] + ' ', done: false })}\n\n`); i++; } else { res.write(`data: ${JSON.stringify({ questionId, delta: '', done: true })}\n\n`); clearInterval(timer); } }, 200); }); // 3. 全部回答结束后，发送回合结束事件并关闭连接 setTimeout(() => { res.write(`data: ${JSON.stringify({ type: 'session_end', reason: 'all_done' })}\n\n`); res.end(); }, questions.length * 200 * 10); }).listen(3000);

前端收到事件后，根据 questionId 将 delta 追加到对应问题气泡，收到 done: true 后结束该问题的渲染，收到 session_end 后关闭连接并清理界面状态。