当前位置: 首页 > news >正文

RestTemplate实时接收Chunked编码传输的HTTP Response

学习调用AI接口的时候,流式响应都是使用的 Transfer-Encoding: chunked,图方便想用RestTemplate,但是平时用到的都是直接返回响应对象的类型。使用bing搜索到一种方式,使用下面的代码来读取,于是掉这个坑里了,浪费了我好长时间。

ResponseEntity<Resource> responseEntity = restTemplate.exchange(apiUrl, HttpMethod.POST, requestEntity, org.springframework.core.io.Resource.class);
PrintWriter writer = httpServletResponse.getWriter();
BufferedReader bufferedReader;
try {bufferedReader = new BufferedReader(new InputStreamReader(responseEntity.getBody().getInputStream()));String line;while ((line = bufferedReader.readLine()) != null && !(ChatGpt3dot5Request.STREAM_MESSAGE_PREFIX + "[DONE]").equals(line)) {String message = getMessageFromLine(line, ChatGpt3dot5Request.STREAM_MESSAGE_PREFIX);writer.write(message);writer.flush();}
} catch (IOException e) {throw new RuntimeException(e);
}

注意,上面的代码是错误的,并不会实时读取到数据,而是会等到响应全结束之后才能读取到数据。


下面的才是正解:

restTemplate.execute(apiUrl, HttpMethod.POST, restTemplate.httpEntityCallback(requestEntity), new ResponseExtractor<ClientHttpResponse>() {@Overridepublic ClientHttpResponse extractData(ClientHttpResponse response) throws IOException {InputStream inputStream = response.getBody();/** 在这个地方从inputStream中读取数据,或者调用自己的方法读取inputStream来处理数据*/return response;}
});

http://www.lryc.cn/news/506466.html

相关文章:

  • GIT区域介绍及码云+GIt配置仓库
  • 网络安全怎么学习
  • PugiXML,一个高效且简单的 C++ XML 解析库!
  • Linux设备树的驱动开发
  • 连锁?下沉?AI?2025年餐饮新活力!
  • Javascript中如何实现函数缓存?函数缓存有哪些应用场景?
  • 子页面访问父页面
  • 芯片级IO (Pad) Ring IP Checklist
  • 计算机毕业设计论文指导
  • Electron-Vue 开发下 dev/prod/webpack server各种路径设置汇总
  • Vue.js前端框架教程9:Vue插槽slot用法
  • 初学stm32 --- NVIC中断
  • Jest 入门指南:从零开始编写 JavaScript 单元测试
  • 【Java Web】Axios实现前后端数据异步交互
  • React 第十七节 useMemo用法详解
  • 鸿蒙项目云捐助第十五讲云数据库的初步使用
  • 如何构建一个可信的联邦RAG系统。
  • 【深度学习之三】FPN与PAN网络详解
  • Qt学习笔记第71到80讲
  • 以管理员身份运行
  • 用 Python 实现井字棋游戏
  • 06 实现自定义AXI DMA驱动
  • SpringBoot集成ENC对配置文件进行加密
  • 初学stm32 ——— 串口通信
  • qwt 多Y轴 项目效果
  • Java中通过ArrayList扩展数组
  • Java:链接redis报错:NoSuchElementException: Unable to validate object
  • datasets库之load_dataset
  • React Router常见面试题目
  • sequelize-cli 封装登录接口