需自建代理将千问api转为sse流:后端设text/event-stream响应头、逐块发送data:文本;前端用eventsource监听并实现逐字打字机渲染,或用fetch+readablestream支持post与自定义头。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜

如果您在使用千问的API时希望实现流式SSE(Server-Sent Events)输出,并在前端呈现打字机效果,则需后端按SSE协议逐块推送文本片段,前端通过EventSource监听并增量渲染。以下是具体实现方式:
一、后端启用SSE响应格式
千问API本身不原生暴露SSE接口,需通过自建代理服务将标准HTTP请求转换为SSE流式响应。服务需设置正确响应头,持续写入以data:开头、以\n\n分隔的事件块,并保持连接不关闭,直到响应完成。
1、配置HTTP响应头:Content-Type设为text/event-stream;Cache-Control设为no-cache;Connection设为keep-alive。
2、构造SSE数据块:每段文本前添加data:前缀,末尾追加两个换行符\n\n,例如data:你好\n\n。
3、禁用响应体缓冲:在Node.js中调用res.flush()或设置res.socket.setNoDelay(true);在Python Flask中使用yield配合response.stream并禁用wsgi.server软件缓冲。
二、前端建立EventSource连接
浏览器通过EventSource API建立长连接,自动重连并解析SSE数据流。该方式仅支持GET请求,且无法携带认证凭据(如Cookie或Authorization头)除非显式配置withCredentials。
1、创建EventSource实例:const es = new EventSource('/api/chat-stream', { withCredentials: true });
2、监听message事件:es.addEventListener('message', event => { const chunk = event.data; appendToDisplay(chunk); });
3、处理连接错误:监听error事件,检查es.readyState值,0表示未连接,1表示正在连接,2表示已连接;若长时间为0或1,可手动调用es.close()后重建。
三、前端实现逐字打字机渲染
接收到的每个data块可能包含多个字符甚至整句,需将其拆解为单字符或按语义单位(如中文词、标点)逐步插入DOM,配合setTimeout或requestAnimationFrame控制节奏,避免阻塞主线程。
1、获取当前显示容器元素:const outputEl = document.getElementById('output');
2、定义打字函数:function typeText(text, index = 0) { if (index typeText(text, index + 1)); } }
3、在message回调中调用:event.data非空时,执行typeText(event.data),注意需维护全局累计文本变量以避免重复追加。
四、使用fetch+ReadableStream替代EventSource
当需要POST请求、自定义headers或更精细流控时,可用fetch配合Response.body.getReader()读取流式响应。此方式绕过SSE协议解析,直接处理原始字节流,兼容性要求Chrome 68+/Firefox 65+。
1、发起fetch请求:fetch('/api/chat-stream', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ prompt: '你好' }) })
2、获取Reader并循环读取:const reader = response.body.getReader(); async function read() { const { done, value } = await reader.read(); if (done) return; const decoder = new TextDecoder('utf-8'); const chunk = decoder.decode(value); appendChunkAsTyping(chunk); await read(); }
3、处理粘包与分块:服务端应确保每个write()调用对应一个语义完整片段,前端需缓存未闭合的UTF-8多字节序列,避免解码乱码。
五、处理中断与状态同步
流式传输过程中用户可能取消请求、切换页面或网络中断,前端需主动清理资源并还原UI状态,防止残留loading态或错乱文本。
1、绑定页面卸载监听:window.addEventListener('beforeunload', () => { if (es) es.close(); if (abortController) abortController.abort(); });
2、点击停止按钮时:调用es.close()或abortController.abort(),同时清空outputEl内容并置灰操作按钮。
3、检测服务端结束信号:约定服务端最后发送data:[DONE]\n\n,前端监听到该字符串后执行收尾逻辑,不可依赖event.data为空判断流结束。
前端入门到VUE实战笔记:立即使用
在学习笔记中,你将探索 前端 的入门与实战技巧!







