spring boot大文件与多文件下载

一、简单大文件下载：

/*** 下载大文件* @param path 路径* @param fileName 文件名* @return* @throws IOException*/
public static ResponseEntity<InputStreamResource> downloadFile(String path, String fileName) throws IOException {Path filePath = Paths.get(path);long size = Files.size(filePath);InputStreamResource resource = new InputStreamResource(Files.newInputStream(filePath));HttpHeaders headers = new HttpHeaders();headers.add(HttpHeaders.CONTENT_DISPOSITION, STR."attachment; filename=\{URLEncoder.encode(fileName, StandardCharsets.UTF_8)}");headers.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_OCTET_STREAM_VALUE);headers.add(HttpHeaders.ACCEPT_RANGES, "bytes");return ResponseEntity.ok().headers(headers).contentLength(size).body(resource);
}

二、多文件下载：

/*** 起线程压缩文件，返回流* @param pathList 路径集合* @param fileName 文件名* @return*/
public static ResponseEntity<InputStreamResource> zipByThread(List<String> pathList, String fileName) throws IOException {PipedInputStream pipedInputStream = new PipedInputStream();PipedOutputStream pipedOutputStream = new PipedOutputStream(pipedInputStream);// 启动新线程以写入管道输出流Thread.ofVirtual().start(() -> {try (ZipOutputStream zos = new ZipOutputStream(pipedOutputStream)) {for (String path : pathList) {Path filePath = Paths.get(path);if (Files.exists(filePath)) {if (Files.isDirectory(filePath)) {zipDirectory(filePath, filePath.getFileName().toString(), zos);} else {zipFile(filePath, zos);}}}} catch (IOException e) {log.error("文件压缩失败：{}", e.getMessage());throw new BusinessException("文件压缩失败");} finally {try {pipedOutputStream.close();} catch (IOException _) {}}});HttpHeaders headers = new HttpHeaders();headers.add(HttpHeaders.CONTENT_DISPOSITION, STR."attachment; filename=\{URLEncoder.encode(fileName, StandardCharsets.UTF_8)}");headers.add(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_OCTET_STREAM_VALUE);headers.add(HttpHeaders.CONTENT_LENGTH, String.valueOf(-1));return ResponseEntity.ok().headers(headers).body(new InputStreamResource(pipedInputStream));
}/*** 压缩文件夹* @param folder* @param parentFolder* @param zos* @throws IOException*/
private static void zipDirectory(Path folder, String parentFolder, ZipOutputStream zos) throws IOException {try (Stream<Path> paths = Files.walk(folder)) {paths.filter(Files::isRegularFile).forEach(path -> {String zipEntryName = Paths.get(parentFolder).resolve(folder.relativize(path)).toString().replace("\\", "/");try {zos.putNextEntry(new ZipEntry(zipEntryName));Files.copy(path, zos);zos.closeEntry();} catch (IOException e) {throw new BusinessException("压缩文件夹失败");}});}
}/*** 压缩文件* @param file* @param zos* @throws IOException*/
private static void zipFile(Path file, ZipOutputStream zos) throws IOException {zos.putNextEntry(new ZipEntry(file.getFileName().toString()));Files.copy(file, zos);zos.closeEntry();
}

三、 Reactive WebFlux 实现非阻塞流式传输(推荐)

1.引入依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
2.单文件下载
/*** 响应式流式下载文件，支持断点续传* @param folderPath 文件路径* @param fileName 文件名* @return 响应实体*/
@GetMapping("/download/one")
public Mono<ResponseEntity<Resource>> download(@RequestParam String folderPath,@RequestParam String fileName) throws IOException {// 获取文件Path basePath = Paths.get(folderPath).toAbsolutePath().normalize();Path filePath = basePath.resolve(fileName).normalize();// 校验文件路径，防止访问到其他目录if (!filePath.startsWith(basePath)) {throw new SecurityException("文件路径不在允许的目录内");}// 读取文件Resource resource = new PathResource(filePath);if (!resource.exists()) {return Mono.just(ResponseEntity.notFound().build());}// 获取文件大小long contentLength = resource.contentLength();// 获取文件类型MediaType mediaType = MediaTypeFactory.getMediaType(resource).orElse(MediaType.APPLICATION_OCTET_STREAM);// 响应文件return Mono.just(ResponseEntity.ok().contentType(mediaType).contentLength(contentLength).header(HttpHeaders.ACCEPT_RANGES, "bytes").body(resource));
}
3.多文件下载
/*** 响应式流式下载多个文件，不支持断点续传，因为需要压缩多个文件，长度未知* @param folderPath 文件路径* @param fileNames 文件名列表* @return 响应实体*/
@GetMapping("/download/multiple")
public Mono<ResponseEntity<InputStreamResource>> downloadMultipleFile(@RequestParam String folderPath,@RequestParam List<String> fileNames) throws IOException {// 验证文件路径Path basePath = Paths.get(folderPath).toAbsolutePath().normalize();List<Path> filePaths = new ArrayList<>(fileNames.size());for (String fileName : fileNames) {Path filePath = basePath.resolve(fileName).normalize();if (!filePath.startsWith(basePath)) {throw new SecurityException("文件路径不在允许的目录内");}filePaths.add(filePath);}// 创建管道流PipedOutputStream pos = new PipedOutputStream();PipedInputStream pis = new PipedInputStream(pos, 1024 * 32);// 在单独的线程中执行压缩Thread.ofVirtual().start(() -> {try (ZipOutputStream zos = new ZipOutputStream(pos)) {// 设置压缩级别zos.setLevel(Deflater.BEST_SPEED);for (Path path : filePaths) {if (!Files.exists(path)) {continue;}if (Files.isDirectory(path)) {zipDirectory(path, path.getFileName().toString(), zos);} else {zipFile(path, zos);}}zos.finish();} catch (IOException e) {// 处理错误} finally {try {pos.close();} catch (IOException e) {// 忽略关闭异常}}});HttpHeaders headers = new HttpHeaders();headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);headers.setContentDispositionFormData("attachment", "download.zip");headers.setContentLength(-1);return Mono.just(ResponseEntity.ok().headers(headers).body(new InputStreamResource(pis)));
}/*** 压缩文件夹* @param folder 文件夹路径* @param parentFolder 父文件夹名* @param zos 压缩输出流* @throws IOException 异常*/
private static void zipDirectory(Path folder, String parentFolder, ZipOutputStream zos) throws IOException {try (Stream<Path> paths = Files.walk(folder)) {paths.filter(Files::isRegularFile).forEach(path -> {String zipEntryName = Paths.get(parentFolder).resolve(folder.relativize(path)).toString().replace("\\", "/");try {zos.putNextEntry(new ZipEntry(zipEntryName));Files.copy(path, zos);zos.closeEntry();} catch (IOException e) {throw new RuntimeException("压缩文件夹失败");}});}
}/*** 压缩文件* @param file 文件路径* @param zos 压缩输出流* @throws IOException 异常*/
private static void zipFile(Path file, ZipOutputStream zos) throws IOException {zos.putNextEntry(new ZipEntry(file.getFileName().toString()));Files.copy(file, zos);zos.closeEntry();
}

注意

如果使用了nginx反代，下载超时需要在nginx配置

proxy_buffering off;

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

第二节：React 基础篇-受控组件 vs 非受控组件

第二节：React 基础篇-受控组件 vs 非受控组件

一、场景题&#xff1a;设计一个实时搜索输入框&#xff0c;说明选择依据 受控组件 vs 非受控组件 核心区别 特征受控组件非受控组件数据管理由React状态&#xff08;state&#xff09;控制通过DOM元素&#xff08;ref&#xff09;直接访问更新时机每次输入触发onChange提交…
阅读更多...
局部路由守卫

局部路由守卫

局部路由守卫为我们提供了更细粒度的路由控制&#xff0c;允许我们在特定的路由或组件级别添加鉴权和逻辑处理。局部路由守卫分为 path 守卫和 component 守卫&#xff0c;它们分别适用于不同的场景。 path 守卫&#xff08;路由守卫&#xff09; path 守卫用于在进入特定路由…
阅读更多...
Android 16应用适配指南

Android 16应用适配指南

Android 16版本特性介绍 https://developer.android.com/about/versions/16?hlzh-cn Android 16 所有功能和 API 概览 https://developer.android.com/about/versions/16/features?hlzh-cn#language-switching Android 16 发布时间 Android 16 适配指南 Google开发平台&…
阅读更多...
android display 笔记（十二）CPU，GPU,DPU的区别

android display 笔记（十二）CPU，GPU,DPU的区别

CPU&#xff08;Central Processing Unit&#xff09;通用计算&#xff1a;处理复杂逻辑、分支预测、多任务调度。 低延迟&#xff1a;优先快速响应单线程任务。 GPU&#xff08;Graphics Processing Unit&#xff09; 高吞吐量并行计算&#xff1a;适合大规模数据并行处理。…
阅读更多...
音频转文本：如何识别音频成文字

音频转文本：如何识别音频成文字

Python脚本：MP4转MP3并语音识别为中文 以下是一个完整的Python脚本，可以将MP4视频转换为MP3音频，然后使用语音识别模型将音频转换为中文文本。 准备工作 首先需要安装必要的库： pip install moviepy pydub SpeechRecognition openai-whisper完整脚本 import os from m…
阅读更多...
理解 MCP 协议的数据传递：HTTP 之上的一层“壳子

理解 MCP 协议的数据传递：HTTP 之上的一层“壳子

以下是以 CSDN 博客的风格记录你对 MCP 协议数据传递的理解和发现&#xff0c;内容涵盖了 MCP 协议基于 HTTP 的本质、JSON-RPC 的“壳子”作用&#xff0c;以及为什么熟悉 HTTP 协议就足以理解 MCP 的数据传递。文章面向技术社区&#xff0c;结构清晰&#xff0c;适合分享。 理…
阅读更多...
基于ssm网络游戏推荐系统(源码+lw+部署文档+讲解)，源码可白嫖!

基于ssm网络游戏推荐系统(源码+lw+部署文档+讲解)，源码可白嫖!

摘要 当今社会进入了科技进步、经济社会快速发展的新时代。国际信息和学术交流也不断加强&#xff0c;计算机技术对经济社会发展和人民生活改善的影响也日益突出&#xff0c;人类的生存和思考方式也产生了变化。传统网络游戏管理采取了人工的管理方法&#xff0c;但这种管理方…
阅读更多...
vue入门：指令

vue入门：指令

文章目录 vue的内置指令说明&#xff1a; 自定义指令 vue的内置指令 Vue 指令的本质是&#xff1a; 声明式的 DOM 操作接口&#xff08;隐藏底层 JavaScript 代码&#xff09;。响应式数据的绑定媒介&#xff08;连接数据和视图&#xff09;。模板编译的标记&#xff08;最终…
阅读更多...
oracle 索引失效

oracle 索引失效

在 Oracle 11g 中&#xff0c;索引失效的常见原因包括函数修改列、隐式类型转换、统计信息过时等&#xff0c;解决方法需结合版本特性&#xff08;如虚拟列、索引跳跃扫描&#xff09;。通过执行计划分析、统计信息维护和合理使用提示&#xff08;Hints&#xff09;&#xff0c…
阅读更多...
k8s蓝绿发布

k8s蓝绿发布

k8s蓝绿发布 什么是蓝绿部署K8S中如何实现蓝绿部署k8s蓝绿部署流程图 什么是蓝绿部署 参考: https://youtu.be/CLq_hA0lAd0 https://help.coding.net/docs/cd/best-practice/blue-green.html 蓝绿部署最早是由马丁福勒 2010年在他的博客中提出. 蓝绿部署是一种软件部署策略,用…
阅读更多...
stm32面试

stm32面试

数据结构相关问题 stm32面试 数据结构相关问题 目录基础数据结构树与图排序与查找算法 Linux相关问题Linux系统基础Linux命令与脚本Linux网络与服务 操作系统相关问题操作系统基础概念操作系统调度算法操作系统同步与通信 STM32相关问题STM32硬件基础STM32编程与开发STM32应用与…
阅读更多...
Mybatis 中 mappers标签 package的使用

Mybatis 中 mappers标签 package的使用

MyBatis 的配置文件中&#xff0c;<mappers> 标签用于指定 MyBatis 应该加载哪些映射器&#xff08;Mapper&#xff09;。其中 package 属性是一种便捷的方式来批量注册多个映射器接口 package 属性允许你指定一个包名&#xff0c;MyBatis 会自动扫描该包下的所有映射器…
阅读更多...
设计模式 --- 访问者模式

设计模式 --- 访问者模式

访问者模式是一种行为设计模式&#xff0c;它允许在不改变对象结构的前提下&#xff0c;定义作用于这些对象元素的新操作。 优点&#xff1a; 1.​​符合开闭原则&#xff1a;新增操作只需添加新的访问者类&#xff0c;无需修改现有对象结构。 ​​2.操作逻辑集中管理​​&am…
阅读更多...
监控docker中的java应用

监控docker中的java应用

1)进入指定的容器 docker exec -it demo /bin/bash 2)下载curl root89a67e345354:/# apt install curl -y 3)下载arthas root89a67e345354:/# curl -O https://arthas.aliyun.com/arthas-boot.jar 4)运行 root89a67e345354:/# java -jar arthas-boot.jar 5)监控 […
阅读更多...
最新版RubyMine超详细图文安装教程，带补丁包（2025最新版保姆级教程）

最新版RubyMine超详细图文安装教程，带补丁包（2025最新版保姆级教程）

目录 前言 一、RubyMine最新版下载 二、RubyMine安装 三、RubyMine补丁 四、运行RubyMine 前言 RubyMine是由JetBrains开发的集成开发环境&#xff08;IDE&#xff09;&#xff0c;专为Ruby和Ruby on Rails开发者设计&#xff0c;提供智能代码补全、调试、测试、版本控制集…
阅读更多...
数字政府与智慧城市区别报告分析

数字政府与智慧城市区别报告分析

数字政府与智慧城市区别报告分析 一、引言 随着信息技术的飞速发展&#xff0c;数字政府和智慧城市成为推动城市现代化和治理能力提升的两个重要概念。虽然它们都依托于信息技术&#xff0c;但二者在目标、内涵、实施路径等方面存在显著差异。本文旨在深入探讨数字政府与智慧…
阅读更多...
[MRCTF2020]ezpop wp

[MRCTF2020]ezpop wp

本题考点:php反序列化的pop链 首先来了解一下pop链是什么,它类似于多米诺骨牌一环套一环,要调用这个成员方法然后去找能调用这个方法的魔术方法,最后一环接一环,完成一个链子,最终形成payload。 那么来了解一下这些魔术方法 __construct() //类的构造函数&#xff0…
阅读更多...
spark架构和RDD相关概念

spark架构和RDD相关概念

运行架构&#xff1a; Spark采用master - slave结构&#xff0c;Driver作为master负责作业任务调度&#xff0c;Executor作为slave负责实际执行任务。 核心组件 Driver&#xff1a;执行Spark任务的main方法&#xff0c;将用户程序转化为作业&#xff0c;在Executor间调度任务&…
阅读更多...
安全是基石

安全是基石

“安全是基石”这句话强调了安全在个人、企业、社会等各个层面中的基础性和不可替代的重要性。无论是物理安全、网络安全、数据安全&#xff0c;还是生产安全、公共安全&#xff0c;都是保障稳定发展的前提。以下是不同领域中“安全”作为基石的体现&#xff1a; 1. 个人安全 基…
阅读更多...
Linux Makefile-概述、语句格式、编写规则、多文件编程、Makefile变量分类：自定义变量、预定义变量

Linux Makefile-概述、语句格式、编写规则、多文件编程、Makefile变量分类：自定义变量、预定义变量

目录 1.make 1.1 make 命令格式 2.Makefile 核心概念‌ ‌ 2.1创建并运行 Makefile步骤 3. Makefile编写 3.1最基础Makefile 3.1.1使用默认make命令 3.1.2使用make -f 命令 3.1.2.1 使用make -f 命令执行默认make操作 3.1.2.2使用 make [ ‐f file ] [ targets ]命令 …
阅读更多...
最新文章

Copyright @ 2022~2023