百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

SpringBoot应用中下载文件的3种实现方式

csdh11 2025-05-05 14:53 1 浏览

1、背景

用户需要从第三方文件服务系统下载文件,后端代理提供一个三方文件服务系统的下载接口。在使用SpringBoot开发的应用中,一般会使用RestTemplate客户端请求第三方的下载文件接口,将文件返回给前端用户。

2、什么是RestTemplate

RestTemplate是Spring框架中提供的一个用于发送HTTP请求的类,它简化了与RESTful Web服务的交互。使用RestTemplate,可以发送GET、POST、PUT、DELETE等HTTP请求,并获取HTTP响应。它可以处理请求和响应中的JSON、XML等数据格式,并支持数据类型转换和错误处理。

RestTemplate的主要作用是封装HTTP通信的细节,开发人员只需要关注业务逻辑即可。

3、使用RestTemplate下载文件

下面的3种实现方式,不同的方式各有优缺点。

3.1、方式1:内存中转下载

这种方式只适合小文件和并发量小的场景,如果文件较大,可能导致内存消耗较大,因为接口会先把文件从第三方完整下载到SpringBoot微服务的内存,再写出到客户端的响应输出流中。

import java.io.IOException;

/**
 * 文件下载示例:使用restTemplate请求第三方文件服务下载文件
 *
 * @author Bruce.CH
 * @since 2023年9月2日
 */
@RestController
public class FileController {
    private static final Logger LOGGER = LoggerFactory.getLogger(FileController.class);

    /**
     * 第三方文件服务下载接口
     */
    private static final String DOWNLOAD_URL = "http://127.0.0.1:8080/v1/file/server/download/{fileId}";

    /**
     * 注入restTemplate对象
     */
    @Resource
    private RestTemplate restTemplate;

    /**
     * 【方式1】
     * 请求第三方文件服务下载接口下载文件id指定的文件:字节流先保存到本地的字节数组中,再写入到响应的输出流
     *
     * @param fileId 第三方文件id
     * @param response 客户端响应
     * @throws IOException IO异常
     */
    @GetMapping("/v1/file/download/{fileId}")
    public void download(@PathVariable("fileId") String fileId, HttpServletResponse response) throws IOException {
        LOGGER.info("download file:{}", fileId);
        Map<String, String> uriVariables = new HashMap<>();
        uriVariables.put("fileId", fileId);
        // 响应类型不支持InputStream类型,使用Resource或byte[]接收三方文件服务返回的文件字节流
        ResponseEntity<byte[]> responseEntity = restTemplate.exchange(DOWNLOAD_URL, HttpMethod.GET, null,
                byte[].class, uriVariables);
        // 设置请求头,直接用第三方文件服务的响应头
        HttpHeaders headers = responseEntity.getHeaders();
        headers.forEach((key, value) -> response.setHeader(key, value.get(0)));
        // 获取整个文件内容的字节数组后拷贝写入到输出流: inputStream -> byte[] -> outputStream
        StreamUtils.copy(responseEntity.getBody(), response.getOutputStream());
        LOGGER.info("download file success");
    }
}

3.2、方式2:临时文件中转下载

这种方式,如果文件较大,响应时间会比较满,但可以减少内存的消耗,因为接口会先把文件从第三方完整下载保存到本地临时文件,然后再从临时文件读取内容写出到客户端的响应输出流中。对响应时间要求不严格的,可以使用这种方式。

/**
 * 文件下载示例:使用restTemplate请求第三方文件服务下载文件
 *
 * @author Bruce.CH
 * @since 2023年9月2日
 */
@RestController
public class FileController {
    private static final Logger LOGGER = LoggerFactory.getLogger(FileController.class);

    /**
     * 第三方文件服务下载接口
     */
    private static final String DOWNLOAD_URL = "http://127.0.0.1:8080/v1/file/server/download/{fileId}";

    /**
     * 注入restTemplate对象
     */
    @Resource
    private RestTemplate restTemplate;

    /**
     * 【方式2】
     * 请求第三方文件服务下载接口下载文件id指定的文件:收到响应即时保存到临时文件,然后再读取临时文件内容写出到客户端的响应输出流中
     *
     * @param fileId 第三方文件id
     * @param response 客户端响应
     */
    @GetMapping("/v1/file/download2/{fileId}")
    public void download2(@PathVariable("fileId") String fileId, HttpServletResponse response) {
        LOGGER.info("download file:{}", fileId);
        Map<String, String> uriVariables = new HashMap<>();
        uriVariables.put("fileId", fileId);
        ResponseExtractor<Boolean> responseExtractor = clientHttpResponse -> {
            // 获取文件名称
            HttpHeaders headers = clientHttpResponse.getHeaders();
            ContentDisposition contentDisposition = headers.getContentDisposition();
            String filename = contentDisposition.getFilename();
            File tmpFile = new File("D:\\temp\\download\\tmp\\" + UUID.randomUUID() + "\\" + filename);
            try {
                // 1、先保存到临时文件
                boolean mkdirs = tmpFile.getParentFile().mkdirs();
                LOGGER.info("mk tmp file dirs? {}", mkdirs);
                StreamUtils.copy(clientHttpResponse.getBody(), new FileOutputStream(tmpFile));

                // 直接用第三方文件服务的响应头
                headers.forEach((key, value) -> response.setHeader(key, value.get(0)));
                // 2、读取临时文件内容写出到响应输出流中: inputStream -> tmpFile -> outputStream
                StreamUtils.copy(new FileInputStream(tmpFile), response.getOutputStream());
            } finally {
                // 3、清理临时文件和UUID目录
                if (tmpFile.exists()) {
                    boolean delete = tmpFile.delete();
                    boolean deleteDir = tmpFile.getParentFile().delete();
                    LOGGER.info("tmp file delete ? {}", delete && deleteDir);
                }
            }
            return true;
        };
        Boolean execute = restTemplate.execute(DOWNLOAD_URL, HttpMethod.GET, null, responseExtractor, uriVariables);
        LOGGER.info("download file success?{}", execute);
    }
}

3.3、方式3:缓冲区中转下载

对比前面的两种方式,方式3整体性能较好,因为接口会从第三方文件服务的响应后,立即读取输入流,将输入流中的文件内容直接写出到客户端的响应输出流中。

/**
 * 文件下载示例:使用restTemplate请求第三方文件服务下载文件
 *
 * @author Bruce.CH
 * @since 2023年9月2日
 */
@RestController
public class FileController {
    private static final Logger LOGGER = LoggerFactory.getLogger(FileController.class);

    /**
     * 第三方文件服务下载接口
     */
    private static final String DOWNLOAD_URL = "http://127.0.0.1:8080/v1/file/server/download/{fileId}";

    /**
     * 注入restTemplate对象
     */
    @Resource
    private RestTemplate restTemplate;
    
    /**
     * 【方式3】
     * 请求第三方文件服务下载接口下载文件id指定的文件:字节流直接绑定到响应的输出流中
     *
     * @param fileId 第三方文件id
     * @param response 客户端响应
     */
    @GetMapping("/v1/file/download3/{fileId}")
    public void download3(@PathVariable("fileId") String fileId, HttpServletResponse response) {
        LOGGER.info("download file:{}", fileId);
        Map<String, String> uriVariables = new HashMap<>();
        uriVariables.put("fileId", fileId);
        ResponseExtractor<Boolean> responseExtractor = clientHttpResponse -> {
            // 设置响应头,直接用第三方文件服务的响应头
            HttpHeaders headers = clientHttpResponse.getHeaders();
            headers.forEach((key, value) -> response.setHeader(key, value.get(0)));
            // 收到响应输入流即时拷贝写出到响应输出流中: inputStream -> outputStream
            StreamUtils.copy(clientHttpResponse.getBody(), response.getOutputStream());
            return true;
        };
        Boolean execute = restTemplate.execute(DOWNLOAD_URL, HttpMethod.GET, null, responseExtractor, uriVariables);
        LOGGER.info("download file success?{}", execute);
    }
}

4、小结

以上3种SpringBoot应用中使用RestTemplate下载文件的方式中,各有优缺点,推荐方式优先顺序为:方式3 > 方式2 > 方式1。

相关推荐

NUS邵林团队发布DexSinGrasp基于强化学习实现物体分离与抓取统一

本文的作者均来自新加坡国立大学LinSLab。本文的共同第一作者为新加坡国立大学实习生许立昕和博士生刘子轩,主要研究方向为机器人学习和灵巧操纵,其余作者分别为硕士生桂哲玮、实习生郭京翔、江泽宇以及...

「PLC进阶」如何通过编写SCL语言程序实现物料分拣?

01、前言SCL作为IEC61131-3编程语言的一种,由于其高级语言的特性,特别适合复杂运算、复杂数学函数应用的场合。本文以FactoryIO软件中的物料分拣案例作为硬件基础,介绍如何通过SCL来实...

zk源码—5.请求的处理过程一(http1.1请求方法)

大纲1.服务器的请求处理链...

自己动手从0开始实现一个分布式 RPC 框架

前言为什么要自己写一个RPC框架,我觉得从个人成长上说,如果一个程序员能清楚的了解RPC框架所具备的要素,掌握RPC框架中涉及的服务注册发现、负载均衡、序列化协议、RPC通信协议、Socket通信、异...

MLSys’25 | 极低内存消耗:用SGD的内存成本实现AdamW的优化性能

AIxiv专栏是机器之心发布学术、技术内容的栏目。过去数年,机器之心AIxiv专栏接收报道了2000多篇内容,覆盖全球各大高校与企业的顶级实验室,有效促进了学术交流与传播。如果您有优秀的工作想要分享,...

线程池误用导致系统假死(线程池会自动销毁吗)

背景介绍在项目中,为了提高系统性能使用了RxJava实现异步方案,其中异步线程池是自建的。但是当QPS稍微增大之后却发现系统假死、无响应和返回,调用方出现大量超时现象。但是通过监控发现,系统线程数正常...

大型乘用车工厂布局规划(六大乘用车基地)

乘用车工厂的布局规划直接影响生产效率、物流成本、安全性和未来扩展能力。合理的布局应确保生产流程顺畅、物流高效、资源优化,并符合现代化智能制造和绿色工厂的要求。以下是详细的工厂布局规划要点:1.工厂布...

西门子 S7-200 SMART PLC 连接Factory IO的方法

有很多同学不清楚如何西门子200smart如何连接FactoryIO,本教程为您提供了如何使用西门子S7-200SMARTPLC连接FactoryIO的说明。设置PC和PLC之间的...

西门子博图高级仿真软件的应用(西门子博途软件仿真)

1.博图高级仿真软件(S7-PLCSIMAdvancedV2.0)S7-PLCSIMAdvancedV2.0包含大量仿真功能,通过创建虚拟控制器对S7-1500和ET200SP控制器进行仿真...

PLC编程必踩的6大坑——请对号入座,评论区见

一、缺乏整体规划:面条式代码问题实例:某快递分拣线项目初期未做流程图设计,工程师直接开始编写传送带控制程序。后期增加质检模块时发现I/O地址冲突,电机启停逻辑与传感器信号出现3处死循环,导致项目延期2...

统信UOS无需开发者模式安装软件包
统信UOS无需开发者模式安装软件包

原文链接:统信UOS无需开发者模式安装软件包...

2025-05-05 14:55 csdh11

100个Java工具类之76:数据指纹DigestUtils

为了提高数据安全性,保证数据的完整性和真实性,DigestUtils应运而生。正确恰当地使用DigestUtils的加密算法,可以实现数据的脱敏,防止数据泄露或篡改。...

麒麟KYLINIOS软件仓库搭建02-软件仓库添加新的软件包

#秋日生活打卡季#原文链接:...

Java常用工具类技术文档(java中工具类的作用)

一、概述Java工具类(UtilityClasses)是封装了通用功能的静态方法集合,能够简化代码、提高开发效率。本文整理Java原生及常用第三方库(如ApacheCommons、GoogleG...

软路由的用法(自动追剧配置)(软路由教学)

本内容来源于@什么值得买APP,观点仅代表作者本人|作者:值友98958248861环境和需求...