chatGPT流式输出前端实现fetch、SSE、websocket
创始人
2024-12-28 06:37:48
0次

一、fetch实现stream

fetch 本身不直接支持流式输出,但你可以使用 ReadableStream 和 TextDecoder 等 Web Streams API 来实现类似的效果。

function streamOutput(msg) {   // 发送 POST 请求   fetch('url', {     method:"POST",     body:JSON.stringify({ "content": msg}),     timeout: 0,     dataType:"text/event-stream",     headers:{       "Content-Type":"application/json"     },   }).then(response => {     // 检查响应是否成功     if (!response.ok) {       throw new Error('Network response was not ok');     }     // 返回一个可读流     return response.body;   }).then(body => {     disableLoading();     const reader = body.getReader();     // 读取数据流     function read() {       return reader.read().then(({ done, value }) => {         // 检查是否读取完毕         if (done) {           console.log('已传输完毕');           return;         }         // 处理每个数据块         console.log('收到的数据:', value);                  // 继续读取下一个数据块         read();       });     }     // 开始读取数据流     read();   }).catch(error => {console.error('Fetch error:', error);}); } 

二、SSE实现(只支持GET请求)

在 SSE 中,浏览器通过发送 HTTP GET 请求到服务器上特定的 SSE 端点(endpoint),然后服务器通过该连接发送事件(event)和相关数据到客户端,故SSE 主要使用 GET 请求。EventSource不支持发送请求头,如果需要发送请求头则要用EventSourcePolyfill。

在使用EventSourcePolyfill前需要引入 Server-Sent Events (SSE) 的 JavaScript 库。

引入方式一:npm或yarn

npm install event-source-polyfill 
yarn add event-source-polyfill 

在js文件中引入

import EventSource from 'event-source-polyfill'; 

引入方式二:
eventsource下载仓库:https://github.com/Yaffle/EventSource
注意:进入src文件下载所需eventsource.js或eventsource.min.js文件,引入时注意路径,如果是jsp文件用绝对路径

 
function streamOutput() { 	  // 创建 EventSourcePolyfill连接,如果不需要发送请求头可以使用EventSource即可 	const eventSource = new EventSourcePolyfill('url',{ 		headers:{       		"Content-Type":"application/json"     	} 	}); 	 	// 处理 SSE 消息 	eventSource.onmessage = function (event) { 	  console.log('接收SSE的消息:', event.data); 	  // 在这里处理接收到的流式数据 	}; 	 	// 处理 SSE 连接打开事件 	eventSource.onopen = function (event) { 	  console.log('SSE连接完成:', event); 	}; 	 	// 处理 SSE 连接关闭事件 	eventSource.onclose = function (event) { 	  console.log('SSE连接关闭:', event); 	}; 	 	// 处理 SSE 错误事件 	eventSource.onerror = function (error) { 	  console.error('SSE EventSource error:', error); 	}; } 

三、websocket实现(url必须为ws或wss开头的接口)

WebSocket 是一种全双工通信协议,允许客户端和服务器之间进行实时的双向通信,并且支持POST请求。但是值得注意的是WebSocket只支持ws或wss开头的接口。WebSocket 握手时并没有提供直接设置请求头的标准方法,它的握手阶段是由浏览器自动处理的,因此你不能直接在创建 WebSocket 连接时设置请求头,但可以通过通过 URL 参数传递的方式传递信息。

function streamOutput(msg) { 	 const socket = new WebSocket('url'); 	 	// 连接打开时触发 	socket.addEventListener('open', event => { 	  console.log('WebSocket连接完成:', event); 	 	  // 处理接收到的消息 	  socket.addEventListener('message', event => { 	    console.log('接收消息:', event.data); 	    // 在这里处理接收到的流式数据 	  }); 	}); 	 	// 连接关闭时触发 	socket.addEventListener('close', event => { 	  console.log('WebSocket连接关闭:', event); 	}); 	 	// 处理错误时触发 	socket.addEventListener('error', error => { 	  console.error('WebSocket error:', error); 	}); } 

相关内容

热门资讯

玩家必备科普透视挂!祺友互娱透... 玩家必备科普透视挂!祺友互娱透视挂多功能AIapp,祺友互娱都是有透视挂app1、下载好祺友互娱透视...
2024教程外挂!闲逸斗地主外... 2024教程外挂!闲逸斗地主外挂多功能AI方法,闲逸斗地主本来是有外挂方法1、让任何用户在无需闲逸斗...
玩家必看科普外挂!久久互娱外挂... 玩家必看科普外挂!久久互娱外挂多功能AI插件,久久互娱一直是有外挂插件1、久久互娱免费辅助多个强度级...
重大推荐开挂!新老夫子开挂多功... 重大推荐开挂!新老夫子开挂多功能AI技巧,新老夫子好像有开挂技巧1、让任何用户在无需新老夫子安装教程...
分享认知透视挂!君悦来透视挂多... 分享认知透视挂!君悦来透视挂多功能AI工具,君悦来确实真的是有透视挂工具1、起透看视 君悦来辅助软件...
专业讨论外挂!微乐广西麻将外挂... 专业讨论外挂!微乐广西麻将外挂多功能AI软件,微乐广西麻将其实存在有外挂软件亲,关键说明,微乐广西麻...
盘点一款作弊器!玄龙大厅作弊器... 盘点一款作弊器!玄龙大厅作弊器多功能AI工具,玄龙大厅竟然真的有作弊器工具1、实时玄龙大厅透视辅助更...
每日必看辅助!MG棋牌辅助多功... 每日必看辅助!MG棋牌辅助多功能AI教程,MG棋牌切实真的有辅助教程1、进入到MG棋牌是否有挂之后,...
玩家必备科普开挂!南京麻将开挂... 玩家必备科普开挂!南京麻将开挂多功能AI软件,南京麻将确实存在有开挂软件1、该软件可以轻松地帮助玩家...
专业讨论外挂!欢乐茶馆外挂多功... 专业讨论外挂!欢乐茶馆外挂多功能AIapp,欢乐茶馆真是是真的有外挂app欢乐茶馆破解侠是真的助透视...