uniapp使用ui.request 请求流式输出

news2025/7/17 6:32:30

正文:

        在现代Web开发中,实时数据流和长时间运行的请求变得越来越常见,尤其是在处理大量数据或进行实时通信时。在这种情况下,uniapp 提供的 ui.request 请求方法可以帮助我们轻松实现流式输出请求。本文将介绍如何使用 uni.request 来实现流式数据请求,并处理实时返回的数据。

一、项目背景

        假设你正在开发一款移动端应用,其中需要向服务器发起请求,获取大量文本数据,并且这些数据需要逐步输出,而不是一次性返回所有结果。这时候,流式请求是一个非常理想的解决方案,它可以在数据准备好后立即传输,而不需要等待完整的数据返回。

二、核心代码解析

        在本篇博客中,我们将分享一个典型的实现流式请求的代码示例,帮助大家理解如何在 uniapp 中使用 ui.request 实现流式输出。

const requestTask = uni.request({
  url: '这是你的接口',
  method: 'post',
  header: {},
  enableChunked: true,  // 启用分块传输
  responseType: 'text', // 响应类型为文本
  data: {},
  success: (res) => {
    console.log(res, '文本');
  },
  fail: (err) => {
    console.error('请求失败:', err);
  }
});

// 处理流式输出
requestTask.onChunkReceived((res) => {
  this.xianshi_tt = false
   //用来解析
  let uint8Array = new TextDecoder('utf-8')
  let decodedString = uint8Array.decode(res.data)
  let dataList = decodedString.split('\n\n')
  dataList.forEach((item) => {
    if (item) {
      let gg = JSON.parse(item.replace('data:', ''));
      let content = gg.choices[0]..reasoning_content;
      // 检查 content 是否有效并且不为空
      if (content && content !== "" && content !== undefined) {
        // 检查 content 是否已经存在于 streamData 中,防止重复
        if (!this.streamData.includes(content)) {
          this.streamData.push(content);
        }
      }
    }
  })
  // 转换数组为字符串
  this.wenan_content = this.streamData.join(''); // 将数组转化为换行分隔的字符串
});

三、关键参数解析

1. enableChunked: true

在进行流式数据请求时,enableChunked: true 是一个非常关键的配置项。它允许我们启用 HTTP 分块传输(Chunked Transfer Encoding),这样服务器可以在数据准备好时就开始传输,而不必等到整个响应完成。

2. responseType: 'text'

responseType: 'text' 指定了我们接收的数据类型为文本格式。通常在处理流式输出时,文本数据会更容易进行解析和处理。

3. onChunkReceived

流式输出的处理主要通过 onChunkReceived 方法来实现。每当服务器发送新的数据块时,这个回调函数就会被触发,里面的逻辑会逐步接收和处理这些数据。

  • TextDecoder 是用来将 Uint8Array 数据解码为字符串的工具。在处理流式数据时,我们会获取到分块的字节流,需要将其解码为字符串以便进一步操作。
  • 数据被解码后,通过 split('\n\n') 将文本按段落进行拆分,每一段数据都会被处理。
4. 数据处理逻辑

我们从 gg.choices[0]..reasoning_content 中提取出需要的文本数据,然后进行一系列的检查:

  • 确保内容有效(非空且未定义)。
  • 确保内容没有重复。

最后,通过 this.streamData.push(content) 将内容添加到 streamData 数组中,形成完整的文本内容。

5. 拼接字符串

所有有效的内容都被存储在 this.streamData 数组中。在数据流逐步输出的过程中,最终会通过 this.wenan_content = this.streamData.join(''); 将数组中的所有内容拼接成一个完整的字符串,从而实现流式输出。

四、流式请求的优势

  1. 提高响应速度: 流式请求允许客户端在数据逐步返回的过程中即时获取并处理数据,而不需要等待完整的数据返回。
  2. 减少内存占用: 不需要将所有数据一次性加载到内存中,而是分批处理,可以有效减小内存压力。
  3. 实时显示: 对于用户而言,流式输出可以实现数据的实时显示,提升用户体验。

五、总结

通过 uniapp 中的 ui.request 配合 enableChunked: true 配置,我们可以非常方便地实现流式输出请求。这种方法适用于需要实时获取和显示大量数据的应用场景,能够显著提高应用的响应速度和用户体验。希望本文的代码示例和解析能帮助你更好地理解流式请求的实现与应用。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2373543.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

20250506让NanoPi NEO core开发板使用Ubuntu core16.04系统的TF卡启动

1、h3-sd-friendlycore-xenial-4.14-armhf-20210618.img.gz 在WIN10下使用7-ZIP解压缩/ubuntu20.04下使用tar 2、Win32DiskImager.exe 写如32GB的TF卡。【以管理员身份运行】 3、TF卡如果已经做过会有3个磁盘分区,可以使用SD Card Formatter/SDCardFormatterv5_WinE…

快速上手 Docker:从入门到安装的简易指南(Mac、Windows、Ubuntu)

PS:笔者在五一刚回来一直搞Docker部署AI项目,发现从开发环境迁移到生成环境时,Docker非常好用。但真的有一定上手难度,推荐读者多自己尝试踩踩坑。 本篇幅有限,使用与修改另起篇幅。 一、Docker是什么 #1. Docker是什…

MySQL + Elasticsearch:为什么要使用ES,使用场景与架构设计详解

MySQL Elasticsearch:为什么要使用ES,使用场景与架构设计详解 前言一、MySQL Elasticsearch的背景与需求1.1 为什么要使用Elasticsearch(ES)?1.2 为什么MySQL在某些场景下不足以满足需求?1.3 MySQL Elas…

从投入产出、效率、上手难易度等角度综合对比 pytest 和 unittest 框架

对于选择python作为测试脚本开发的同学来说,pytest和python unittest是必需了解的两个框架。那么他们有什么区别?我们该怎么选?让我们一起来了解一下吧! 我们从投入产出、效率、上手难易度等角度综合对比 pytest 和 unittest 框架…

关于汇编语言与程序设计——单总线温度采集与显示的应用

一、实验要求 (1)握码管的使用方式 (2)掌握DS18B20温度传感器的工作原理 (3)掌握单总线通信方式实现 MCU与DS18B20数据传输 二、设计思路 1.整体思路 通过编写数码管显示程序和单总线温度采集程序,结合温度传感报警,利用手指触碰传感器,当…

spring中的@Inject注解详情

在 Spring 框架中,Inject 是 Java 依赖注入标准(JSR-330) 的核心注解,与 Spring 原生的 Autowired 类似,但具备更标准化的跨框架特性。以下从功能特性、使用场景及与 Spring 原生注解的对比进行详细解析: 一…

Vue基础(8)_监视属性、深度监视、监视的简写形式

监视属性(watch): 1.当被监视的属性变化时,回调函数(handler)自动调用,进行相关操作。 2.监视的属性必须存在,才能进行监视!! 3.监视的两种写法: (1).new Vue时传入watch配置 (2).通过vm.$watc…

TCP IP

TCP/IP 通信协议,不是单一协议,是一组协议的集合 TCP IP UDP 1.建立链接 三次握手 第一步:客户端发送一个FIN报文,SEQX,等待服务器回应 第二步:服务器端受到,发送ackx1,seqy, 等待客户端回应 第三步&am…

(四)毛子整洁架构(Presentation层/Authentiacation/Authorization)

文章目录 项目地址一、Presentation 层1.1 数据库migration1. 添加数据库连接字符串2. 创建自动Migration/Seed3.修改Entity添加private 构造函数4. 执行迁移 1.2 全局错误处理中间件1.3 Controller 添加1. Apartments2. Bookings3. 测试 二、Authentiacation2.1 添加Keycloak服…

K8S服务的请求访问转发原理

开启 K8s 服务异常排障过程前,须对 K8s 服务的访问路径有一个全面的了解,下面我们先介绍目前常用的 K8s 服务访问方式(不同云原生平台实现方式可能基于部署方案、性能优化等情况会存在一些差异,但是如要运维 K8s 服务,…

20250510解决NanoPi NEO core开发板在Ubuntu core22.04.3系统下适配移远的4G模块EC200A-CN的问题

1、h3-eflasher-friendlycore-jammy-4.14-armhf-20250402.img.gz 在WIN10下使用7-ZIP解压缩/ubuntu20.04下使用tar 2、Win32DiskImager.exe 写如32GB的TF卡。【以管理员身份运行】 3、TF卡如果已经做过会有3个磁盘分区,可以使用SD Card Formatter/SDCardFormatterv5…

Linux系统之----模拟实现shell

在前面一个阶段的学习中,我们已经学习了环境变量、进程控制等等一系列知识,也许有人会问,学这个东西有啥用?那么,今天我就和大家一起综合运用一下这些知识,模拟实现下shell! 首先我们来看一看我…

TCP黏包解决方法

1. 问题描述 TCP客户端每100ms发送一次数据,每次为16006字节的数据长度。由于TCP传输数据时,为了达到最佳传输效能,数据包的最大长度需要由MSS限定(MSS就是TCP数据包每次能够传输的最大数据分段),超过这个长度会进行自动拆包。也就是说虽然客户端一次发送16006字节数据,…

vue访问后端接口,实现用户注册

文章目录 一、后端接口文档二、前端代码请求响应工具调用后端API接口页面函数绑定单击事件,调用/api/user.js中的函数 三、参考视频 一、后端接口文档 二、前端代码 请求响应工具 /src/utils/request.js //定制请求的实例//导入axios npm install axios import …

Nginx性能调优与深度监控

目录 1更改进程数与连接数 (1)进程数 (2)连接数 2,静态缓存功能设置 (1)设置静态资源缓存 (2)验证静态缓存 3,设置连接超时 4,日志切割 …

如何在大型项目中解决 VsCode 语言服务器崩溃的问题

在大型C/C项目中,VS Code的语言服务器(如C/C扩展)可能因内存不足或配置不当频繁崩溃。本文结合系统资源分析与实战技巧,提供一套完整的解决方案。 一、问题根源诊断 1.1 内存瓶颈分析 通过top命令查看系统资源使用情况&#xff…

AutoDL实现端口映射与远程连接AutoDL与Pycharm上传文件到远程服务器(李沐老师的环境)

文章目录 以上配置的作用前提AutoDL实现端口映射远程连接AutoDLPycharm上传文件到远程服务器以上配置的作用 使用AutoDL的实例:因本地没有足够强的算力,所以需要使用AutoDL AutoDL端口映射:当在实例上安装深度学习的环境,但因为实例的linux系统问题,无法图形化显示d2l中的文件…

13.thinkphp的Session和cookie

一.Session 1. 在使用Session之前,需要开启初始化,在中间件文件middleware.php; // Session 初始化 \think\middleware\SessionInit::class 2. TP6.0不支持原生$_SESSION的获取方式,也不支持session_开头的函数&…

多线程获取VI模块的YUV数据

一.RV1126 VI模块采集摄像头YUV数据的流程 step1:VI模块初始化 step2:启动VI模块工作 step3:开启多线程采集VI数据并保存 1.1初始化VI模块: VI模块的初始化实际上就是对VI_CHN_ATTR_S的参数进行设置、然后调用RK_MPI_VI_SetC…

[ctfshow web入门] web68

信息收集 highlight_file被禁用了,使用cinclude("php://filter/convert.base64-encode/resourceindex.php");读取index.php,使用cinclude("php://filter/convert.iconv.utf8.utf16/resourceindex.php");可能有些乱码,不…