SpringBoot大文件上传如何做到断点续传？-编程实验室

大文件传输系统建设方案

一、项目背景与需求分析

作为山西某大型国企上市公司的项目负责人，我司目前承担着集团级大文件传输平台建设任务。客户群体涵盖部委、政府部门及大型央企，对系统安全性、稳定性及兼容性提出严苛要求。经详细调研，核心需求如下：

（一）功能需求

大文件传输：支持单文件100GB级传输，含文件夹上传/下载（保留层级结构）
断点续传：需突破浏览器限制，实现跨会话进度持久化（含IE8兼容）
安全体系：
- 传输加密：SM4/AES双算法支持
- 存储加密：透明加密机制
- 信创适配：全栈国产化环境支持
性能指标：
- 下载速度≥50MB/s（100G文件）
- 并发处理能力≥1000用户

（二）技术约束

开发环境：
- 后端：SpringBoot 2.7.x
- 前端：Vue2 CLI（需兼容JSP/.NET WebForm）
- 数据库：Oracle/达梦/人大金仓动态配置
部署环境：
- 操作系统：Windows7(IE8)/统信UOS/银河麒麟
- 云存储：华为OBS（混合云动态配置）
合规要求：
- 信创认证：通过党政机关采购名录
- 源代码授权：预算≤160万（集团永久使用）

二、技术方案设计

（一）系统架构

（二）核心模块实现

1. 前端实现（Vue2 + WebSocket）

// file-uploader.vue 核心片段exportdefault{data(){return{chunkSize:10*1024*1024,// 10MB分片ws:null,progressMap:newMap()// 持久化进度存储}},methods:{// 初始化WebSocket连接（兼容IE8）initWebSocket(fileId){if(window.WebSocket){this.ws=newWebSocket(`wss://${location.host}/ws/upload/${fileId}`);}elseif(window.MozWebSocket){this.ws=newMozWebSocket(`wss://${location.host}/ws/upload/${fileId}`);}else{// IE8降级方案this.fallbackUpload(fileId);return;}this.ws.onmessage=(e)=>{constdata=JSON.parse(e.data);if(data.type==='progress'){this.progressMap.set(data.chunkId,data.percent);this.saveProgressToLocalStorage();}};},// 本地存储进度（兼容IE8）saveProgressToLocalStorage(){try{if(window.localStorage){localStorage.setItem('uploadProgress',JSON.stringify(Array.from(this.progressMap)));}else{// IE8使用userData存储constuserData=document.createElement('input');userData.addBehavior('#default#userData');userData.setAttribute('uploadProgress',JSON.stringify(Array.from(this.progressMap)));userData.save('FileUploadData');}}catch(e){console.error('Progress save failed:',e);}},// 文件分片上传（支持文件夹）asyncuploadFile(file,path=''){constfileId=this.generateFileId(file);consttotalChunks=Math.ceil(file.size/this.chunkSize);// 从本地恢复进度this.loadProgressFromLocalStorage(fileId);for(leti=0;i<totalChunks;i++){if(this.progressMap.has(`${fileId}-${i}`))continue;constchunk=file.slice(i*this.chunkSize,(i+1)*this.chunkSize);constformData=newFormData();formData.append('file',chunk);formData.append('chunkIndex',i);formData.append('totalChunks',totalChunks);formData.append('relativePath',path);try{awaitaxios.post(`/api/upload/${fileId}`,formData,{headers:{'X-Encryption-Type':'SM4'// 加密标识},onUploadProgress:(progressEvent)=>{constpercent=Math.round((progressEvent.loaded*100)/progressEvent.total);this.progressMap.set(`${fileId}-${i}`,percent);this.saveProgressToLocalStorage();}});}catch(e){console.error(`Chunk${i}upload failed`,e);throwe;}}// 通知服务端合并文件awaitaxios.post('/api/merge',{fileId,fileName:file.name,relativePath:path});},// 文件夹上传（递归处理）asyncuploadFolder(folderEntry,currentPath=''){constreader=folderEntry.createReader();constentries=awaitnewPromise((resolve)=>{reader.readEntries(resolve);});for(constentryofentries){if(entry.isFile){constfile=awaitnewPromise((resolve)=>{entry.file(resolve);});awaitthis.uploadFile(file,`${currentPath}/${entry.name}`);}elseif(entry.isDirectory){awaitthis.uploadFolder(entry,`${currentPath}/${entry.name}`);}}}}}

2. 后端实现（SpringBoot）

// FileUploadController.java 核心片段@RestController@RequestMapping("/api")publicclassFileUploadController{@AutowiredprivateFileStorageServicestorageService;@AutowiredprivateEncryptionServiceencryptionService;// 文件分片上传@PostMapping("/upload/{fileId}")publicResponseEntity>uploadChunk(@PathVariableStringfileId,@RequestParam("file")MultipartFilefile,@RequestParamintchunkIndex,@RequestParaminttotalChunks,@RequestHeader("X-Encryption-Type")StringencryptionType){try{// 1. 解密处理byte[]decryptedData;if("SM4".equals(encryptionType)){decryptedData=encryptionService.sm4Decrypt(file.getBytes());}else{decryptedData=encryptionService.aesDecrypt(file.getBytes());}// 2. 存储分片StringchunkPath=storageService.storeChunk(fileId,chunkIndex,decryptedData,totalChunks);// 3. 返回进度信息Mapresponse=newHashMap<>();response.put("chunkIndex",chunkIndex);response.put("status","SUCCESS");returnResponseEntity.ok(response);}catch(Exceptione){returnResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(Collections.singletonMap("error",e.getMessage()));}}// 合并文件@PostMapping("/merge")publicResponseEntitymergeFile(@RequestBodyMergeRequestrequest){try{// 验证所有分片是否存在if(!storageService.allChunksExist(request.getFileId(),request.getTotalChunks())){returnResponseEntity.badRequest().body("Missing chunks");}// 合并文件StringfinalPath=storageService.mergeFile(request.getFileId(),request.getFileName(),request.getRelativePath());// 返回下载URLreturnResponseEntity.ok(finalPath);}catch(Exceptione){returnResponseEntity.internalServerError().body(e.getMessage());}}// WebSocket进度推送（IE8降级方案）@GetMapping("/ws/upload/{fileId}")publicWebSocketHandlerhandleWebSocket(@PathVariableStringfileId){returnsession->{// 实现自定义业务逻辑};}}

3. 信创适配层

// 国密加密实现publicclassSM4EncryptionServiceimplementsEncryptionService{privatestaticfinalStringSM4_KEY="your-32-byte-sm4-key";// 实际应从安全配置读取@Overridepublicbyte[]encrypt(byte[]data)throwsException{SM4Engineengine=newSM4Engine();PaddedBufferedBlockCiphercipher=newPaddedBufferedBlockCipher(newCBCBlockCipher(engine),newPKCS7Padding());byte[]keyBytes=SM4_KEY.getBytes(StandardCharsets.UTF_8);byte[]iv=newbyte[engine.getBlockSize()];// 实际应从安全配置读取cipher.init(true,newParametersWithIV(newKeyParameter(keyBytes),iv));byte[]output=newbyte[cipher.getOutputSize(data.length)];intlen=cipher.processBytes(data,0,data.length,output,0);len+=cipher.doFinal(output,len);returnArrays.copyOf(output,len);}@Overridepublicbyte[]decrypt(byte[]encryptedData)throwsException{// 实现解密逻辑（与encrypt对称）// ...}}

三、供应商选型建议

基于集团需求，建议从以下维度评估供应商：

（一）资质要求

信创认证：
- 党政机关采购名录入围证明
- 国产操作系统兼容性认证（统信UOS/麒麟等）
- 国产数据库适配认证（达梦/人大金仓）
安全资质：
- 等保三级认证
- 国密算法实现合规证明
- 源代码安全审计报告

（二）技术能力

核心功能：
- 必须提供文件夹层级结构传输实现
- 需展示IE8兼容性测试报告
- 需提供100G文件传输压力测试报告
开发支持：
- 提供完整的SpringBoot集成示例
- 支持Vue2/JSP/.NET WebForm多前端框架
- 提供信创环境部署手册

（三）商务条款

授权模式：
- 永久源代码授权（集团内无限使用）
- 包含5年免费升级服务
- 提供源码同步更新机制
成功案例：
- 至少3个央企/部委级案例
- 提供合同关键页复印件
- 提供客户联系方式供实地考察

四、实施路线图

阶段	周期	交付物
需求确认	2周	详细需求规格说明书
技术选型	3周	供应商评估报告
原型开发	4周	可运行演示系统
信创适配	6周	全栈国产化环境验证
试点部署	2周	客户现场压力测试
全面推广	持续	集团级部署手册

五、风险控制

技术风险：
- 建立双开发团队（自研+供应商）
- 要求供应商提供7×24小时技术支持
- 预留20%预算用于技术攻关
合规风险：
- 引入第三方安全审计
- 关键代码段进行混淆处理
- 建立源代码版本追溯机制
商务风险：
- 分阶段付款（30%-40%-30%）
- 明确违约赔偿条款
- 要求供应商提供银行履约保函

本方案已充分考虑政府客户特有的安全合规要求，通过分层架构设计实现技术解耦，确保系统既能满足当前需求，又具备未来5年的技术演进能力。建议尽快启动供应商评估流程，确保在Q3前完成试点部署。

SQL示例

创建数据库

配置数据库连接

自动下载maven依赖

启动项目

启动成功

访问及测试

默认页面接口定义

在浏览器中访问

数据表中的数据

效果预览

文件上传

文件刷新续传

支持离线保存文件进度，在关闭浏览器，刷新浏览器后进行不丢失，仍然能够继续上传

文件夹上传

支持上传文件夹并保留层级结构，同样支持进度信息离线保存，刷新页面，关闭页面，重启系统不丢失上传进度。

批量下载

支持文件批量下载

下载续传

文件下载支持离线保存进度信息，刷新页面，关闭页面，重启系统均不会丢失进度信息。

文件夹下载

支持下载文件夹，并保留层级结构，不打包，不占用服务器资源。

示例下载

下载完整示例