鸿蒙HarmonyOS Next和安卓、IOS实现方式不一样鸿蒙需要使用鸿蒙内置的ohos.net.http数据请求去实现但在vue的js中引入ohos.net.http会报错没有这个模块所以鸿蒙需要通过 UTS 插件的形式在 uni-app 框架内调用ohos.net.http文档文档中心实现步骤1、创建UTS插件目录uni_modules/harmony-stream插件名称自定义/utssdk/app-harmony特定结构不要修改插件主要代码在uni_modules/harmony-stream/utssdk/app-harmony/index.uts代码中就是通过使用鸿蒙特定的模块ohos.net.http和ohos.util去实现数据流式输出import http from ohos.net.http; import util from ohos.util; type StreamRequestOptions { url: string; method?: GET | POST | PUT | DELETE; body?: any; headers?: Recordstring, string; onChunk: (chunk: string) void; onDone: () void; onError: (err: string) void; }; export function startStreamRequest(options: StreamRequestOptions) { let httpRequest http.createHttp(); httpRequest.on(dataReceive, (data: ArrayBuffer) { try { let decoder util.TextDecoder.create(utf-8); let chunk decoder.decodeToString(new Uint8Array(data)); options.onChunk(chunk); } catch (e) { options.onError(解码失败); } }); httpRequest.on(dataEnd, () { options.onDone(); httpRequest.off(dataReceive); httpRequest.off(dataEnd); httpRequest.destroy(); }); let extraData: string; if (typeof options.body string) { extraData options.body; } else { extraData JSON.stringify(options.body || {}); } let headers: Recordstring, string { Content-Type: application/json }; if (options.headers) { headers { ...headers, ...options.headers }; } let methodMap: Recordstring, http.RequestMethod { GET: http.RequestMethod.GET, POST: http.RequestMethod.POST, PUT: http.RequestMethod.PUT, DELETE: http.RequestMethod.DELETE }; let method methodMap[options.method || POST] || http.RequestMethod.POST; // 打印调试信息 console.log( 请求信息 ); console.log(URL:, options.url); console.log(Method:, options.method || POST); console.log(Headers:, JSON.stringify(headers)); console.log(Body:, extraData); console.log(); interface RequestConfig { method: http.RequestMethod; header: Recordstring, string; extraData: string; } let config: RequestConfig { method: method, header: headers, extraData: extraData }; httpRequest.requestInStream( options.url, config, (err: Error | null) { if (err) { console.log(请求错误:, err); options.onError(请求失败: err.message); httpRequest.off(dataReceive); httpRequest.off(dataEnd); httpRequest.destroy(); } } ); }插件信息在uni_modules/harmony-stream下增加package.json和utssdk同级{ name: harmony-stream, version: 1.0.0, description: 鸿蒙流式请求 UTS 插件, main: index.uts, uni_modules: { platforms: { app-harmony: { plugins: [ { name: harmony-stream, class: index } ] } } } }2、Vue中使用部分参数说明代码中有注释script setup langts import { startStreamRequest } from /uni_modules/harmony-stream; // 发送消息 const sendMsg async () { // 同样根据接口获取ai需要token await AiApi.getAiToken({ mini_user_id, }).then(res { // 简化版数据处理 // 完整内容 let fullContent // 是否已完成 let isCompleted false // 更新AI消息内容 const updateAIContent (content: string, done: boolean false) { if (done) { // 最终完成时直接用完整内容 // fullContent就是AI返回结束后返回的整体内容 } else if (content) { // 增量更新每次返回叠加后的内容 // content就是AI返回的内容 } } // 处理SSE数据块 const processChunk (chunk: string) { // 如果已经完成忽略后续数据 if (isCompleted) return try { // 按行分割 const lines chunk.split(\n) let currentEvent let currentData for (let i 0; i lines.length; i) { const line lines[i].trim() if (line.startsWith(event:)) { currentEvent line.replace(event:, ).trim() } else if (line.startsWith(data:)) { currentData line.replace(data:, ).trim() // 有 event 和 data 配对处理数据 if (currentEvent currentData) { handleSSEMessage(currentEvent, currentData) // 重置准备接收下一组 currentEvent currentData } } } // 如果最后有残留的 data 但没有 event可能是 ping 或其他 if (!currentEvent currentData) { // 尝试直接解析 try { const parsed JSON.parse(currentData) if (parsed.content) { const contentText String(parsed.content) const decoded contentText.replace(/\\n/g, \n) fullContent decoded updateAIContent(fullContent) } } catch (e) { // 忽略 } } } catch (e) { console.log(处理数据块出错:, e) } } // 处理单个 SSE 消息 const handleSSEMessage (event: string, data: string) { try { // 跳过 ping 心跳 if (event ping) return // 解析 JSON const parsed JSON.parse(data) // 处理增量消息 if (event conversation.message.delta) { if (parsed.content) { const contentText String(parsed.content) // 处理换行符 const decoded contentText.replace(/\\n/g, \n) fullContent decoded updateAIContent(fullContent) } } // 处理完成消息包含完整内容和 time_cost if (event conversation.message.completed) { if (parsed.content) { // 直接用完整内容替换 const finalContent String(parsed.content).replace(/\\n/g, \n) fullContent finalContent isCompleted true updateAIContent(fullContent, true) } } // 处理对话完成 if (event conversation.chat.completed) { // 如果还没完成用之前累积的内容 if (!isCompleted fullContent) { isCompleted true updateAIContent(fullContent, true) } } // 处理 [DONE] if (event done) { if (!isCompleted fullContent) { isCompleted true updateAIContent(fullContent, true) } } } catch (e) { console.log(解析SSE消息失败:, e) } } // 发起流式请求 startStreamRequest({ url: https://xxx/getAnswerStream/sse, method: POST, headers: { Token: res.data.token, Content-Type: application/json }, body: JSON.stringify({ query: inputValue.value, userId: mini_user_id, }), onChunk: (chunk: any) { console.log(收到原始数据:, chunk) processChunk(chunk) }, onDone: () { console.log(流式请求完成) // 如果还没完成强制完成 if (!isCompleted fullContent) { isCompleted true updateAIContent(fullContent, true) } else if (!fullContent) { // 如果没收到任何内容显示提示 } }, onError: (errMsg: any) { console.error(流式请求出错:, errMsg) } }) }) } /script