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

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

yuyutoo 2025-05-08 07:45 11 浏览 0 评论

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。

相关推荐

Java开发中如何优雅地避免OOM(OutOfMemoryError)

Java开发中如何优雅地避免OOM(OutOfMemoryError)在这个信息化高速发展的时代,内存就像程序员手中的笔,缺了它就什么都写不出来。而OOM(OutOfMemoryError)就像是横在...

常见的JVM调优方法和步骤

1、内存调优堆内存设置:通过-Xms和-Xmx参数调整初始和最大堆内存大小-Xms:初始堆大小(如-Xms512M)-Xmx:最大堆大小(如-Xmx2048M)调整新生代和老年代的比例...

Java中9种常见的CMS GC问题分析与解决(一)

目前,互联网上Java的...

JDK21新特性:Prepare to Disallow the Dynamic Loading of Agents

PreparetoDisallowtheDynamicLoadingofAgentsJEP451:准备禁止动态加载代理摘要...

Java程序GC垃圾回收机制优化指南

Java程序GC垃圾回收机制优化指南作为一个Java开发者,我们经常会在任务管理器里看到Java进程占用内存不断增长,然后突然下降的现象。这其实就是在Java虚拟机中运行的垃圾回收(GC)机制在起作用...

Java Java命令学习系列(一)——Jps

jps位于jdk的bin目录下,其作用是显示当前系统的java进程情况,及其id号。jps相当于Solaris进程工具ps。不象”pgrepjava”或”ps-efgrepjava”,jps...

面试题专题:头条一面参考答案(003)

前两篇文章也都是介绍头条一面的内容及参考答案...

Java JVM原理与性能调优:从基础到高级应用

一、JVM基础架构与内存模型1.1JVM整体架构概览Java虚拟机(JVM)是Java程序运行的基石,它由以下几个核心子系统组成:...

死锁攻防战:阿里架构师教你用3种核武器杜绝程序僵死

从线程转储分析到银行家算法,彻底掌握大厂必考的死锁解决方案以下是为Java死锁问题设计的结构化技术解析方案,包含代码级解决方案与高频追问应对策略:...

Java 1.8 虚拟机内存分布详解

Java1.8虚拟机内存分布详解Java1.8的JVM内存布局相比早期版本有显著变化(如永久代被元空间取代)。以下是其核心内存区域的划分、作用及配置参数:一、JVM内存整体结构...

Java 多线程开发难题?这篇文章给你答案!

作为互联网大厂的后端开发人员,在Java多线程开发过程中,必然会面临诸多复杂且具有挑战性的问题。在高并发场景下,各类潜在问题对系统的稳定性与性能产生严重影响,本文将深入探讨这些问题,并提供全面且有...

软件性能调优全攻略:从瓶颈定位到工具应用

性能调优是软件测试中的重要环节,旨在提高系统的响应时间、吞吐量、并发能力、资源利用率,并降低系统崩溃或卡顿的风险。通常,性能调优涉及发现性能瓶颈、分析问题根因、优化代码和系统配置等步骤,调优之前需要先...

JVM性能优化实战技巧

JVM性能优化实战技巧在现代企业级应用开发中,JavaVirtualMachine(JVM)作为承载Java应用程序的核心引擎,其性能直接决定了系统的响应速度、吞吐量以及资源利用率。因此,掌握一些...

JVM 深度解析:运行时数据区域、分代回收与垃圾回收机制全攻略

共同学习,有错欢迎指出。JVM运行时数据区域1.程序计数器程序计数器是一块较小的内存空间,可看作当前线程所执行的字节码的行号指示器。在虚拟机概念模型里,字节码解释器通过改变这个计数器的值选取下一条...

JVM内存管理详解与调优实战

JVM内存管理详解与调优实战Java虚拟机(JVM)作为Java程序运行的核心组件,其内存管理机制直接影响着应用程序的性能表现。今天,咱们就来一场既严肃又有趣的JVM内存管理之旅,看看这个“幕后英雄”...

取消回复欢迎 发表评论: